|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
afterOpenForAppend().
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.
Context prefix
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.RpcClient which supports failover.Channel implementation that uses the local file system for
its storage.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.
RpcClient, optionally with failover.
RpcClientFactory.getInstance(Properties props), given a File path
to a Properties file.
createTransaction if not.
Channel instance.
HostInterceptor.intercept(Event) in a loop.
Event.
TimestampInterceptor.intercept(Event) in a loop.
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.RpcClientFactory.
Sink implementation that simply discards all events it receives.ConfigurationConstants.CONFIG_CREATE_FK instead.
ConfigurationConstants.CONFIG_CREATE_INDEX instead.
ConfigurationConstants.CONFIG_CREATE_SCHEMA instead.
ConfigurationConstants.CONFIG_DATABASE_TYPE instead.
ConfigurationConstants.CONFIG_JDBC_DRIVER_CLASS instead.
ConfigurationConstants.CONFIG_JDBC_PROPS_FILE instead.
ConfigurationConstants.CONFIG_JDBC_SYSPROP_PREFIX instead
ConfigurationConstants.CONFIG_MAX_CAPACITY instead.
ConfigurationConstants.CONFIG_MAX_CONNECTIONS instead
ConfigurationConstants.CONFIG_PASSWORD instead.
ConfigurationConstants.CONFIG_TX_ISOLATION_LEVEL instead.
ConfigurationConstants.CONFIG_URL instead.
ConfigurationConstants.CONFIG_USERNAME instead.
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.
FileChannel, which gives better
performance and is also durable.HbaseEventSerializer which parses columns based on a supplied
regular expression and column name list.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.
Writable with a sequence id so that both can
be written together to a file.
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||