public class IgniteSink
extends org.apache.flume.sink.AbstractSink
implements org.apache.flume.conf.Configurable
| Constructor and Description |
|---|
IgniteSink()
Empty constructor.
|
| Modifier and Type | Method and Description |
|---|---|
void |
configure(org.apache.flume.Context context)
Sink configurations with Ignite-specific settings.
|
org.apache.flume.Sink.Status |
process()
Processes Flume events.
|
void |
start()
Starts a grid and initializes na event transformer.
|
void |
stop()
Stops the grid.
|
public void configure(org.apache.flume.Context context)
configure in interface org.apache.flume.conf.Configurablecontext - Context for sink.public void start()
start in interface org.apache.flume.lifecycle.LifecycleAwarestart in class org.apache.flume.sink.AbstractSinkpublic void stop()
stop in interface org.apache.flume.lifecycle.LifecycleAwarestop in class org.apache.flume.sink.AbstractSinkpublic org.apache.flume.Sink.Status process()
throws org.apache.flume.EventDeliveryException
process in interface org.apache.flume.Sinkorg.apache.flume.EventDeliveryException
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016