org.apache.flume.sink.hbase2

Class SimpleHBase2EventSerializer

java.lang.Object

org.apache.flume.sink.hbase2.SimpleHBase2EventSerializer

All Implemented Interfaces:

Configurable, ConfigurableComponent, HBase2EventSerializer

public class SimpleHBase2EventSerializer
extends Object
implements HBase2EventSerializer

A simple serializer that returns puts from an event, by writing the event body into it. The headers are discarded. It also updates a row in HBase which acts as an event counter.

Takes optional parameters:

rowPrefix: The prefix to be used. Default: default

incrementRow The row to increment. Default: incRow

suffix: uuid/random/timestamp.Default: uuid

Mandatory parameters:

cf:Column family.

Components that have no defaults and will not be used if null: payloadColumn: Which column to put payload in. If it is null, event data will not be written.

incColumn: Which column to increment. Null means no column is incremented.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SimpleHBase2EventSerializer.KeyType

Constructor Summary

Constructors

Constructor and Description
SimpleHBase2EventSerializer()

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(ComponentConfiguration conf)
void	configure(Context context) Request the implementing class to (re)configure itself.
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[] cf) Initialize the event serializer.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleHBase2EventSerializer

public SimpleHBase2EventSerializer()

Method Detail

configure

public void configure(Context context)

Description copied from interface: Configurable

Request the implementing class to (re)configure itself.

When configuration parameters are changed, they must be reflected by the component asap.

There are no thread safety guarantees on when configure might be called.

Specified by:

configure in interface Configurable

configure

public void configure(ComponentConfiguration conf)

Specified by:

configure in interface ConfigurableComponent

initialize

public void initialize(Event event,
                       byte[] cf)

Description copied from interface: HBase2EventSerializer

Initialize the event serializer.

Specified by:

initialize in interface HBase2EventSerializer

Parameters:

event - Event to be written to HBase

cf - Column family to write to

getActions

public List<org.apache.hadoop.hbase.client.Row> getActions()
                                                    throws FlumeException

Description copied from interface: HBase2EventSerializer

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.

Specified by:

getActions in interface HBase2EventSerializer

Returns:

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

Throws:

FlumeException

getIncrements

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

Specified by:

getIncrements in interface HBase2EventSerializer

close

public void close()

Specified by:

close in interface HBase2EventSerializer