public class HBaseTapCollector
extends cascading.tuple.TupleEntrySchemeCollector<org.apache.hadoop.mapred.JobConf,cascading.tuple.TupleEntrySchemeCollector>
implements org.apache.hadoop.mapred.OutputCollector
TupleEntrySchemeCollector that writes tuples to the
resource managed by a particular HBaseTap instance.| 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.
|
| 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() |
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
flowProcess - of type FlowProcesstap - of type Tapjava.io.IOException - when fails to initializepublic void prepare()
prepare in class cascading.tuple.TupleEntrySchemeCollector<org.apache.hadoop.mapred.JobConf,cascading.tuple.TupleEntrySchemeCollector>public void close()
close in class cascading.tuple.TupleEntrySchemeCollector<org.apache.hadoop.mapred.JobConf,cascading.tuple.TupleEntrySchemeCollector>public void collect(java.lang.Object writableComparable,
java.lang.Object writable)
throws java.io.IOException
Tap this instance
encapsulates.collect in interface org.apache.hadoop.mapred.OutputCollectorwritableComparable - of type WritableComparablewritable - of type Writablejava.io.IOException - when