Class and Description |
---|
Channel |
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 |
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 |
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. |
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.
|
Class and Description |
---|
Channel |
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.
|
Class and Description |
---|
Channel |
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.
|
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.
|
Class and Description |
---|
Channel |
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.
|
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.
|
Class and Description |
---|
Channel |
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.
|
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.
|
Class and Description |
---|
FlumeException
Base class of all flume exceptions.
|
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.
|
Class and Description |
---|
Context
The context is a key-value store used to pass configuration information
throughout the system.
|
Class and Description |
---|
Context
The context is a key-value store used to pass configuration information
throughout the system.
|
Class and Description |
---|
Event
Basic representation of a data object in Flume.
|
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.
|
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.
|
Class and Description |
---|
Context
The context is a key-value store used to pass configuration information
throughout the system.
|
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.
|
Class and Description |
---|
Channel |
CounterGroup
Used for counting events, collecting metrics, etc.
|
SinkRunner |
SourceRunner
A source runner controls how a source is driven.
|
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.
|
Class and Description |
---|
Event
Basic representation of a data object in Flume.
|
Class and Description |
---|
Channel |
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
|
Class and Description |
---|
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.
|
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 |
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 |
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 |
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 |
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 |
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 |
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 |
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. |
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. |
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 |
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 |
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 |
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.
|
Class and Description |
---|
Context
The context is a key-value store used to pass configuration information
throughout the system.
|
EventDrivenSource |
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. |
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 |
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. |
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 |
PollableSource.Status |
Source
A source generates and calls methods on the
configured
ChannelProcessor to persist those events into the
configured channels. |
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 |
PollableSource.Status |
Source
A source generates and calls methods on the
configured
ChannelProcessor to persist those events into the
configured channels. |
Class and Description |
---|
Context
The context is a key-value store used to pass configuration information
throughout the system.
|
EventDrivenSource |
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. |
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 |
PollableSource.Status |
Source
A source generates and calls methods on the
configured
ChannelProcessor to persist those events into the
configured channels. |
Class and Description |
---|
Context
The context is a key-value store used to pass configuration information
throughout the system.
|
EventDrivenSource |
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. |
Class and Description |
---|
Context
The context is a key-value store used to pass configuration information
throughout the system.
|
EventDrivenSource |
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. |
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.
|
Copyright © 2009–2019 Apache Software Foundation. All rights reserved.