cascading.tap.hadoop.io
Class TapOutputCollector

java.lang.Object
  extended by 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
 

Constructor Detail

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
Method Detail

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 WritableComparable
writable - of type Writable
Throws:
IOException - when

close

public void close()
Specified by:
close in interface Closeable


Copyright © 2007-2013 Concurrent, Inc. All Rights Reserved.