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

Interface MapJoinTableContainer.ReusableGetAdaptor

Enclosing interface:

MapJoinTableContainer

public static interface MapJoinTableContainer.ReusableGetAdaptor

Retrieve rows from hashtable key by key, one key at a time, w/o copying the structures for each key. "Old" HashMapWrapper will still create/retrieve new objects for java HashMap; but the optimized one doesn't have to.

Method Summary

Methods

Modifier and Type	Method and Description
Object[]	getCurrentKey()
MapJoinRowContainer	getCurrentRows()
boolean	hasAnyNulls(int fieldCount, boolean[] nullsafes) Checks whether the current key has any nulls.
JoinUtil.JoinResult	setFromOther(MapJoinTableContainer.ReusableGetAdaptor other) Changes current rows to which adaptor is referring to the rows corresponding to the key that another adaptor has already deserialized via setFromVector/setFromRow.
JoinUtil.JoinResult	setFromRow(Object row, List<ExprNodeEvaluator> fields, List<ObjectInspector> ois) Changes current rows to which adaptor is referring to the rows corresponding to the key represented by a row object, and fields and ois used to interpret it.
JoinUtil.JoinResult	setFromVector(VectorHashKeyWrapper kw, VectorExpressionWriter[] keyOutputWriters, VectorHashKeyWrapperBatch keyWrapperBatch) Changes current rows to which adaptor is referring to the rows corresponding to the key represented by a VHKW object, and writers and batch used to interpret it.

Method Detail

setFromVector

JoinUtil.JoinResult setFromVector(VectorHashKeyWrapper kw,
                                VectorExpressionWriter[] keyOutputWriters,
                                VectorHashKeyWrapperBatch keyWrapperBatch)
                                  throws HiveException

Changes current rows to which adaptor is referring to the rows corresponding to the key represented by a VHKW object, and writers and batch used to interpret it.

Throws:

HiveException

setFromRow

JoinUtil.JoinResult setFromRow(Object row,
                             List<ExprNodeEvaluator> fields,
                             List<ObjectInspector> ois)
                               throws HiveException

Changes current rows to which adaptor is referring to the rows corresponding to the key represented by a row object, and fields and ois used to interpret it.

Throws:

HiveException

setFromOther

JoinUtil.JoinResult setFromOther(MapJoinTableContainer.ReusableGetAdaptor other)
                                 throws HiveException

Changes current rows to which adaptor is referring to the rows corresponding to the key that another adaptor has already deserialized via setFromVector/setFromRow.

Throws:

HiveException

hasAnyNulls

boolean hasAnyNulls(int fieldCount,
                  boolean[] nullsafes)

Checks whether the current key has any nulls.

getCurrentRows

MapJoinRowContainer getCurrentRows()

Returns:

The container w/the rows corresponding to a key set via a previous set... call.

getCurrentKey

Object[] getCurrentKey()

Returns:

key