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

Class ObjectContainer<ROW>

java.lang.Object

org.apache.hadoop.hive.ql.exec.persistence.ObjectContainer<ROW>

public class ObjectContainer<ROW>
extends Object

An eager object container that puts every row directly to output stream. The object can be of any type. 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
ObjectContainer(String spillLocalDirs)

Method Summary

Modifier and Type	Method and Description
void	add(ROW row)
void	clear()
boolean	hasNext()
ROW	next()
int	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

ObjectContainer

public ObjectContainer(String spillLocalDirs)

Method Detail

add

public void add(ROW row)

clear

public void clear()

hasNext

public boolean hasNext()

next

public ROW next()

size

public int size()