org.apache.storm.hbase.trident.mapper
Class SimpleTridentHBaseMapper

java.lang.Object
  extended by org.apache.storm.hbase.trident.mapper.SimpleTridentHBaseMapper
All Implemented Interfaces:
Serializable, TridentHBaseMapper

public class SimpleTridentHBaseMapper
extends Object
implements TridentHBaseMapper

See Also:
Serialized Form

Constructor Summary
SimpleTridentHBaseMapper()
           
 
Method Summary
 ColumnList columns(TridentTuple tuple)
          Given a tuple, return a list of HBase columns to insert.
 byte[] rowKey(TridentTuple tuple)
          Given a tuple, return the HBase rowkey.
 SimpleTridentHBaseMapper withColumnFamily(String columnFamily)
           
 SimpleTridentHBaseMapper withColumnFields(Fields columnFields)
           
 SimpleTridentHBaseMapper withCounterFields(Fields counterFields)
           
 SimpleTridentHBaseMapper withRowKeyField(String rowKeyField)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

SimpleTridentHBaseMapper

public SimpleTridentHBaseMapper()
Method Detail

withRowKeyField

public SimpleTridentHBaseMapper withRowKeyField(String rowKeyField)

withColumnFields

public SimpleTridentHBaseMapper withColumnFields(Fields columnFields)

withCounterFields

public SimpleTridentHBaseMapper withCounterFields(Fields counterFields)

withColumnFamily

public SimpleTridentHBaseMapper withColumnFamily(String columnFamily)

rowKey

public byte[] rowKey(TridentTuple tuple)
Description copied from interface: TridentHBaseMapper
Given a tuple, return the HBase rowkey.

Specified by:
rowKey in interface TridentHBaseMapper
Returns:

columns

public ColumnList columns(TridentTuple tuple)
Description copied from interface: TridentHBaseMapper
Given a tuple, return a list of HBase columns to insert.

Specified by:
columns in interface TridentHBaseMapper
Returns:


Copyright © 2016 The Apache Software Foundation. All Rights Reserved.