public class BasePartitionTap.PartitionCollector extends TupleEntryCollector
tupleEntry
Constructor and Description |
---|
BasePartitionTap.PartitionCollector(FlowProcess<? extends Config> flowProcess) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Method close closes the underlying resource being written to.
|
void |
closeCollector(String path) |
protected void |
collect(TupleEntry tupleEntry) |
add, add, setFields
public BasePartitionTap.PartitionCollector(FlowProcess<? extends Config> flowProcess)
public void close()
TupleEntryCollector
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).close
in class TupleEntryCollector
public void closeCollector(String path)
protected void collect(TupleEntry tupleEntry) throws IOException
collect
in class TupleEntryCollector
IOException
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.