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

Interface MapJoinTableContainer

All Known Subinterfaces:

MapJoinPersistableTableContainer, VectorMapJoinTableContainer

All Known Implementing Classes:

AbstractMapJoinTableContainer, HashMapWrapper, HybridHashTableContainer, MapJoinBytesTableContainer, VectorMapJoinFastTableContainer

public interface MapJoinTableContainer

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	MapJoinTableContainer.ReusableGetAdaptor Retrieve rows from hashtable key by key, one key at a time, w/o copying the structures for each key.

Method Summary

Methods

Modifier and Type	Method and Description
void	clear() Clears the contents of the table.
MapJoinTableContainer.ReusableGetAdaptor	createGetter(MapJoinKey keyTypeFromLoader) Creates reusable get adaptor that can be used to retrieve rows from the table based on either vectorized or non-vectorized input rows to MapJoinOperator.
void	dumpMetrics()
MapJoinKey	getAnyKey()
boolean	hasSpill() Checks if the container has spilled any data onto disk.
MapJoinKey	putRow(MapJoinObjectSerDeContext keyContext, org.apache.hadoop.io.Writable currentKey, MapJoinObjectSerDeContext valueContext, org.apache.hadoop.io.Writable currentValue) Adds row from input to the table.
void	seal() Indicates to the container that the puts have ended; table is now r/o.

Method Detail

putRow

MapJoinKey putRow(MapJoinObjectSerDeContext keyContext,
                org.apache.hadoop.io.Writable currentKey,
                MapJoinObjectSerDeContext valueContext,
                org.apache.hadoop.io.Writable currentValue)
                  throws SerDeException,
                         HiveException,
                         IOException

Adds row from input to the table.

Throws:

SerDeException

HiveException

IOException

seal

void seal()

Indicates to the container that the puts have ended; table is now r/o.

createGetter

MapJoinTableContainer.ReusableGetAdaptor createGetter(MapJoinKey keyTypeFromLoader)

Creates reusable get adaptor that can be used to retrieve rows from the table based on either vectorized or non-vectorized input rows to MapJoinOperator.

Parameters:

keyTypeFromLoader - Last key from hash table loader, to determine key type used when loading hashtable (if it can vary).

clear

void clear()

Clears the contents of the table.

getAnyKey

MapJoinKey getAnyKey()

dumpMetrics

void dumpMetrics()

hasSpill

boolean hasSpill()

Checks if the container has spilled any data onto disk. This is only applicable for HybridHashTableContainer.