|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
Event to the associated Flume source.
Source implementation that receives Avro events from Avro sink of
Flume OGSink implementation that can send events to an RPC server (such as
Flume's AvroSource).Source implementation that receives Avro events from clients that
implement AvroSourceProtocol.Channel semantics, including the
implied thread-local semantics of the Transaction class,
which is required to extend BasicTransactionSemantics.Transaction semantics designed
to work in concert with BasicChannelSemantics to simplify
creation of robust Channel implementations.Transaction to which it belongs.Source to a Sink.Events into
Channels.Channel
objects.Configurables.target implements Configurable and, if so, ask
it to configure itself using the supplied context.
Transaction objects, which must
extend BasicTransactionSemantics.
Event fails to
reach at least one of its intended (next-hop) destinations.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.Source implementation that executes a Unix process and turns each
line of text into an event.Channel implementation that uses the local file system for
its storage.Transaction for FileChannels.Source specified.
events that may be batched
at once by appendBatch().
RpcClient connected to the specified
hostname and port.
RpcClient connected to the specified
hostname and port with the specified batchSize.
createTransaction if not.
Channel instance.
true if this object appears to be in a usable state, and
it returns false if this object is permanently disabled.
Sink implementation that logs all events received at the INFO level
to the org.apache.flume.sink.LoggerSink logger.RpcClient.NettyAvroRpcClient objects.Sink implementation that simply discards all events it receives.Source that requires an external driver to poll to determine
whether there are events that are available to ingest
from the source.SourceRunner that can drive a
PollableSource.Channel implementation that supports in-memory
buffering and delivery of events.put to the thread's BasicTransactionSemantics instance.
BasicChannelSemantics delegates calls
to put.
put transactions.
put transactions.
RPCClient implementations.Channel.Runnable that polls a
SinkProcessor and manages event delivery notification,
BACKOFF delay handling, etc.ChannelProcessor to persist those events into the
configured channels.take to the thread's BasicTransactionSemantics instance.
BasicChannelSemantics delegates calls
to take.
take transactions.
take transactions.
Transaction client
semantics.
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||