org.apache.ignite.stream.flume

Class IgniteSink

java.lang.Object

org.apache.flume.sink.AbstractSink

org.apache.ignite.stream.flume.IgniteSink

All Implemented Interfaces:

org.apache.flume.conf.Configurable, org.apache.flume.lifecycle.LifecycleAware, org.apache.flume.NamedComponent, org.apache.flume.Sink

public class IgniteSink
extends org.apache.flume.sink.AbstractSink
implements org.apache.flume.conf.Configurable

Flume sink for Apache Ignite.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flume.Sink

org.apache.flume.Sink.Status

Constructor Summary

Constructors

Constructor and Description
IgniteSink() Empty constructor.

Method Summary

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 an event transformer.
void	stop() Stops the grid.

Methods inherited from class org.apache.flume.sink.AbstractSink

getChannel, getLifecycleState, getName, setChannel, setName, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

IgniteSink

public IgniteSink()

Empty constructor.

Method Detail

configure

public void configure(org.apache.flume.Context context)

Sink configurations with Ignite-specific settings.

Specified by:

configure in interface org.apache.flume.conf.Configurable

Parameters:

context - Context for sink.

start

public void start()

Starts a grid and initializes an event transformer.

Specified by:

start in interface org.apache.flume.lifecycle.LifecycleAware

Overrides:

start in class org.apache.flume.sink.AbstractSink

stop

public void stop()

Stops the grid.

Specified by:

stop in interface org.apache.flume.lifecycle.LifecycleAware

Overrides:

stop in class org.apache.flume.sink.AbstractSink

process

public org.apache.flume.Sink.Status process()
                                     throws org.apache.flume.EventDeliveryException

Processes Flume events.

Specified by:

process in interface org.apache.flume.Sink

Throws:

org.apache.flume.EventDeliveryException