cascading.tap.hadoop.io
Class TapOutputCollector
java.lang.Object
cascading.tap.hadoop.io.TapOutputCollector
- All Implemented Interfaces:
- Closeable, org.apache.hadoop.mapred.OutputCollector
public class TapOutputCollector
- extends Object
- implements org.apache.hadoop.mapred.OutputCollector, Closeable
Constructor Summary |
TapOutputCollector(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess,
Tap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector> tap)
|
TapOutputCollector(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess,
Tap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector> tap,
String prefix)
|
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 |
TapOutputCollector
public TapOutputCollector(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess,
Tap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector> tap)
throws IOException
- Throws:
IOException
TapOutputCollector
public TapOutputCollector(FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess,
Tap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector> tap,
String prefix)
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 org.apache.hadoop.mapred.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.