|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
ElasticSearchIndexRequestBuilderFactory.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.EventDeserializer.reset() on the stream and then closes it.
Configurables.target implements Configurable and, if so, ask
it to configure itself using the supplied context.
XContentBuilderIndexRequestBuilder from the supplied
Client via delegation to the subclass-hook template methods
AbstractElasticSearchIndexRequestBuilderFactory.getIndexName(String, long) and
AbstractElasticSearchIndexRequestBuilderFactory.prepareIndexRequest(IndexRequestBuilder, String, String, Event)
Transaction objects, which must
extend BasicTransactionSemantics.
Context prefix
IndexRequestBuilder
instances from serialized flume events.ElasticSearchSink configured using the supplied
configuration
BucketPath.escapeString(String, Map, TimeZone, boolean, int, int,
boolean)
with the timezone set to the default.
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.AvroCLIClient to
ingest into Flume.ElasticSearchIndexRequestBuilderFactory.Source implementation that executes a Unix process and turns each
line of text into an event.RpcClient which supports failover.FastDateFormat to use for index names
in AbstractElasticSearchIndexRequestBuilderFactory.getIndexName(String, long)
Channel implementation that uses the local file system for
its storage.Source specified.
ObjectName within the flume namespace:
org.apache.flume.events that may be batched
at once by appendBatch().
BytesStream made up of the serialized flume event
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.
ReliableSpoolingFileEventReader.readEvents(int) call.
createTransaction if not.
Channel instance.
HostInterceptor.intercept(Event) in a loop.
Event.
RegexFilteringInterceptor.intercept(Event).
StaticInterceptor.intercept(Event) in a loop.
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.Resettable.reset() being called.
Resettable.reset() being called.
MorphlineHandler that processes it's events using a morphline Command chain.Command chain.Command chain, and loads them into Apache Solr.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.IndexRequestBuilder instance
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.
n lines associated with the input stream.
RegexExtractorInterceptorHbaseEventSerializer which parses columns based on a supplied
regular expression and column name list.ReliableEventReader which reads log data from files stored
in a spooling directory and renames each file once all of its data has been
read (through EventDeserializer.readEvent() calls).EventDeserializer.mark() was never previously called.
Resettable.mark() has never been called.
ResettableInputStream.mark()
ResettableFileInputStream.reset() is dependent on the underlying PositionTracker instance's durability semantics.marked and reset with no limit to
the number of bytes which may have been read between the calls.RPCClient implementations.LogEntry from existing
Scribe system.EventReader implementation which delegates to a
BufferedReader.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.
Sink implementation that can send events to an RPC server (such as
Flume's ThriftSource).Transaction client
semantics.
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||