org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators

Class POPackage.POPackageTupleBuffer

java.lang.Object

org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPackage.POPackageTupleBuffer

All Implemented Interfaces:

AccumulativeTupleBuffer

Enclosing class:

POPackage

public class POPackage.POPackageTupleBuffer
extends java.lang.Object
implements AccumulativeTupleBuffer

Constructor Summary

Constructors

Constructor and Description
POPackageTupleBuffer(int batchSize, java.lang.Object key, java.util.Iterator<NullableTuple> iter)

Method Summary

Modifier and Type	Method and Description
void	clear() Clear internal buffer, this should be called after all data are retreived
java.util.Iterator<Tuple>	getTuples(int index) Get iterator of tuples in the buffer
boolean	hasNextBatch() Whether there are more tuples to pull out of iterator
Tuple	illustratorMarkup(java.lang.Object in, java.lang.Object out, int eqClassIndex)
void	nextBatch() Pull next batch of tuples from iterator and put them into this buffer

Methods inherited from class java.lang.Object

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

Constructor Detail

POPackageTupleBuffer

public POPackageTupleBuffer(int batchSize,
                            java.lang.Object key,
                            java.util.Iterator<NullableTuple> iter)

Method Detail

hasNextBatch

public boolean hasNextBatch()

Description copied from interface: AccumulativeTupleBuffer

Whether there are more tuples to pull out of iterator

Specified by:

hasNextBatch in interface AccumulativeTupleBuffer

nextBatch

public void nextBatch()
               throws java.io.IOException

Description copied from interface: AccumulativeTupleBuffer

Pull next batch of tuples from iterator and put them into this buffer

Specified by:

nextBatch in interface AccumulativeTupleBuffer

Throws:

java.io.IOException

clear

public void clear()

Description copied from interface: AccumulativeTupleBuffer

Clear internal buffer, this should be called after all data are retreived

Specified by:

clear in interface AccumulativeTupleBuffer

getTuples

public java.util.Iterator<Tuple> getTuples(int index)

Description copied from interface: AccumulativeTupleBuffer

Get iterator of tuples in the buffer

Specified by:

getTuples in interface AccumulativeTupleBuffer

Parameters:

index - the index of tuple

illustratorMarkup

public Tuple illustratorMarkup(java.lang.Object in,
                               java.lang.Object out,
                               int eqClassIndex)