cascading.tap.hadoop.io
Class TapOutputCollector
java.lang.Object
cascading.tap.hadoop.io.TapOutputCollector
- All Implemented Interfaces:
- Closeable, OutputCollector
public class TapOutputCollector
- extends Object
- implements OutputCollector, Closeable
Constructor Summary |
TapOutputCollector(cascading.flow.FlowProcess<JobConf> flowProcess,
cascading.tap.Tap<JobConf,RecordReader,OutputCollector> tap)
|
TapOutputCollector(cascading.flow.FlowProcess<JobConf> flowProcess,
cascading.tap.Tap<JobConf,RecordReader,OutputCollector> tap,
String prefix)
|
TapOutputCollector(cascading.flow.FlowProcess<JobConf> flowProcess,
cascading.tap.Tap<JobConf,RecordReader,OutputCollector> tap,
String prefix,
long sequence)
|
Method Summary |
void |
close()
|
void |
collect(Object writableComparable,
Object writable)
Method collect writes the given values to the Tap this instance encapsulates. |
protected void |
initialize()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PART_TASK_PATTERN
public static final String PART_TASK_PATTERN
- See Also:
- Constant Field Values
PART_TASK_SEQ_PATTERN
public static final String PART_TASK_SEQ_PATTERN
- See Also:
- Constant Field Values
TapOutputCollector
public TapOutputCollector(cascading.flow.FlowProcess<JobConf> flowProcess,
cascading.tap.Tap<JobConf,RecordReader,OutputCollector> tap)
throws IOException
- Throws:
IOException
TapOutputCollector
public TapOutputCollector(cascading.flow.FlowProcess<JobConf> flowProcess,
cascading.tap.Tap<JobConf,RecordReader,OutputCollector> tap,
String prefix)
throws IOException
- Throws:
IOException
TapOutputCollector
public TapOutputCollector(cascading.flow.FlowProcess<JobConf> flowProcess,
cascading.tap.Tap<JobConf,RecordReader,OutputCollector> tap,
String prefix,
long sequence)
throws IOException
- Throws:
IOException
initialize
protected void initialize()
throws IOException
- Throws:
IOException
collect
public void collect(Object writableComparable,
Object writable)
throws IOException
- Method collect writes the given values to the
Tap
this instance encapsulates.
- Specified by:
collect
in interface OutputCollector
- Parameters:
writableComparable
- of type WritableComparablewritable
- of type Writable
- Throws:
IOException
- when
close
public void close()
- Specified by:
close
in interface Closeable
Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.