Review Board 1.7.22


Default values for HBase and AsyncHBase default serializers

Review Request #10989 - Created May 8, 2013 and submitted

Sravya Tirukkovalur
trunk
FLUME-1757
Reviewers
Flume
flume-git
Default HBase and AsyncHBase simple serializers required the user to provide payload column and increment column. Created default values for these for better usability. The default values are: payloadcolumn = "pCol" and increment column = "iCol". Made a note of this in the flume user doc as well. 
Wrote unit tests. And validated the change. 
flume-ng-doc/sphinx/FlumeUserGuide.rst
Revision 38f2205 New Change
[20] 1677 lines
[+20]
1678
**channel**         --
1678
**channel**         --
1679
**type**            --                                                      The component type name, needs to be ``org.apache.flume.sink.hbase.HBaseSink``
1679
**type**            --                                                      The component type name, needs to be ``org.apache.flume.sink.hbase.HBaseSink``
1680
**table**           --                                                      The name of the table in Hbase to write to.
1680
**table**           --                                                      The name of the table in Hbase to write to.
1681
**columnFamily**    --                                                      The column family in Hbase to write to.
1681
**columnFamily**    --                                                      The column family in Hbase to write to.
1682
batchSize           100                                                     Number of events to be written per txn.
1682
batchSize           100                                                     Number of events to be written per txn.
1683
serializer          org.apache.flume.sink.hbase.SimpleHbaseEventSerializer
1683
serializer          org.apache.flume.sink.hbase.SimpleHbaseEventSerializer  Default increment column = "iCol", payload column = "pCol".
1684
serializer.*        --                                                      Properties to be passed to the serializer.
1684
serializer.*        --                                                      Properties to be passed to the serializer.
1685
kerberosPrincipal   --                                                      Kerberos user principal for accessing secure HBase
1685
kerberosPrincipal   --                                                      Kerberos user principal for accessing secure HBase
1686
kerberosKeytab      --                                                      Kerberos keytab for accessing secure HBase
1686
kerberosKeytab      --                                                      Kerberos keytab for accessing secure HBase
1687
==================  ======================================================  ==============================================================================
1687
==================  ======================================================  ==============================================================================
1688

    
   
1688

   
[+20] [20] 1337 lines
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleAsyncHbaseEventSerializer.java
Revision dd19616 New Change
 
flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleHbaseEventSerializer.java
Revision 52bc84d New Change
 
flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestAsyncHBaseSink.java
Revision 03c3e4c New Change
 
flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestHBaseSink.java
Revision ad94fc9 New Change
 
  1. flume-ng-doc/sphinx/FlumeUserGuide.rst: Loading...
  2. flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleAsyncHbaseEventSerializer.java: Loading...
  3. flume-ng-sinks/flume-ng-hbase-sink/src/main/java/org/apache/flume/sink/hbase/SimpleHbaseEventSerializer.java: Loading...
  4. flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestAsyncHBaseSink.java: Loading...
  5. flume-ng-sinks/flume-ng-hbase-sink/src/test/java/org/apache/flume/sink/hbase/TestHBaseSink.java: Loading...