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 HBaseTapCollectorextends 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

      All Methods Instance Methods Concrete Methods 
      Modifier and TypeMethod and Description
      voidclose() 
      voidcollect(java.lang.Object writableComparable, java.lang.Object writable)
      Method collect writes the given values to the Tap this instance encapsulates.
      voidprepare() 
      • 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


NOTHING
NOTHING
Add the Maven Dependecy to your project: maven dependecy for com.amazonaws : aws-java-sdk : 1.3.14