Uses of Package
org.apache.flume

Packages that use org.apache.flume

Package	Description
org.apache.flume
org.apache.flume.agent.embedded	This package provides Flume users the ability to embed simple agents in applications.
org.apache.flume.api
org.apache.flume.channel
org.apache.flume.channel.file
org.apache.flume.channel.file.encryption
org.apache.flume.channel.jdbc
org.apache.flume.channel.jdbc.impl
org.apache.flume.channel.kafka
org.apache.flume.client.avro
org.apache.flume.clients.log4jappender
org.apache.flume.conf
org.apache.flume.conf.channel
org.apache.flume.conf.sink
org.apache.flume.conf.source
org.apache.flume.event
org.apache.flume.formatter.output
org.apache.flume.instrumentation
org.apache.flume.instrumentation.http
org.apache.flume.interceptor
org.apache.flume.node
org.apache.flume.serialization
org.apache.flume.shared.kafka.test
org.apache.flume.sink
org.apache.flume.sink.elasticsearch
org.apache.flume.sink.elasticsearch.client
org.apache.flume.sink.hbase
org.apache.flume.sink.hdfs
org.apache.flume.sink.hive
org.apache.flume.sink.irc
org.apache.flume.sink.kafka
org.apache.flume.sink.kite
org.apache.flume.sink.kite.parser
org.apache.flume.sink.kite.policy
org.apache.flume.sink.solr.morphline
org.apache.flume.source
org.apache.flume.source.avroLegacy
org.apache.flume.source.http
org.apache.flume.source.jms
org.apache.flume.source.kafka
org.apache.flume.source.scribe
org.apache.flume.source.taildir
org.apache.flume.source.thriftLegacy
org.apache.flume.source.twitter
org.apache.flume.tools

Classes in org.apache.flume used by org.apache.flume

Class and Description
Channel A channel connects a Source to a Sink.
ChannelException A channel exception is raised whenever a channel operation fails.
Clock Facade for System.currentTimeMillis for Testing
CounterGroup Used for counting events, collecting metrics, etc.
Event Basic representation of a data object in Flume.
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.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
PollableSource.Status
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.
Sink.Status
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.
SourceRunner A source runner controls how a source is driven.
Transaction Provides the transaction boundary while accessing a channel.
Transaction.TransactionState

Classes in org.apache.flume used by org.apache.flume.agent.embedded

Class and Description
ChannelException A channel exception is raised whenever a channel operation fails.
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
EventDeliveryException An event delivery exception is raised whenever an Event fails to reach at least one of its intended (next-hop) destinations.
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.
FlumeException Base class of all flume exceptions.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
Source A source generates and calls methods on the configured ChannelProcessor to persist those events into the configured channels.

Classes in org.apache.flume used by org.apache.flume.api

Class and Description
Event Basic representation of a data object in Flume.
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.

Classes in org.apache.flume used by org.apache.flume.channel

Class and Description
Channel A channel connects a Source to a Sink.
ChannelException A channel exception is raised whenever a channel operation fails.
ChannelFactory
ChannelSelector Allows the selection of a subset of channels from the given set based on its implementation policy.
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
FlumeException Base class of all flume exceptions.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
Transaction Provides the transaction boundary while accessing a channel.

Classes in org.apache.flume used by org.apache.flume.channel.file

Class and Description
Channel A channel connects a Source to a Sink.
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
FlumeException Base class of all flume exceptions.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.

Classes in org.apache.flume used by org.apache.flume.channel.file.encryption

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
FlumeException Base class of all flume exceptions.

Classes in org.apache.flume used by org.apache.flume.channel.jdbc

Class and Description
Channel A channel connects a Source to a Sink.
ChannelException A channel exception is raised whenever a channel operation fails.
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
Transaction Provides the transaction boundary while accessing a channel.

Classes in org.apache.flume used by org.apache.flume.channel.jdbc.impl

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
Transaction Provides the transaction boundary while accessing a channel.

Classes in org.apache.flume used by org.apache.flume.channel.kafka

Class and Description
Channel A channel connects a Source to a Sink.
Context The context is a key-value store used to pass configuration information throughout the system.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.

Classes in org.apache.flume used by org.apache.flume.client.avro

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.

Classes in org.apache.flume used by org.apache.flume.clients.log4jappender

Class and Description
FlumeException Base class of all flume exceptions.

Classes in org.apache.flume used by org.apache.flume.conf

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
FlumeException Base class of all flume exceptions.

Classes in org.apache.flume used by org.apache.flume.conf.channel

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.

Classes in org.apache.flume used by org.apache.flume.conf.sink

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.

Classes in org.apache.flume used by org.apache.flume.conf.source

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.

Classes in org.apache.flume used by org.apache.flume.event

Class and Description
Event Basic representation of a data object in Flume.

Classes in org.apache.flume used by org.apache.flume.formatter.output

Class and Description
Clock Facade for System.currentTimeMillis for Testing
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.

Classes in org.apache.flume used by org.apache.flume.instrumentation

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
FlumeException Base class of all flume exceptions.

Classes in org.apache.flume used by org.apache.flume.instrumentation.http

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.

Classes in org.apache.flume used by org.apache.flume.interceptor

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.

