KuduEventProducer (Kudu 0.8.0 API)

Prev Class
Next Class

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

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

Methods
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()
```

Prev Class
Next Class

All Classes

Summary:
Nested |
Field |
Constr |
Method

Detail:
Field |
Constr |
Method

Copyright © 2016. All rights reserved.