org.kududb.flume.sink

Interface KuduEventProducer

All Superinterfaces:

org.apache.flume.conf.Configurable, org.apache.flume.conf.ConfigurableComponent

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public interface KuduEventProducer
extends org.apache.flume.conf.Configurable, org.apache.flume.conf.ConfigurableComponent

Interface for an event producer which produces Kudu Operations to write the headers and body of an event in a Kudu table. This is configurable, so any config params required should be taken through this. The columns should exist in the table specified in the configuration for the KuduSink.

Method Summary

Modifier and Type	Method and Description
void	close()
List<Operation>	getOperations() Get the operations that should be written out to Kudu as a result of this event.
void	initialize(org.apache.flume.Event event, KuduTable table) Initialize the event producer.

Methods inherited from interface org.apache.flume.conf.Configurable

configure

Methods inherited from interface org.apache.flume.conf.ConfigurableComponent

configure

Method Detail

initialize

void initialize(org.apache.flume.Event event,
                KuduTable table)

Initialize the event producer.

Parameters:

event - to be written to Kudu

table - the KuduTable object used for creating Kudu Operation objects

getOperations

List<Operation> getOperations()

Get the operations that should be written out to Kudu as a result of this event. This list is written to Kudu using the Kudu client API.

Returns:

List of Operation which are written as such to Kudu

close

void close()