Interface HbaseEventSerializer

All Superinterfaces:
Configurable, ConfigurableComponent
All Known Implementing Classes:
RegexHbaseEventSerializer, SimpleHbaseEventSerializer

public interface HbaseEventSerializer
extends Configurable, ConfigurableComponent

Interface for an event serializer which serializes the headers and body of an event to write them to hbase. This is configurable, so any config params required should be taken through this. Only the column family is passed in. The columns should exist in the table and column family specified in the configuration for the HbaseSink.

Method Summary
 void close()
 List<org.apache.hadoop.hbase.client.Row> getActions()
          Get the actions that should be written out to hbase as a result of this event.
 List<org.apache.hadoop.hbase.client.Increment> getIncrements()
 void initialize(Event event, byte[] columnFamily)
          Initialize the event serializer.
Methods inherited from interface org.apache.flume.conf.Configurable
Methods inherited from interface org.apache.flume.conf.ConfigurableComponent

Method Detail


void initialize(Event event,
                byte[] columnFamily)
Initialize the event serializer.

Event - to be written to HBase.


List<org.apache.hadoop.hbase.client.Row> getActions()
Get the actions that should be written out to hbase as a result of this event. This list is written to hbase using the HBase batch API.

List of Row which are written as such to HBase. 0.92 increments do not implement Row, so this is not generic.


List<org.apache.hadoop.hbase.client.Increment> getIncrements()


void close()

Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.