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

Constructors

Constructor and Description
MapJoinEagerRowContainer()

Method Summary

Methods

Modifier and Type	Method and Description
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()
boolean	hasRows()
boolean	isSingleRow()
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

clone, equals, finalize, 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>>

hasRows

public boolean hasRows()

Specified by:

hasRows in interface AbstractRowContainer<List<Object>>

Returns:

whether the row container has at least 1 row. NOTE: Originally we named this isEmpty, but that name conflicted with another interface.

isSingleRow

public boolean isSingleRow()

Specified by:

isSingleRow in interface AbstractRowContainer<List<Object>>

Returns:

whether the row container has 1 row.

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