org.apache.kudu.flume.sink

Interface KuduOperationsProducer

All Superinterfaces:

AutoCloseable, org.apache.flume.conf.Configurable

All Known Implementing Classes:

AvroKuduOperationsProducer, RegexpKuduOperationsProducer, SimpleKeyedKuduOperationsProducer, SimpleKuduOperationsProducer

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public interface KuduOperationsProducer
extends org.apache.flume.conf.Configurable, AutoCloseable

Interface for an operations producer that produces Kudu Operations from Flume events.

Method Summary

Modifier and Type	Method and Description
void	close() Cleans up any state.
List<Operation>	getOperations(org.apache.flume.Event event) Returns the operations that should be written to Kudu as a result of this event.
void	initialize(KuduTable table) Initializes the operations producer.

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

configure

Method Detail

initialize

void initialize(KuduTable table)

Initializes the operations producer. Called between configure and getOperations.

Parameters:

table - the KuduTable used to create Kudu Operation objects

getOperations

List<Operation> getOperations(org.apache.flume.Event event)

Returns the operations that should be written to Kudu as a result of this event.

Parameters:

event - Event to convert to one or more Operations

Returns:

List of Operations that should be written to Kudu

close

void close()

Cleans up any state. Called when the sink is stopped.

Specified by:

close in interface AutoCloseable