public interface MapJoinTableContainer extends MemoryEstimate
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.
|
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(org.apache.hadoop.io.Writable currentKey,
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.
|
void |
setSerde(MapJoinObjectSerDeContext keyCtx,
MapJoinObjectSerDeContext valCtx) |
int |
size()
Return the size of the hash table
|
getEstimatedMemorySize
MapJoinKey putRow(org.apache.hadoop.io.Writable currentKey, org.apache.hadoop.io.Writable currentValue) throws SerDeException, HiveException, IOException
SerDeException
HiveException
IOException
void seal()
MapJoinTableContainer.ReusableGetAdaptor createGetter(MapJoinKey keyTypeFromLoader)
keyTypeFromLoader
- Last key from hash table loader, to determine key type used
when loading hashtable (if it can vary).void clear()
MapJoinKey getAnyKey()
void dumpMetrics()
boolean hasSpill()
int size()
void setSerde(MapJoinObjectSerDeContext keyCtx, MapJoinObjectSerDeContext valCtx) throws SerDeException
SerDeException
Copyright © 2022 The Apache Software Foundation. All rights reserved.