com.twitter.maple.hbase

Class HBaseTapCollector

java.lang.Object

cascading.tuple.TupleEntryCollector

cascading.tuple.TupleEntrySchemeCollector<org.apache.hadoop.mapred.JobConf,cascading.tuple.TupleEntrySchemeCollector>

com.twitter.maple.hbase.HBaseTapCollector

All Implemented Interfaces:

org.apache.hadoop.mapred.OutputCollector

public class HBaseTapCollector
extends cascading.tuple.TupleEntrySchemeCollector<org.apache.hadoop.mapred.JobConf,cascading.tuple.TupleEntrySchemeCollector>
implements org.apache.hadoop.mapred.OutputCollector

Class HBaseTapCollector is a kind of TupleEntrySchemeCollector that writes tuples to the resource managed by a particular HBaseTap instance.

Field Summary

Fields inherited from class cascading.tuple.TupleEntrySchemeCollector

sinkCall

Fields inherited from class cascading.tuple.TupleEntryCollector

tupleEntry

Constructor Summary

Constructors

Constructor and Description
HBaseTapCollector(cascading.flow.FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess, cascading.tap.Tap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector> tap) Constructor TapCollector creates a new TapCollector instance.

Method Summary

Modifier and Type	Method and Description
void	close()
void	collect(java.lang.Object writableComparable, java.lang.Object writable) Method collect writes the given values to the Tap this instance encapsulates.
void	prepare()

Methods inherited from class cascading.tuple.TupleEntrySchemeCollector

add, add, collect, getFlowProcess, getOutput, setFields, setOutput, wrapOutput

Methods inherited from class java.lang.Object

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

Constructor Detail

HBaseTapCollector

public HBaseTapCollector(cascading.flow.FlowProcess<org.apache.hadoop.mapred.JobConf> flowProcess,
                         cascading.tap.Tap<org.apache.hadoop.mapred.JobConf,org.apache.hadoop.mapred.RecordReader,org.apache.hadoop.mapred.OutputCollector> tap)
                  throws java.io.IOException

Constructor TapCollector creates a new TapCollector instance.

Parameters:

flowProcess - of type FlowProcess

tap - of type Tap

Throws:

java.io.IOException - when fails to initialize

Method Detail

prepare

public void prepare()

Overrides:

prepare in class cascading.tuple.TupleEntrySchemeCollector<org.apache.hadoop.mapred.JobConf,cascading.tuple.TupleEntrySchemeCollector>

close

public void close()

Overrides:

close in class cascading.tuple.TupleEntrySchemeCollector<org.apache.hadoop.mapred.JobConf,cascading.tuple.TupleEntrySchemeCollector>

collect

public void collect(java.lang.Object writableComparable,
                    java.lang.Object writable)
             throws java.io.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:

java.io.IOException - when