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

Class KeyValueContainer

java.lang.Object

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

public class KeyValueContainer
extends Object

An eager key/value container that puts every row directly to output stream. Kryo is used for the serialization/deserialization. When reading, we load IN_MEMORY_NUM_ROWS rows from input stream to memory batch by batch.

Constructor Summary

Constructors

Constructor and Description
KeyValueContainer()

Method Summary

Methods

Modifier and Type	Method and Description
void	add(HiveKey key, org.apache.hadoop.io.BytesWritable value)
void	clear()
boolean	hasNext()
ObjectPair<HiveKey,org.apache.hadoop.io.BytesWritable>	next()
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

KeyValueContainer

public KeyValueContainer()

Method Detail

add

public void add(HiveKey key,
       org.apache.hadoop.io.BytesWritable value)

clear

public void clear()

hasNext

public boolean hasNext()

next

public ObjectPair<HiveKey,org.apache.hadoop.io.BytesWritable> next()

size

public int size()