org.apache.hadoop.hive.ql.exec.persistence
Class MapJoinEagerRowContainer

java.lang.Object
  org.apache.hadoop.hive.ql.exec.persistence.MapJoinEagerRowContainer

All Implemented Interfaces:

AbstractRowContainer<List<Object>>, AbstractRowContainer.RowIterator<List<Object>>, MapJoinRowContainer

public class MapJoinEagerRowContainer
extends Object
implements MapJoinRowContainer, AbstractRowContainer.RowIterator<List<Object>>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hive.ql.exec.persistence.AbstractRowContainer

AbstractRowContainer.RowIterator<ROW>

Constructor Summary

MapJoinEagerRowContainer()

Method Summary

void	addRow(List<Object> t) add a row into the RowContainer
void	addRow(Object[] t)
void	clearRows() Remove all elements in the RowContainer.
MapJoinRowContainer	copy()
List<Object>	first()
byte	getAliasFilter()
List<Object>	next()
void	read(MapJoinObjectSerDeContext context, ObjectInputStream in, org.apache.hadoop.io.Writable container)
void	read(MapJoinObjectSerDeContext context, org.apache.hadoop.io.Writable currentValue)
int	rowCount() Get the number of elements in the RowContainer.
AbstractRowContainer.RowIterator<List<Object>>	rowIter()
void	write(MapJoinObjectSerDeContext context, ObjectOutputStream out)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MapJoinEagerRowContainer

public MapJoinEagerRowContainer()

Method Detail

addRow

public void addRow(List<Object> t)

Description copied from interface: AbstractRowContainer

add a row into the RowContainer

Specified by:

addRow in interface AbstractRowContainer<List<Object>>

Parameters:

t - row

addRow

public void addRow(Object[] t)

Specified by:

addRow in interface MapJoinRowContainer

rowIter

public AbstractRowContainer.RowIterator<List<Object>> rowIter()

Specified by:

rowIter in interface AbstractRowContainer<List<Object>>

first

public List<Object> first()

Specified by:

first in interface AbstractRowContainer.RowIterator<List<Object>>

next

public List<Object> next()

Specified by:

next in interface AbstractRowContainer.RowIterator<List<Object>>

rowCount

public int rowCount()

Get the number of elements in the RowContainer.

Specified by:

rowCount in interface AbstractRowContainer<List<Object>>

Returns:

number of elements in the RowContainer

clearRows

public void clearRows()

Remove all elements in the RowContainer.

Specified by:

clearRows in interface AbstractRowContainer<List<Object>>

getAliasFilter

public byte getAliasFilter()

Specified by:

getAliasFilter in interface MapJoinRowContainer

copy

public MapJoinRowContainer copy()

Specified by:

copy in interface MapJoinRowContainer

read

public void read(MapJoinObjectSerDeContext context,
                 ObjectInputStream in,
                 org.apache.hadoop.io.Writable container)
          throws IOException,
                 SerDeException

Throws:

IOException

SerDeException

read

public void read(MapJoinObjectSerDeContext context,
                 org.apache.hadoop.io.Writable currentValue)
          throws SerDeException

Throws:

SerDeException

write

public void write(MapJoinObjectSerDeContext context,
                  ObjectOutputStream out)
           throws IOException,
                  SerDeException

Specified by:

write in interface MapJoinRowContainer

Throws:

IOException

SerDeException