Classes in org.apache.flume used by org.apache.flume.node

Class and Description
Channel A channel connects a Source to a Sink.
CounterGroup Used for counting events, collecting metrics, etc.
SinkRunner A driver for sinks that polls them, attempting to process events if any are available in the Channel.
SourceRunner A source runner controls how a source is driven.

Classes in org.apache.flume used by org.apache.flume.serialization

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.

Classes in org.apache.flume used by org.apache.flume.shared.kafka.test

Class and Description
Event Basic representation of a data object in Flume.

Classes in org.apache.flume used by org.apache.flume.sink

Class and Description
Channel A channel connects a Source to a Sink.
Context The context is a key-value store used to pass configuration information throughout the system.
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.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
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.
Sink.Status
SinkFactory
SinkProcessor Interface for a device that allows abstraction of the behavior of multiple sinks, always assigned to a SinkRunner

Classes in org.apache.flume used by org.apache.flume.sink.elasticsearch

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
EventDeliveryException An event delivery exception is raised whenever an Event fails to reach at least one of its intended (next-hop) destinations.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
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.
Sink.Status

Classes in org.apache.flume used by org.apache.flume.sink.elasticsearch.client

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.

Classes in org.apache.flume used by org.apache.flume.sink.hbase

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
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.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
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.
Sink.Status

Classes in org.apache.flume used by org.apache.flume.sink.hdfs

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
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.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
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.
Sink.Status

Classes in org.apache.flume used by org.apache.flume.sink.hive

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
EventDeliveryException An event delivery exception is raised whenever an Event fails to reach at least one of its intended (next-hop) destinations.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
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.
Sink.Status

Classes in org.apache.flume used by org.apache.flume.sink.irc

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
EventDeliveryException An event delivery exception is raised whenever an Event fails to reach at least one of its intended (next-hop) destinations.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
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.
Sink.Status

Classes in org.apache.flume used by org.apache.flume.sink.kafka

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
EventDeliveryException An event delivery exception is raised whenever an Event fails to reach at least one of its intended (next-hop) destinations.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
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.
Sink.Status

Classes in org.apache.flume used by org.apache.flume.sink.kite

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
EventDeliveryException An event delivery exception is raised whenever an Event fails to reach at least one of its intended (next-hop) destinations.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
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.
Sink.Status

Classes in org.apache.flume used by org.apache.flume.sink.kite.parser

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
EventDeliveryException An event delivery exception is raised whenever an Event fails to reach at least one of its intended (next-hop) destinations.

Classes in org.apache.flume used by org.apache.flume.sink.kite.policy

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
EventDeliveryException An event delivery exception is raised whenever an Event fails to reach at least one of its intended (next-hop) destinations.

Classes in org.apache.flume used by org.apache.flume.sink.solr.morphline

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
EventDeliveryException An event delivery exception is raised whenever an Event fails to reach at least one of its intended (next-hop) destinations.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
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.
Sink.Status

Classes in org.apache.flume used by org.apache.flume.source

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
EventDeliveryException An event delivery exception is raised whenever an Event fails to reach at least one of its intended (next-hop) destinations.
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.
FlumeException Base class of all flume exceptions.
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.
PollableSource.Status
Source A source generates and calls methods on the configured ChannelProcessor to persist those events into the configured channels.
SourceFactory
SourceRunner A source runner controls how a source is driven.

Classes in org.apache.flume used by org.apache.flume.source.avroLegacy

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
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.
Source A source generates and calls methods on the configured ChannelProcessor to persist those events into the configured channels.

Classes in org.apache.flume used by org.apache.flume.source.http

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
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.
FlumeException Base class of all flume exceptions.
NamedComponent Enables a component to be tagged with a name so that it can be referred to uniquely within the configuration system.
Source A source generates and calls methods on the configured ChannelProcessor to persist those events into the configured channels.

Classes in org.apache.flume used by org.apache.flume.source.jms

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
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.
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.
PollableSource.Status
Source A source generates and calls methods on the configured ChannelProcessor to persist those events into the configured channels.

Classes in org.apache.flume used by org.apache.flume.source.kafka

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
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.
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.
PollableSource.Status
Source A source generates and calls methods on the configured ChannelProcessor to persist those events into the configured channels.

Classes in org.apache.flume used by org.apache.flume.source.scribe

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
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.
Source A source generates and calls methods on the configured ChannelProcessor to persist those events into the configured channels.

Classes in org.apache.flume used by org.apache.flume.source.taildir

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
Event Basic representation of a data object in Flume.
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.
PollableSource.Status
Source A source generates and calls methods on the configured ChannelProcessor to persist those events into the configured channels.

Classes in org.apache.flume used by org.apache.flume.source.thriftLegacy

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
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.
Source A source generates and calls methods on the configured ChannelProcessor to persist those events into the configured channels.

Classes in org.apache.flume used by org.apache.flume.source.twitter

Class and Description
Context The context is a key-value store used to pass configuration information throughout the system.
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.
Source A source generates and calls methods on the configured ChannelProcessor to persist those events into the configured channels.

Classes in org.apache.flume used by org.apache.flume.tools

Class and Description
Event Basic representation of a data object in Flume.