@InterfaceAudience.Public @InterfaceStability.Evolving public class SimpleKuduOperationsProducer extends Object implements KuduOperationsProducer
Insert
per Event
by writing the event body into a BINARY column. The headers are discarded.
Simple Kudu Event Producer configuration parameters
Property Name | Default | Required? | Description |
---|---|---|---|
producer.payloadColumn | payload | No | The name of the BINARY column to write the Flume the event body to. |
Modifier and Type | Field and Description |
---|---|
static String |
PAYLOAD_COLUMN_DEFAULT |
static String |
PAYLOAD_COLUMN_PROP |
Constructor and Description |
---|
SimpleKuduOperationsProducer() |
Modifier and Type | Method and Description |
---|---|
void |
close()
Cleans up any state.
|
void |
configure(org.apache.flume.Context context) |
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.
|
public static final String PAYLOAD_COLUMN_PROP
public static final String PAYLOAD_COLUMN_DEFAULT
public void configure(org.apache.flume.Context context)
configure
in interface org.apache.flume.conf.Configurable
public void initialize(KuduTable table)
KuduOperationsProducer
initialize
in interface KuduOperationsProducer
table
- the KuduTable used to create Kudu Operation objectspublic List<Operation> getOperations(org.apache.flume.Event event) throws org.apache.flume.FlumeException
KuduOperationsProducer
getOperations
in interface KuduOperationsProducer
event
- Event to convert to one or more Operationsorg.apache.flume.FlumeException
public void close()
KuduOperationsProducer
close
in interface AutoCloseable
close
in interface KuduOperationsProducer
Copyright © 2018 The Apache Software Foundation. All rights reserved.