cascading.tap.partition

Class BasePartitionTap.PartitionCollector

java.lang.Object

cascading.tuple.TupleEntryCollector

cascading.tap.partition.BasePartitionTap.PartitionCollector

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

Enclosing class:

BasePartitionTap<Config,Input,Output>

public class BasePartitionTap.PartitionCollector
extends TupleEntryCollector

Field Summary

Fields inherited from class cascading.tuple.TupleEntryCollector

tupleEntry

Constructor Summary

Constructors

Constructor and Description
PartitionCollector(FlowProcess<? extends Config> flowProcess)

Method Summary

Modifier and Type	Method and Description
void	close() Method close closes the underlying resource being written to.
void	closeCollector(java.lang.String path)
protected void	collect(TupleEntry tupleEntry)

Methods inherited from class cascading.tuple.TupleEntryCollector

add, add, addTuple, addTupleEntry, setFields

Methods inherited from class java.lang.Object

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

Constructor Detail

PartitionCollector

public PartitionCollector(FlowProcess<? extends Config> flowProcess)

Method Detail

close

public void close()

Description copied from class: TupleEntryCollector

Method close closes the underlying resource being written to.

This method should be called when when an instance is returned via Tap.openForWrite(cascading.flow.FlowProcess) and no more Tuple instances will be written out.

This method must not be called when an instance is returned from getOutputCollector() from any of the relevant OperationCall implementations (inside a Function, Aggregator, or Buffer).

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Overrides:

close in class TupleEntryCollector

closeCollector

public void closeCollector(java.lang.String path)

collect

protected void collect(TupleEntry tupleEntry)
                throws java.io.IOException

Specified by:

collect in class TupleEntryCollector

Throws:

java.io.IOException