cascading.tap.hadoop
Class TapCollector

java.lang.Object
  cascading.tuple.TupleEntryCollector
      cascading.tap.hadoop.TapCollector

public class TapCollector
extends TupleEntryCollector

Class TapCollector is a kind of TupleEntryCollector that writes tuples to the resource managed by a particular Tap instance.

Field Summary

Fields inherited from class cascading.tuple.TupleEntryCollector

declared

Constructor Summary

TapCollector(Tap tap, JobConf conf)
Constructor TapCollector creates a new TapCollector instance.

Method Summary

void	close() Method close closes the underlying resource being written to.
void	collect(Object writableComparable, Object writable) Method collect writes the given values to the Tap this instance encapsulates.
protected void	collect(Tuple tuple)

Methods inherited from class cascading.tuple.TupleEntryCollector

add, add

Methods inherited from class java.lang.Object

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

Constructor Detail

TapCollector

public TapCollector(Tap tap,
                    JobConf conf)
             throws IOException

Constructor TapCollector creates a new TapCollector instance.

Parameters:

tap - of type Tap

conf - of type JobConf

Throws:

IOException - when

Method Detail

collect

protected void collect(Tuple tuple)

Specified by:

collect in class TupleEntryCollector

close

public void close()

Description copied from class: TupleEntryCollector

Method close closes the underlying resource being written to. This method should be called when no more Tuple instances will be written out.

Overrides:

close in class TupleEntryCollector

collect

public void collect(Object writableComparable,
                    Object writable)
             throws IOException

Method collect writes the given values to the Tap this instance encapsulates.

Parameters:

writableComparable - of type WritableComparable

writable - of type Writable

Throws:

IOException - when