Package org.apache.flume

Interface Summary
Channel A channel connects a Source to a Sink.
ChannelFactory  
ChannelSelector Allows the selection of a subset of channels from the given set based on its implementation policy.
Clock Facade for System.currentTimeMillis for Testing
Event Basic representation of a data object in Flume.
EventDrivenSource A Source that does not need an external driver to poll for events to ingest; it provides its own event-driven mechanism to invoke event processing.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
PollableSource A Source that requires an external driver to poll to determine whether there are events that are available to ingest from the source.
Sink A sink is connected to a Channel and consumes its contents, sending them to a configured destination that may vary according to the sink type.
SinkFactory  
SinkProcessor Interface for a device that allows abstraction of the behavior of multiple sinks, always assigned to a SinkRunner
Source A source generates and calls methods on the configured ChannelProcessor to persist those events into the configured channels.
SourceFactory  
Transaction Provides the transaction boundary while accessing a channel.
 

Class Summary
Constants  
Context The context is a key-value store used to pass configuration information throughout the system.
CounterGroup Used for counting events, collecting metrics, etc.
Dummy Placeholder class so the git mirror does not leave out the src/main/java dir
SinkRunner A driver for sinks that polls them, attempting to process events if any are available in the Channel.
SinkRunner.PollingRunner Runnable that polls a SinkProcessor and manages event delivery notification, BACKOFF delay handling, etc.
SourceRunner A source runner controls how a source is driven.
SystemClock Default implementation of Clock which uses System
 

Enum Summary
PollableSource.Status  
Sink.Status  
Transaction.TransactionState  
 

Exception Summary
ChannelException A channel exception is raised whenever a channel operation fails.
EventDeliveryException An event delivery exception is raised whenever an Event fails to reach at least one of its intended (next-hop) destinations.
FlumeException Base class of all flume exceptions.
 

Annotation Types Summary
VersionAnnotation This class is about package attribute that captures version info of Flume that was compiled.
 



Copyright © 2009-2012 Apache Software Foundation. All Rights Reserved.