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

Class UnwrapRowContainer

java.lang.Object

org.apache.hadoop.hive.ql.exec.persistence.UnwrapRowContainer

All Implemented Interfaces:

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

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

Unwraps values from current key with valueIndex in mapjoin desc

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
UnwrapRowContainer(byte alias, int[] valueIndex, ObjectInspectorConverters.Converter[] converters, boolean tagged)

Method Summary

Modifier and Type	Method and Description
void	addRow(List<Object> t) add a row into the RowContainer
void	addRow(Object[] value)
void	clearRows() Remove all elements in the RowContainer.
MapJoinRowContainer	copy()
List<Object>	first()
byte	getAliasFilter()
boolean	hasRows()
boolean	isSingleRow()
List<Object>	next()
int	rowCount()
AbstractRowContainer.RowIterator<List<Object>>	rowIter()
MapJoinRowContainer	setInternal(MapJoinRowContainer internal, Object[] currentKey)
String	toString()
void	write(MapJoinObjectSerDeContext valueContext, ObjectOutputStream out)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

UnwrapRowContainer

public UnwrapRowContainer(byte alias,
                          int[] valueIndex,
                          ObjectInspectorConverters.Converter[] converters,
                          boolean tagged)

Method Detail

setInternal

public MapJoinRowContainer setInternal(MapJoinRowContainer internal,
                                       Object[] currentKey)

first

public List<Object> first()
                   throws HiveException

Specified by:

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

Throws:

HiveException

next

public List<Object> next()
                  throws HiveException

Specified by:

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

Throws:

HiveException

rowIter

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

Specified by:

rowIter in interface AbstractRowContainer<List<Object>>

Throws:

HiveException

addRow

public void addRow(List<Object> t)
            throws HiveException

Description copied from interface: AbstractRowContainer

add a row into the RowContainer

Specified by:

addRow in interface AbstractRowContainer<List<Object>>

Parameters:

t - row

Throws:

HiveException

hasRows

public boolean hasRows()
                throws HiveException

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.

Throws:

HiveException

isSingleRow

public boolean isSingleRow()
                    throws HiveException

Specified by:

isSingleRow in interface AbstractRowContainer<List<Object>>

Returns:

whether the row container has 1 row.

Throws:

HiveException

rowCount

public int rowCount()
             throws HiveException

Specified by:

rowCount in interface AbstractRowContainer<List<Object>>

Returns:

number of elements in the RowContainer

Throws:

HiveException

clearRows

public void clearRows()
               throws HiveException

Description copied from interface: AbstractRowContainer

Remove all elements in the RowContainer.

Specified by:

clearRows in interface AbstractRowContainer<List<Object>>

Throws:

HiveException

getAliasFilter

public byte getAliasFilter()
                    throws HiveException

Specified by:

getAliasFilter in interface MapJoinRowContainer

Throws:

HiveException

copy

public MapJoinRowContainer copy()
                         throws HiveException

Specified by:

copy in interface MapJoinRowContainer

Throws:

HiveException

addRow

public void addRow(Object[] value)
            throws HiveException

Specified by:

addRow in interface MapJoinRowContainer

Throws:

HiveException

write

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

Specified by:

write in interface MapJoinRowContainer

Throws:

IOException

SerDeException

toString

public String toString()

Overrides:

toString in class Object