A B C D E F G H I J K L M N O P Q R S T U V W X Z 

A

AbstractAvroEventSerializer<T> - Class in org.apache.flume.serialization
This is a helper class provided to make it straightforward to serialize Flume events into Avro data.
AbstractAvroEventSerializer() - Constructor for class org.apache.flume.serialization.AbstractAvroEventSerializer
 
AbstractChannel - Class in org.apache.flume.channel
 
AbstractChannel() - Constructor for class org.apache.flume.channel.AbstractChannel
 
AbstractChannelSelector - Class in org.apache.flume.channel
 
AbstractChannelSelector() - Constructor for class org.apache.flume.channel.AbstractChannelSelector
 
AbstractConfigurationProvider - Class in org.apache.flume.node
 
AbstractConfigurationProvider(String) - Constructor for class org.apache.flume.node.AbstractConfigurationProvider
 
AbstractElasticSearchIndexRequestBuilderFactory - Class in org.apache.flume.sink.elasticsearch
Abstract base class for custom implementations of ElasticSearchIndexRequestBuilderFactory.
AbstractElasticSearchIndexRequestBuilderFactory(FastDateFormat) - Constructor for class org.apache.flume.sink.elasticsearch.AbstractElasticSearchIndexRequestBuilderFactory
Constructor for subclasses
AbstractEventDrivenSource - Class in org.apache.flume.source
Base class which ensures sub-classes will inherit all the properties of BasicSourceSemantics.
AbstractEventDrivenSource() - Constructor for class org.apache.flume.source.AbstractEventDrivenSource
 
AbstractHDFSWriter - Class in org.apache.flume.sink.hdfs
 
AbstractHDFSWriter() - Constructor for class org.apache.flume.sink.hdfs.AbstractHDFSWriter
 
AbstractPollableSource - Class in org.apache.flume.source
Base class which ensures sub-classes will inherit all the properties of BasicSourceSemantics in addition to: Ensuring when configure/start throw an exception process will not be called Ensure that process will not be called unless configure and start have successfully been called
AbstractPollableSource() - Constructor for class org.apache.flume.source.AbstractPollableSource
 
AbstractRpcClient - Class in org.apache.flume.api
 
AbstractRpcClient() - Constructor for class org.apache.flume.api.AbstractRpcClient
 
AbstractRpcSink - Class in org.apache.flume.sink
This sink provides the basic RPC functionality for Flume.
AbstractRpcSink() - Constructor for class org.apache.flume.sink.AbstractRpcSink
 
AbstractSink - Class in org.apache.flume.sink
 
AbstractSink() - Constructor for class org.apache.flume.sink.AbstractSink
 
AbstractSinkProcessor - Class in org.apache.flume.sink
A convenience base class for sink processors.
AbstractSinkProcessor() - Constructor for class org.apache.flume.sink.AbstractSinkProcessor
 
AbstractSinkSelector - Class in org.apache.flume.sink
 
AbstractSinkSelector() - Constructor for class org.apache.flume.sink.AbstractSinkSelector
 
AbstractSource - Class in org.apache.flume.source
 
AbstractSource() - Constructor for class org.apache.flume.source.AbstractSource
 
AbstractZooKeeperConfigurationProvider - Class in org.apache.flume.node
ZooKeeper based configuration implementation provider.
AbstractZooKeeperConfigurationProvider(String, String, String) - Constructor for class org.apache.flume.node.AbstractZooKeeperConfigurationProvider
 
activateOptions() - Method in class org.apache.flume.clients.log4jappender.LoadBalancingLog4jAppender
Activate the options set using setHosts(), setSelector and setMaxBackoff
activateOptions() - Method in class org.apache.flume.clients.log4jappender.Log4jAppender
Activate the options set using setPort() and setHostname()
ACTIVE_KEY - Static variable in class org.apache.flume.channel.file.encryption.EncryptionConfiguration
Encryption key alias, default is null.
ACTIVELOGS_FIELD_NUMBER - Static variable in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
 
add(CounterGroup) - Method in class org.apache.flume.CounterGroup
 
addActiveLogs(ProtosFactory.ActiveLog) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
addActiveLogs(int, ProtosFactory.ActiveLog) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
addActiveLogs(ProtosFactory.ActiveLog.Builder) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
addActiveLogs(int, ProtosFactory.ActiveLog.Builder) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
addActiveLogsBuilder() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
addActiveLogsBuilder(int) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
addAllActiveLogs(Iterable<? extends ProtosFactory.ActiveLog>) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
addAllHeaders(Iterable<? extends ProtosFactory.FlumeEventHeader>) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
addAndGet(String, Long) - Method in class org.apache.flume.CounterGroup
 
addAndGet(String, long) - Method in class org.apache.flume.instrumentation.MonitoredCounterGroup
Atomically adds the delta to the current value for this key
addByteOffset(boolean) - Method in class org.apache.flume.source.taildir.ReliableTaildirEventReader.Builder
 
addChannel(String, Channel) - Method in interface org.apache.flume.node.MaterializedConfiguration
 
addChannel(String, Channel) - Method in class org.apache.flume.node.SimpleMaterializedConfiguration
 
addComplexField(XContentBuilder, String, XContentType, byte[]) - Static method in class org.apache.flume.sink.elasticsearch.ContentBuilderUtil
 
addEvent(Event, IndexNameBuilder, String, long) - Method in interface org.apache.flume.sink.elasticsearch.client.ElasticSearchClient
Add new event to the bulk
addEvent(Event, IndexNameBuilder, String, long) - Method in class org.apache.flume.sink.elasticsearch.client.ElasticSearchRestClient
 
addEvent(Event, IndexNameBuilder, String, long) - Method in class org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient
 
addFieldsToBody(Set<String>, String, String, String, String, String) - Static method in class org.apache.flume.source.SyslogUtils
 
addFormats(Map<String, String>) - Method in class org.apache.flume.source.SyslogUtils
 
addHeaders(ProtosFactory.FlumeEventHeader) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
addHeaders(int, ProtosFactory.FlumeEventHeader) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
addHeaders(ProtosFactory.FlumeEventHeader.Builder) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
addHeaders(int, ProtosFactory.FlumeEventHeader.Builder) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
addHeadersBuilder() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
addHeadersBuilder(int) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
addSimpleField(XContentBuilder, String, byte[]) - Static method in class org.apache.flume.sink.elasticsearch.ContentBuilderUtil
 
addSinkRunner(String, SinkRunner) - Method in interface org.apache.flume.node.MaterializedConfiguration
 
addSinkRunner(String, SinkRunner) - Method in class org.apache.flume.node.SimpleMaterializedConfiguration
 
addSourceRunner(String, SourceRunner) - Method in interface org.apache.flume.node.MaterializedConfiguration
 
addSourceRunner(String, SourceRunner) - Method in class org.apache.flume.node.SimpleMaterializedConfiguration
 
addToEventAcceptedCount(long) - Method in class org.apache.flume.instrumentation.SourceCounter
 
addToEventDrainAttemptCount(long) - Method in class org.apache.flume.instrumentation.SinkCounter
 
addToEventDrainSuccessCount(long) - Method in class org.apache.flume.instrumentation.SinkCounter
 
addToEventPutSuccessCount(long) - Method in class org.apache.flume.instrumentation.ChannelCounter
 
addToEventReceivedCount(long) - Method in class org.apache.flume.instrumentation.SourceCounter
 
addToEvents(ThriftFlumeEvent) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
 
addToEventTakeSuccessCount(long) - Method in class org.apache.flume.instrumentation.ChannelCounter
 
addToKafkaCommitTimer(long) - Method in class org.apache.flume.instrumentation.kafka.KafkaChannelCounter
 
addToKafkaCommitTimer(long) - Method in class org.apache.flume.instrumentation.kafka.KafkaSourceCounter
 
addToKafkaEventGetTimer(long) - Method in class org.apache.flume.instrumentation.kafka.KafkaChannelCounter
 
addToKafkaEventGetTimer(long) - Method in class org.apache.flume.instrumentation.kafka.KafkaSourceCounter
 
addToKafkaEventSendTimer(long) - Method in class org.apache.flume.instrumentation.kafka.KafkaChannelCounter
 
addToKafkaEventSendTimer(long) - Method in class org.apache.flume.instrumentation.kafka.KafkaSinkCounter
 
addToMessages(LogEntry) - Method in class org.apache.flume.source.scribe.Scribe.Log_args
 
addToRollbackCounter(long) - Method in class org.apache.flume.instrumentation.kafka.KafkaChannelCounter
 
AESCTRNoPaddingProvider - Class in org.apache.flume.channel.file.encryption
 
AESCTRNoPaddingProvider() - Constructor for class org.apache.flume.channel.file.encryption.AESCTRNoPaddingProvider
 
AESCTRNoPaddingProvider.DecryptorBuilder - Class in org.apache.flume.channel.file.encryption
 
AESCTRNoPaddingProvider.DecryptorBuilder() - Constructor for class org.apache.flume.channel.file.encryption.AESCTRNoPaddingProvider.DecryptorBuilder
 
AESCTRNoPaddingProvider.EncryptorBuilder - Class in org.apache.flume.channel.file.encryption
 
AESCTRNoPaddingProvider.EncryptorBuilder() - Constructor for class org.apache.flume.channel.file.encryption.AESCTRNoPaddingProvider.EncryptorBuilder
 
afterCreate() - Method in class org.apache.flume.serialization.AbstractAvroEventSerializer
 
afterCreate() - Method in class org.apache.flume.serialization.BodyTextEventSerializer
 
afterCreate() - Method in interface org.apache.flume.serialization.EventSerializer
Hook to write a header after file is opened for the first time.
afterCreate() - Method in class org.apache.flume.serialization.HeaderAndBodyTextEventSerializer
 
afterCreate() - Method in class org.apache.flume.sink.hdfs.AvroEventSerializer
 
afterReopen() - Method in class org.apache.flume.serialization.AbstractAvroEventSerializer
 
afterReopen() - Method in class org.apache.flume.serialization.BodyTextEventSerializer
 
afterReopen() - Method in interface org.apache.flume.serialization.EventSerializer
Hook to handle any framing needed when file is re-opened (for write).
Could have been named afterOpenForAppend().
afterReopen() - Method in class org.apache.flume.serialization.HeaderAndBodyTextEventSerializer
 
afterReopen() - Method in class org.apache.flume.sink.hdfs.AvroEventSerializer
 
ALIAS - Static variable in class org.apache.flume.sink.hive.HiveDelimitedTextSerializer
 
ALIAS - Static variable in class org.apache.flume.sink.hive.HiveJsonSerializer
 
allocate(int) - Static method in class org.apache.flume.tools.DirectMemoryUtils
 
allowedFormats() - Method in class org.apache.flume.sink.kite.DatasetSink
Return the list of allowed formats.
allowLogPrintConfig() - Static method in class org.apache.flume.conf.LogPrivacyUtil
Tells whether logging of potentially sensitive user data is allowed or not.
allowLogRawData() - Static method in class org.apache.flume.conf.LogPrivacyUtil
Tells whether logging of configuration details - including secrets - is allowed or not.
annotateBaseName(Boolean) - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
 
annotateFileName(Boolean) - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
 
annotateFileName(boolean) - Method in class org.apache.flume.source.taildir.ReliableTaildirEventReader.Builder
 
append(ThriftFlumeEvent, AsyncMethodCallback<ThriftFlumeEventServer.AsyncClient.append_call>) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncClient
 
append(ThriftFlumeEvent, AsyncMethodCallback<ThriftFlumeEventServer.AsyncClient.append_call>) - Method in interface com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncIface
 
append(ThriftFlumeEvent) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Client
 
append(ThriftFlumeEvent) - Method in interface com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Iface
 
append(Event) - Method in class org.apache.flume.api.AbstractRpcClient
 
append(Event) - Method in class org.apache.flume.api.FailoverRpcClient
Tries to append an event to the currently connected client.
append(Event) - Method in class org.apache.flume.api.LoadBalancingRpcClient
 
append(Event) - Method in class org.apache.flume.api.NettyAvroRpcClient
 
append(Event) - Method in interface org.apache.flume.api.RpcClient
Send a single Event to the associated Flume source.
append(Event) - Method in class org.apache.flume.api.ThriftRpcClient
 
append(LoggingEvent) - Method in class org.apache.flume.clients.log4jappender.LoadBalancingLog4jAppender
 
append(LoggingEvent) - Method in class org.apache.flume.clients.log4jappender.Log4jAppender
Append the LoggingEvent, to send to the first Flume hop.
append(Event) - Method in class org.apache.flume.sink.hdfs.HDFSCompressedDataStream
 
append(Event) - Method in class org.apache.flume.sink.hdfs.HDFSDataStream
 
append(Event) - Method in class org.apache.flume.sink.hdfs.HDFSSequenceFile
 
append(Event) - Method in interface org.apache.flume.sink.hdfs.HDFSWriter
 
append(AvroFlumeOGEvent) - Method in class org.apache.flume.source.avroLegacy.AvroLegacySource
 
append(AvroFlumeEvent) - Method in class org.apache.flume.source.AvroSource
 
append(ThriftFlumeEvent, AsyncMethodCallback<ThriftSourceProtocol.AsyncClient.append_call>) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.AsyncClient
 
append(ThriftFlumeEvent, AsyncMethodCallback<ThriftSourceProtocol.AsyncClient.append_call>) - Method in interface org.apache.flume.thrift.ThriftSourceProtocol.AsyncIface
 
append(ThriftFlumeEvent) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.Client
 
append(ThriftFlumeEvent) - Method in interface org.apache.flume.thrift.ThriftSourceProtocol.Iface
 
appendBatch(List<Event>) - Method in class org.apache.flume.api.AbstractRpcClient
 
appendBatch(List<Event>) - Method in class org.apache.flume.api.FailoverRpcClient
Tries to append a list of events to the currently connected client.
appendBatch(List<Event>) - Method in class org.apache.flume.api.LoadBalancingRpcClient
 
appendBatch(List<Event>) - Method in class org.apache.flume.api.NettyAvroRpcClient
 
appendBatch(List<Event>) - Method in interface org.apache.flume.api.RpcClient
Send a list of events to the associated Flume source.
appendBatch(List<Event>) - Method in class org.apache.flume.api.ThriftRpcClient
 
appendBatch(List<AvroFlumeEvent>) - Method in class org.apache.flume.source.AvroSource
 
appendBatch(List<ThriftFlumeEvent>, AsyncMethodCallback<ThriftSourceProtocol.AsyncClient.appendBatch_call>) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.AsyncClient
 
appendBatch(List<ThriftFlumeEvent>, AsyncMethodCallback<ThriftSourceProtocol.AsyncClient.appendBatch_call>) - Method in interface org.apache.flume.thrift.ThriftSourceProtocol.AsyncIface
 
appendBatch(List<ThriftFlumeEvent>) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.Client
 
appendBatch(List<ThriftFlumeEvent>) - Method in interface org.apache.flume.thrift.ThriftSourceProtocol.Iface
 
appendField(XContentBuilder, String, byte[]) - Static method in class org.apache.flume.sink.elasticsearch.ContentBuilderUtil
 
Application - Class in org.apache.flume.node
 
Application() - Constructor for class org.apache.flume.node.Application
 
Application(List<LifecycleAware>) - Constructor for class org.apache.flume.node.Application
 
AsyncHbaseEventSerializer - Interface in org.apache.flume.sink.hbase
Interface for an event serializer which serializes the headers and body of an event to write them to hbase.
AsyncHBaseSink - Class in org.apache.flume.sink.hbase
A simple sink which reads events from a channel and writes them to HBase.
AsyncHBaseSink() - Constructor for class org.apache.flume.sink.hbase.AsyncHBaseSink
 
AsyncHBaseSink(Configuration) - Constructor for class org.apache.flume.sink.hbase.AsyncHBaseSink
 
AUTH_KEYTAB - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
 
AUTH_PRINCIPAL - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
 
AUTH_PROXY_USER - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
Hadoop authentication settings
AUTO_COMMIT_ENABLED - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
AVAILABLE_PARSERS - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
 
AVAILABLE_POLICIES - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
 
AVG_EVENT_SIZE - Static variable in class org.apache.flume.channel.SpillableMemoryChannel
Estimated average size of events expected to be in the channel
AVRO_ENTITY_PARSER - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
Built-in entity parsers
AVRO_EVENT - Static variable in class org.apache.flume.sink.kafka.KafkaSinkConstants
 
AVRO_EVENT - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants
 
AVRO_SCHEMA_HEADER_HASH - Static variable in class org.apache.flume.serialization.AvroEventDeserializer
 
AVRO_SCHEMA_HEADER_LITERAL - Static variable in class org.apache.flume.serialization.AvroEventDeserializer
 
AVRO_SCHEMA_LITERAL_HEADER - Static variable in class org.apache.flume.sink.hdfs.AvroEventSerializer
 
AVRO_SCHEMA_LITERAL_HEADER - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
Headers where avro schema information is expected.
AVRO_SCHEMA_URL_HEADER - Static variable in class org.apache.flume.sink.hdfs.AvroEventSerializer
 
AVRO_SCHEMA_URL_HEADER - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
 
AvroCLIClient - Class in org.apache.flume.client.avro
 
AvroCLIClient() - Constructor for class org.apache.flume.client.avro.AvroCLIClient
 
avroClient - Variable in class org.apache.flume.source.avroLegacy.AvroLegacySource
 
AvroEventDeserializer - Class in org.apache.flume.serialization
A deserializer that parses Avro container files, generating one Flume event per record in the Avro file, and storing binary avro-encoded records in the Flume event body.
AvroEventDeserializer.AvroSchemaType - Enum in org.apache.flume.serialization
 
AvroEventDeserializer.Builder - Class in org.apache.flume.serialization
 
AvroEventDeserializer.Builder() - Constructor for class org.apache.flume.serialization.AvroEventDeserializer.Builder
 
AvroEventSerializer - Class in org.apache.flume.sink.hdfs
This class serializes Flume events into Avro data files.
AvroEventSerializer.Builder - Class in org.apache.flume.sink.hdfs
 
AvroEventSerializer.Builder() - Constructor for class org.apache.flume.sink.hdfs.AvroEventSerializer.Builder
 
AvroEventSerializerConfigurationConstants - Class in org.apache.flume.serialization
 
AvroEventSerializerConfigurationConstants() - Constructor for class org.apache.flume.serialization.AvroEventSerializerConfigurationConstants
 
AvroLegacySource - Class in org.apache.flume.source.avroLegacy
A Source implementation that receives Avro events from Avro sink of Flume OG
AvroLegacySource() - Constructor for class org.apache.flume.source.avroLegacy.AvroLegacySource
 
AvroParser - Class in org.apache.flume.sink.kite.parser
An EntityParser that parses Avro serialized bytes from an event.
AvroParser.Builder - Class in org.apache.flume.sink.kite.parser
 
AvroParser.Builder() - Constructor for class org.apache.flume.sink.kite.parser.AvroParser.Builder
 
AvroSink - Class in org.apache.flume.sink
A Sink implementation that can send events to an RPC server (such as Flume's AvroSource).
AvroSink() - Constructor for class org.apache.flume.sink.AvroSink
 
AvroSource - Class in org.apache.flume.source
A Source implementation that receives Avro events from clients that implement AvroSourceProtocol.
AvroSource() - Constructor for class org.apache.flume.source.AvroSource
 

B

BACKOFF_SLEEP_INCREMENT - Static variable in class org.apache.flume.source.PollableSourceConstants
 
BACKUP_CHECKPOINT_DIR - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
The directory to which the checkpoint must be backed up
BACKUPCHECKPOINTPOSITION_FIELD_NUMBER - Static variable in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
 
BACKUPCHECKPOINTWRITEORDERID_FIELD_NUMBER - Static variable in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
 
BadCheckpointException - Exception in org.apache.flume.channel.file
Exception thrown when the checkpoint directory contains invalid data, probably due to the channel stopping while the checkpoint was written.
BadCheckpointException(String) - Constructor for exception org.apache.flume.channel.file.BadCheckpointException
 
BadCheckpointException(String, Throwable) - Constructor for exception org.apache.flume.channel.file.BadCheckpointException
 
BASENAME_HEADER - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
Whether to include the basename of a file in a header.
BASENAME_HEADER_KEY - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
Header in which to put the basename of file.
baseNameHeader(String) - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
 
basePath - Variable in class org.apache.flume.node.AbstractZooKeeperConfigurationProvider
 
BasicChannelSemantics - Class in org.apache.flume.channel
An implementation of basic Channel semantics, including the implied thread-local semantics of the Transaction class, which is required to extend BasicTransactionSemantics.
BasicChannelSemantics() - Constructor for class org.apache.flume.channel.BasicChannelSemantics
 
BasicConfigurationConstants - Class in org.apache.flume.conf
 
BasicSourceSemantics - Class in org.apache.flume.source
Alternative to AbstractSource, which: Ensure configure cannot be called while started Exceptions thrown during configure, start, stop put source in ERROR state Exceptions thrown during start, stop will be logged but not re-thrown. Exception in configure disables starting
BasicSourceSemantics() - Constructor for class org.apache.flume.source.BasicSourceSemantics
 
BasicTransactionSemantics - Class in org.apache.flume.channel
An implementation of basic Transaction semantics designed to work in concert with BasicChannelSemantics to simplify creation of robust Channel implementations.
BasicTransactionSemantics() - Constructor for class org.apache.flume.channel.BasicTransactionSemantics
 
BasicTransactionSemantics.State - Enum in org.apache.flume.channel
The state of the Transaction to which it belongs.
BATCH_DURATION_MILLIS - Static variable in class org.apache.flume.sink.solr.morphline.MorphlineSink
 
BATCH_DURATION_MS - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants
 
BATCH_SIZE - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
Maximum number of events the sink should take from the channel per transaction, if available.
BATCH_SIZE - Static variable in class org.apache.flume.sink.hive.Config
 
BATCH_SIZE - Static variable in class org.apache.flume.sink.kafka.KafkaSinkConstants
 
BATCH_SIZE - Static variable in class org.apache.flume.sink.solr.morphline.MorphlineSink
 
BATCH_SIZE - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
BATCH_SIZE - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants
 
BATCH_SIZE - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
What size to batch with before sending to ChannelProcessor.
BATCH_SIZE - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
What size to batch with before sending to ChannelProcessor.
BATCH_SIZE_DEFAULT - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
BatchAware - Interface in org.apache.flume.sink.hbase
This interface allows for implementing HBase serializers that are aware of batching.
batchSize - Variable in class org.apache.flume.api.AbstractRpcClient
 
beforeClose() - Method in class org.apache.flume.serialization.AbstractAvroEventSerializer
 
beforeClose() - Method in class org.apache.flume.serialization.BodyTextEventSerializer
 
beforeClose() - Method in interface org.apache.flume.serialization.EventSerializer
Hook to write a trailer before the stream is closed.
beforeClose() - Method in class org.apache.flume.serialization.HeaderAndBodyTextEventSerializer
 
beforeClose() - Method in class org.apache.flume.sink.hdfs.AvroEventSerializer
 
begin() - Method in class org.apache.flume.channel.BasicTransactionSemantics
 
begin() - Method in class org.apache.flume.channel.jdbc.impl.JdbcTransactionImpl
 
begin() - Method in class org.apache.flume.channel.PseudoTxnMemoryChannel.NoOpTransaction
 
begin() - Method in interface org.apache.flume.Transaction
Starts a transaction boundary for the current channel operation.
beginTransaction() - Method in interface org.apache.flume.sink.solr.morphline.MorphlineHandler
Begins a transaction
beginTransaction() - Method in class org.apache.flume.sink.solr.morphline.MorphlineHandlerImpl
 
BINARY_PROTOCOL - Static variable in class org.apache.flume.api.ThriftRpcClient
 
BINARY_PROTOCOL - Static variable in class org.apache.flume.source.ThriftSource
 
BlobDeserializer - Class in org.apache.flume.sink.solr.morphline
A deserializer that reads a Binary Large Object (BLOB) per event, typically one BLOB per file; To be used in conjunction with Flume SpoolDirectorySource.
BlobDeserializer(Context, ResettableInputStream) - Constructor for class org.apache.flume.sink.solr.morphline.BlobDeserializer
 
BlobDeserializer.Builder - Class in org.apache.flume.sink.solr.morphline
Builder implementations MUST have a public no-arg constructor
BlobDeserializer.Builder() - Constructor for class org.apache.flume.sink.solr.morphline.BlobDeserializer.Builder
 
BlobHandler - Class in org.apache.flume.sink.solr.morphline
BlobHandler for HTTPSource that returns event that contains the request parameters as well as the Binary Large Object (BLOB) uploaded with this request.
BlobHandler() - Constructor for class org.apache.flume.sink.solr.morphline.BlobHandler
 
BLOBHandler - Class in org.apache.flume.source.http
BLOBHandler for HTTPSource that accepts any binary stream of data as event.
BLOBHandler() - Constructor for class org.apache.flume.source.http.BLOBHandler
 
body - Variable in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
body - Variable in class org.apache.flume.thrift.ThriftFlumeEvent
 
BODY_FIELD_NUMBER - Static variable in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
 
BodyTextEventSerializer - Class in org.apache.flume.serialization
This class simply writes the body of the event to the output stream and appends a newline after each event.
BodyTextEventSerializer.Builder - Class in org.apache.flume.serialization
 
BodyTextEventSerializer.Builder() - Constructor for class org.apache.flume.serialization.BodyTextEventSerializer.Builder
 
BOOTSTRAP_SERVERS - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants
 
BOOTSTRAP_SERVERS_CONFIG - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
BOOTSTRAP_SERVERS_CONFIG - Static variable in class org.apache.flume.sink.kafka.KafkaSinkConstants
 
BROKER_LIST_FLUME_KEY - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
BROKER_LIST_FLUME_KEY - Static variable in class org.apache.flume.sink.kafka.KafkaSinkConstants
 
BROKER_LIST_KEY - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
Old Configuration Parameters
BucketClosedException - Exception in org.apache.flume.sink.hdfs
 
BucketClosedException(String) - Constructor for exception org.apache.flume.sink.hdfs.BucketClosedException
 
BucketPath - Class in org.apache.flume.formatter.output
 
BucketPath() - Constructor for class org.apache.flume.formatter.output.BucketPath
 
buffer - Variable in class org.apache.flume.instrumentation.GangliaServer
 
BUFFER_MAX_LINE_LENGTH - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
Deprecated.
BUFFER_MAX_LINES - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
Deprecated.
BUFFER_SIZE - Static variable in class org.apache.flume.instrumentation.GangliaServer
 
bufferForBody() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
bufferForBody() - Method in class org.apache.flume.thrift.ThriftFlumeEvent
 
build() - Method in class org.apache.flume.channel.file.encryption.AESCTRNoPaddingProvider.DecryptorBuilder
 
build() - Method in class org.apache.flume.channel.file.encryption.AESCTRNoPaddingProvider.EncryptorBuilder
 
build() - Method in class org.apache.flume.channel.file.encryption.CipherProvider.Decryptor.Builder
 
build() - Method in class org.apache.flume.channel.file.encryption.CipherProvider.Encryptor.Builder
 
build(Context) - Method in class org.apache.flume.channel.file.encryption.JCEFileKeyProvider.Builder
 
build(Context) - Method in interface org.apache.flume.channel.file.encryption.KeyProvider.Builder
 
build() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
 
build() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
 
build() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit.Builder
 
build() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
 
build() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
 
build() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
 
build() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
 
build() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
 
build() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback.Builder
 
build() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
 
build() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter.Builder
 
build() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
 
build() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.Builder
 
build() - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
 
build(Context) - Method in class org.apache.flume.formatter.output.DefaultPathManager.Builder
 
build(Context) - Method in interface org.apache.flume.formatter.output.PathManager.Builder
 
build(Context) - Method in class org.apache.flume.formatter.output.RollTimePathManager.Builder
 
build() - Method in class org.apache.flume.interceptor.HostInterceptor.Builder
 
build() - Method in interface org.apache.flume.interceptor.Interceptor.Builder
 
build() - Method in class org.apache.flume.interceptor.RegexExtractorInterceptor.Builder
 
build() - Method in class org.apache.flume.interceptor.RegexFilteringInterceptor.Builder
 
build() - Method in class org.apache.flume.interceptor.SearchAndReplaceInterceptor.Builder
 
build() - Method in class org.apache.flume.interceptor.StaticInterceptor.Builder
 
build() - Method in class org.apache.flume.interceptor.TimestampInterceptor.Builder
 
build(Context, ResettableInputStream) - Method in class org.apache.flume.serialization.AvroEventDeserializer.Builder
 
build(Context, OutputStream) - Method in class org.apache.flume.serialization.BodyTextEventSerializer.Builder
 
build(Context, ResettableInputStream) - Method in interface org.apache.flume.serialization.EventDeserializer.Builder
 
build(Context, ResettableInputStream, OutputStream) - Method in interface org.apache.flume.serialization.EventSerDe.Builder
 
build(Context, OutputStream) - Method in interface org.apache.flume.serialization.EventSerializer.Builder
 
build(Context, OutputStream) - Method in class org.apache.flume.serialization.FlumeEventAvroEventSerializer.Builder
 
build(Context, OutputStream) - Method in class org.apache.flume.serialization.HeaderAndBodyTextEventSerializer.Builder
 
build(Context, ResettableInputStream) - Method in class org.apache.flume.serialization.LineDeserializer.Builder
 
build(Context, OutputStream) - Method in class org.apache.flume.sink.hdfs.AvroEventSerializer.Builder
 
build(Context) - Method in class org.apache.flume.sink.hdfs.HDFSTextSerializer.Builder
 
build(Context) - Method in class org.apache.flume.sink.hdfs.HDFSWritableSerializer.Builder
 
build(Context) - Method in interface org.apache.flume.sink.hdfs.SequenceFileSerializer.Builder
 
build(Schema, Context) - Method in class org.apache.flume.sink.kite.parser.AvroParser.Builder
 
build(Schema, Context) - Method in interface org.apache.flume.sink.kite.parser.EntityParser.Builder
 
build(Context) - Method in interface org.apache.flume.sink.kite.policy.FailurePolicy.Builder
Build a new FailurePolicy
build(Context) - Method in class org.apache.flume.sink.kite.policy.RetryPolicy.Builder
 
build(Context) - Method in class org.apache.flume.sink.kite.policy.SavePolicy.Builder
 
build(Context, ResettableInputStream) - Method in class org.apache.flume.sink.solr.morphline.BlobDeserializer.Builder
 
build() - Method in class org.apache.flume.sink.solr.morphline.MorphlineInterceptor.Builder
 
build() - Method in class org.apache.flume.sink.solr.morphline.UUIDInterceptor.Builder
 
build(Context) - Method in class org.apache.flume.source.jms.DefaultJMSMessageConverter.Builder
 
build(Context) - Method in interface org.apache.flume.source.jms.JMSMessageConverter.Builder
 
build() - Method in class org.apache.flume.source.taildir.ReliableTaildirEventReader.Builder
 
build() - Method in interface org.apache.flume.tools.EventValidator.Builder
 
buildPartial() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
 
buildPartial() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
 
buildPartial() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit.Builder
 
buildPartial() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
 
buildPartial() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
 
buildPartial() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
 
buildPartial() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
 
buildPartial() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
 
buildPartial() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback.Builder
 
buildPartial() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
 
buildPartial() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter.Builder
 
buildPartial() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
 
BYTE_CAPACITY - Static variable in class org.apache.flume.channel.SpillableMemoryChannel
max number of bytes used for all events in the queue.
BYTE_CAPACITY_BUFFER_PERCENTAGE - Static variable in class org.apache.flume.channel.SpillableMemoryChannel
percent of buffer between byteCapacity and the estimated event size.
BYTE_OFFSET_HEADER - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
Whether to add the byte offset of a tailed line to the header
BYTE_OFFSET_HEADER_KEY - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
 

C

CACHE_PATTERN_MATCHING - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
Whether to cache the list of files matching the specified file patterns till parent directory is modified.
cachePatternMatching(boolean) - Method in class org.apache.flume.source.taildir.ReliableTaildirEventReader.Builder
 
CALL_TIMEOUT - Static variable in class org.apache.flume.sink.hive.Config
 
CAPACITY - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
Maximum capacity of the channel.
CAPACITY - Static variable in class org.apache.flume.channel.SpillableMemoryChannel
file channel capacity overridden by Spillable Channel
category - Variable in class org.apache.flume.source.scribe.LogEntry
 
cf - Variable in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
 
CHANNEL - Static variable in class org.apache.flume.agent.embedded.EmbeddedAgentConfiguration
Prefix for channel properties
Channel - Interface in org.apache.flume
A channel connects a Source to a Sink.
channel - Variable in class org.apache.flume.conf.sink.SinkConfiguration
 
CHANNEL_NAME_MAX_LENGTH - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
The maximum length of channel name.
CHANNEL_PREFIX - Static variable in class org.apache.flume.agent.embedded.EmbeddedAgentConfiguration
Prefix for passing configuration parameters to the channel
CHANNEL_TYPE - Static variable in class org.apache.flume.agent.embedded.EmbeddedAgentConfiguration
Channel type, choices are `memory' or `file'
CHANNEL_TYPE_FILE - Static variable in class org.apache.flume.agent.embedded.EmbeddedAgentConfiguration
File based channel which stores events in on local disk.
CHANNEL_TYPE_MEMORY - Static variable in class org.apache.flume.agent.embedded.EmbeddedAgentConfiguration
Memory channel which stores events in heap.
CHANNEL_TYPE_SPILLABLEMEMORY - Static variable in class org.apache.flume.agent.embedded.EmbeddedAgentConfiguration
Spillable Memory channel which stores events in heap.
ChannelConfiguration - Class in org.apache.flume.conf.channel
 
ChannelConfiguration(String) - Constructor for class org.apache.flume.conf.channel.ChannelConfiguration
 
ChannelConfiguration.ChannelConfigurationType - Enum in org.apache.flume.conf.channel
 
channelCounter - Variable in class org.apache.flume.channel.SpillableMemoryChannel
 
ChannelCounter - Class in org.apache.flume.instrumentation
 
ChannelCounter(String) - Constructor for class org.apache.flume.instrumentation.ChannelCounter
 
ChannelCounter(String, String[]) - Constructor for class org.apache.flume.instrumentation.ChannelCounter
 
ChannelCounterMBean - Interface in org.apache.flume.instrumentation
This interface represents a channel counter mbean.
ChannelException - Exception in org.apache.flume
A channel exception is raised whenever a channel operation fails.
ChannelException(String) - Constructor for exception org.apache.flume.ChannelException
 
ChannelException(Throwable) - Constructor for exception org.apache.flume.ChannelException
 
ChannelException(String, Throwable) - Constructor for exception org.apache.flume.ChannelException
 
ChannelFactory - Interface in org.apache.flume
 
ChannelFullException - Exception in org.apache.flume
 
ChannelFullException(String) - Constructor for exception org.apache.flume.ChannelFullException
 
ChannelFullException(Throwable) - Constructor for exception org.apache.flume.ChannelFullException
 
ChannelFullException(String, Throwable) - Constructor for exception org.apache.flume.ChannelFullException
 
channelNames - Variable in class org.apache.flume.conf.channel.ChannelSelectorConfiguration
 
ChannelProcessor - Class in org.apache.flume.channel
A channel processor exposes operations to put Events into Channels.
ChannelProcessor(ChannelSelector) - Constructor for class org.apache.flume.channel.ChannelProcessor
 
ChannelProcessorCounter - Class in org.apache.flume.instrumentation
 
ChannelProcessorCounter(String) - Constructor for class org.apache.flume.instrumentation.ChannelProcessorCounter
 
channels - Variable in class org.apache.flume.conf.source.SourceConfiguration
 
ChannelSelector - Interface in org.apache.flume
Allows the selection of a subset of channels from the given set based on its implementation policy.
ChannelSelectorConfiguration - Class in org.apache.flume.conf.channel
 
ChannelSelectorConfiguration(String) - Constructor for class org.apache.flume.conf.channel.ChannelSelectorConfiguration
 
ChannelSelectorConfiguration.ChannelSelectorConfigurationType - Enum in org.apache.flume.conf.channel
 
ChannelSelectorFactory - Class in org.apache.flume.channel
 
ChannelSelectorFactory() - Constructor for class org.apache.flume.channel.ChannelSelectorFactory
 
ChannelSelectorType - Enum in org.apache.flume.conf.channel
Enumeration of built in channel selector types available in the system.
ChannelType - Enum in org.apache.flume.conf.channel
Enumeration of built in channel types available in the system.
ChannelUtils - Class in org.apache.flume.channel
A collection of utilities for interacting with Channel objects.
charset - Static variable in interface org.apache.flume.sink.elasticsearch.ElasticSearchEventSerializer
 
CHARSET - Static variable in class org.apache.flume.source.ExecSourceConfigurationConstants
Charset for reading input
CHARSET_CONFIG - Static variable in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
What charset to use when serializing into HBase's byte arrays
CHARSET_DEFAULT - Static variable in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
 
CHARSET_DFLT - Static variable in class org.apache.flume.serialization.LineDeserializer
 
CHECKPOINT_DIR - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
Directory Checkpoints will be written in
CHECKPOINT_INTERVAL - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
Interval at which checkpoints should be taken.
CHECKPOINTPOSITION_FIELD_NUMBER - Static variable in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
 
CheckpointRebuilder - Class in org.apache.flume.channel.file
 
CheckpointRebuilder(List<File>, FlumeEventQueue, boolean) - Constructor for class org.apache.flume.channel.file.CheckpointRebuilder
 
CHECKPOINTWRITEORDERID_FIELD_NUMBER - Static variable in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
 
checkResultsAgainstSkew(PartitionTestScenario, Map<Integer, List<Event>>, Map<Integer, List<byte[]>>, int, int) - Static method in class org.apache.flume.shared.kafka.test.KafkaPartitionTestUtil
This method checks the retrieved messages (passed as resultsMap) against the expected results (passed as partitionMap).
CHECKSUM_FIELD_NUMBER - Static variable in class org.apache.flume.channel.file.proto.ProtosFactory.Put
 
CHKPT_ONCLOSE - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
chooseFieldsToKeep(String) - Static method in class org.apache.flume.source.SyslogUtils
 
CIPHER_PROVIDER - Static variable in class org.apache.flume.channel.file.encryption.EncryptionConfiguration
Encryption cipher provider, default is null.
CipherProvider - Class in org.apache.flume.channel.file.encryption
 
CipherProvider() - Constructor for class org.apache.flume.channel.file.encryption.CipherProvider
 
CipherProvider.Decryptor - Class in org.apache.flume.channel.file.encryption
 
CipherProvider.Decryptor() - Constructor for class org.apache.flume.channel.file.encryption.CipherProvider.Decryptor
 
CipherProvider.Decryptor.Builder<T extends CipherProvider.Decryptor> - Class in org.apache.flume.channel.file.encryption
Builder implementations MUST have a no-arg constructor
CipherProvider.Decryptor.Builder() - Constructor for class org.apache.flume.channel.file.encryption.CipherProvider.Decryptor.Builder
 
CipherProvider.Encryptor - Class in org.apache.flume.channel.file.encryption
 
CipherProvider.Encryptor() - Constructor for class org.apache.flume.channel.file.encryption.CipherProvider.Encryptor
 
CipherProvider.Encryptor.Builder<T extends CipherProvider.Encryptor> - Class in org.apache.flume.channel.file.encryption
Builder implementations MUST have a no-arg constructor
CipherProvider.Encryptor.Builder() - Constructor for class org.apache.flume.channel.file.encryption.CipherProvider.Encryptor.Builder
 
CIPHERPROVIDER_FIELD_NUMBER - Static variable in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
 
CipherProviderFactory - Class in org.apache.flume.channel.file.encryption
 
CipherProviderFactory() - Constructor for class org.apache.flume.channel.file.encryption.CipherProviderFactory
 
CipherProviderType - Enum in org.apache.flume.channel.file.encryption
 
clean(ByteBuffer) - Static method in class org.apache.flume.tools.DirectMemoryUtils
 
cleanUp() - Method in interface org.apache.flume.sink.hbase.AsyncHbaseEventSerializer
Clean up any state.
cleanUp() - Method in class org.apache.flume.sink.hbase.SimpleAsyncHbaseEventSerializer
 
clear() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
clear() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args
 
clear() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args
 
clear() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result
 
clear() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
 
clear() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
 
clear() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit.Builder
 
clear() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
 
clear() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
 
clear() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
 
clear() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
 
clear() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
 
clear() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback.Builder
 
clear() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
 
clear() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter.Builder
 
clear() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
 
clear() - Method in class org.apache.flume.Context
Removes all of the mappings from this map.
clear() - Method in class org.apache.flume.source.scribe.LogEntry
 
clear() - Method in class org.apache.flume.source.scribe.Scribe.Log_args
 
clear() - Method in class org.apache.flume.source.scribe.Scribe.Log_result
 
clear() - Method in class org.apache.flume.thrift.ThriftFlumeEvent
 
clear() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_args
 
clear() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_result
 
clear() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
 
clear() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result
 
clearActiveLogs() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
clearBackupCheckpointPosition() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
optional sfixed64 backupCheckpointPosition = 6;
clearBackupCheckpointWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
optional sfixed64 backupCheckpointWriteOrderID = 7;
clearBody() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
required bytes body = 2;
clearCheckpointPosition() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
required sfixed64 checkpointPosition = 3;
clearCheckpointWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
required sfixed64 checkpointWriteOrderID = 4;
clearChecksum() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
optional sfixed64 checksum = 2;
clearCipherProvider() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
required string cipherProvider = 1;
clearCount() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
required sfixed32 count = 2;
clearEncryption() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
optional .LogFileEncryption encryption = 5;
clearEvent() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
required .FlumeEvent event = 1;
clearFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
required sfixed32 fileID = 1;
clearHeaders() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
clearKey() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
required string key = 1;
clearKeyAlias() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
required string keyAlias = 2;
clearLogFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
required sfixed32 logFileID = 1;
clearLogFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
required sfixed32 logFileID = 2;
clearOffset() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
required sfixed32 offset = 2;
clearParameters() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
optional bytes parameters = 3;
clearQueueHead() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
required sfixed32 queueHead = 4;
clearQueueSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
required sfixed32 queueSize = 3;
clearTransactionID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
required sfixed64 transactionID = 2;
clearType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit.Builder
required sfixed32 type = 1;
clearType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
required sfixed32 type = 1;
clearValue() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
required string value = 2;
clearVersion() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
required sfixed32 version = 1;
clearVersion() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
required sfixed32 version = 1;
clearWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
required sfixed64 writeOrderID = 2;
clearWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
required sfixed64 writeOrderID = 3;
CLIENT_PREFIX - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
The client prefix to extract the configuration that will be passed to elasticsearch client.
CLIENT_TYPE - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
The client type used for sending bulks to ElasticSearch
Clock - Interface in org.apache.flume
Facade for System.currentTimeMillis for Testing
clone() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
 
clone() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
 
clone() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit.Builder
 
clone() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
 
clone() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
 
clone() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
 
clone() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
 
clone() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
 
clone() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback.Builder
 
clone() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
 
clone() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter.Builder
 
clone() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
 
close(AsyncMethodCallback<ThriftFlumeEventServer.AsyncClient.close_call>) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncClient
 
close(AsyncMethodCallback<ThriftFlumeEventServer.AsyncClient.close_call>) - Method in interface com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncIface
 
close() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Client
 
close() - Method in interface com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Iface
 
close() - Method in class org.apache.flume.api.AbstractRpcClient
 
close() - Method in class org.apache.flume.api.FailoverRpcClient
Close the connection.
close() - Method in class org.apache.flume.api.LoadBalancingRpcClient
 
close() - Method in class org.apache.flume.api.NettyAvroRpcClient
 
close() - Method in interface org.apache.flume.api.RpcClient
Immediately closes the client so that it may no longer be used.
close() - Method in class org.apache.flume.api.ThriftRpcClient
 
close() - Method in class org.apache.flume.channel.BasicTransactionSemantics
 
close() - Method in class org.apache.flume.channel.ChannelProcessor
 
close() - Method in class org.apache.flume.channel.file.LogFile.OperationRecordUpdater
 
close() - Method in class org.apache.flume.channel.file.LogFile.SequentialReader
 
close() - Method in class org.apache.flume.channel.jdbc.impl.JdbcChannelProviderImpl
 
close() - Method in class org.apache.flume.channel.jdbc.impl.JdbcTransactionImpl
 
close() - Method in interface org.apache.flume.channel.jdbc.JdbcChannelProvider
Deinitializes the channel provider.
close() - Method in class org.apache.flume.channel.PseudoTxnMemoryChannel.NoOpTransaction
 
close() - Method in interface org.apache.flume.client.avro.EventReader
Clean-up any state associated with this reader.
close() - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader
 
close() - Method in class org.apache.flume.client.avro.SimpleTextLineEventReader
 
close() - Method in class org.apache.flume.clients.log4jappender.Log4jAppender
Closes underlying client.
close() - Method in class org.apache.flume.interceptor.HostInterceptor
 
close() - Method in interface org.apache.flume.interceptor.Interceptor
Perform any closing / shutdown needed by the Interceptor.
close() - Method in class org.apache.flume.interceptor.InterceptorChain
 
close() - Method in class org.apache.flume.interceptor.RegexExtractorInterceptor
 
close() - Method in class org.apache.flume.interceptor.RegexFilteringInterceptor
 
close() - Method in class org.apache.flume.interceptor.SearchAndReplaceInterceptor
 
close() - Method in class org.apache.flume.interceptor.StaticInterceptor
 
close() - Method in class org.apache.flume.interceptor.TimestampInterceptor
 
close() - Method in class org.apache.flume.serialization.AvroEventDeserializer
 
close() - Method in class org.apache.flume.serialization.DurablePositionTracker
 
close() - Method in interface org.apache.flume.serialization.EventDeserializer
Calls EventDeserializer.reset() on the stream and then closes it.
close() - Method in class org.apache.flume.serialization.LineDeserializer
 
close() - Method in interface org.apache.flume.serialization.PositionTracker
 
close() - Method in class org.apache.flume.serialization.ResettableFileInputStream
 
close() - Method in class org.apache.flume.serialization.ResettableInputStream
 
close() - Method in interface org.apache.flume.sink.elasticsearch.client.ElasticSearchClient
Close connection to elastic search in client
close() - Method in class org.apache.flume.sink.elasticsearch.client.ElasticSearchRestClient
 
close() - Method in class org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient
 
close() - Method in interface org.apache.flume.sink.hbase.HbaseEventSerializer
 
close() - Method in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
 
close() - Method in class org.apache.flume.sink.hbase.SimpleHbaseEventSerializer
 
close() - Method in class org.apache.flume.sink.hdfs.HDFSCompressedDataStream
 
close() - Method in class org.apache.flume.sink.hdfs.HDFSDataStream
 
close() - Method in class org.apache.flume.sink.hdfs.HDFSSequenceFile
 
close() - Method in interface org.apache.flume.sink.hdfs.HDFSWriter
 
close() - Method in interface org.apache.flume.sink.kite.policy.FailurePolicy
Close this FailurePolicy and release any resources.
close() - Method in class org.apache.flume.sink.kite.policy.RetryPolicy
 
close() - Method in class org.apache.flume.sink.kite.policy.SavePolicy
 
close() - Method in class org.apache.flume.sink.solr.morphline.BlobDeserializer
 
close() - Method in class org.apache.flume.sink.solr.morphline.MorphlineInterceptor
 
close() - Method in class org.apache.flume.sink.solr.morphline.UUIDInterceptor
 
close() - Method in class org.apache.flume.source.taildir.ReliableTaildirEventReader
 
close() - Method in class org.apache.flume.source.taildir.TailFile
 
close() - Method in interface org.apache.flume.Transaction
Ends a transaction boundary for the current channel operation.
CLUSTER_NAME - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
Name of the ElasticSearch cluster to connect to
COL_NAME_CONFIG - Static variable in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
Comma separated list of column names to place matching groups in.
collectorRunnable - Variable in class org.apache.flume.instrumentation.GangliaServer
 
COLUMN_LOOKUP_QUERY - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler
 
COLUMN_NAME_DEFAULT - Static variable in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
 
com.cloudera.flume.handlers.thrift - package com.cloudera.flume.handlers.thrift
 
commit() - Method in class org.apache.flume.channel.BasicTransactionSemantics
 
commit() - Method in class org.apache.flume.channel.jdbc.impl.JdbcTransactionImpl
 
commit() - Method in class org.apache.flume.channel.PseudoTxnMemoryChannel.NoOpTransaction
 
commit() - Method in interface org.apache.flume.client.avro.ReliableEventReader
Indicate to the implementation that the previously-returned events have been successfully processed and committed.
commit() - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader
Commit the last lines which were read.
commit() - Method in class org.apache.flume.source.taildir.ReliableTaildirEventReader
Commit the last lines which were read.
commit() - Method in interface org.apache.flume.Transaction
Indicates that the transaction can be successfully committed.
commitTransaction() - Method in interface org.apache.flume.sink.solr.morphline.MorphlineHandler
Sends any outstanding documents to Solr and waits for a positive or negative ack (i.e.
commitTransaction() - Method in class org.apache.flume.sink.solr.morphline.MorphlineHandlerImpl
 
COMPACT_PROTOCOL - Static variable in class org.apache.flume.api.ThriftRpcClient
 
COMPACT_PROTOCOL - Static variable in class org.apache.flume.source.ThriftSource
 
compareTo(ThriftFlumeEvent) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
compareTo(ThriftFlumeEventServer.append_args) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args
 
compareTo(ThriftFlumeEventServer.close_args) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args
 
compareTo(ThriftFlumeEventServer.close_result) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result
 
compareTo(LogRecord) - Method in class org.apache.flume.channel.file.LogRecord
 
compareTo(LogEntry) - Method in class org.apache.flume.source.scribe.LogEntry
 
compareTo(Scribe.Log_args) - Method in class org.apache.flume.source.scribe.Scribe.Log_args
 
compareTo(Scribe.Log_result) - Method in class org.apache.flume.source.scribe.Scribe.Log_result
 
compareTo(ThriftFlumeEvent) - Method in class org.apache.flume.thrift.ThriftFlumeEvent
 
compareTo(ThriftSourceProtocol.append_args) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_args
 
compareTo(ThriftSourceProtocol.append_result) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_result
 
compareTo(ThriftSourceProtocol.appendBatch_args) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
 
compareTo(ThriftSourceProtocol.appendBatch_result) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result
 
completedSuffix(String) - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
 
ComponentConfiguration - Class in org.apache.flume.conf
Abstract implementation of the Component Configuration Manager.
ComponentConfiguration(String) - Constructor for class org.apache.flume.conf.ComponentConfiguration
 
ComponentConfiguration.ComponentType - Enum in org.apache.flume.conf
 
ComponentConfigurationFactory - Class in org.apache.flume.conf
 
ComponentConfigurationFactory() - Constructor for class org.apache.flume.conf.ComponentConfigurationFactory
 
componentName - Variable in class org.apache.flume.conf.ComponentConfiguration
 
COMPRESS_BACKUP_CHECKPOINT - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
compressFile(File, File) - Static method in class org.apache.flume.channel.file.Serialization
Compress file using Snappy
COMPRESSION_CODEC - Static variable in class org.apache.flume.serialization.AvroEventSerializerConfigurationConstants
Avro compression codec.
CONF_HOSTS - Variable in class org.apache.flume.instrumentation.GangliaServer
 
CONF_ISGANGLIA3 - Variable in class org.apache.flume.instrumentation.GangliaServer
 
CONF_MONITOR_CLASS - Static variable in class org.apache.flume.node.Application
 
CONF_MONITOR_PREFIX - Static variable in class org.apache.flume.node.Application
 
CONF_POLL_FREQUENCY - Variable in class org.apache.flume.instrumentation.GangliaServer
 
Config - Class in org.apache.flume.sink.hive
 
Config() - Constructor for class org.apache.flume.sink.hive.Config
 
CONFIG_ACKEVENT - Static variable in class org.apache.flume.source.NetcatSourceConfigurationConstants
Ack every event received with an "OK" back to the sender
CONFIG_BACKOFF - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
 
CONFIG_BACKOFF - Static variable in class org.apache.flume.sink.LoadBalancingSinkProcessor
 
CONFIG_BATCH_SIZE - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
Configuration key used to specify the batch size.
CONFIG_BATCH_SIZE - Static variable in class org.apache.flume.source.ExecSourceConfigurationConstants
Number of lines to read at a time
CONFIG_BATCH_TIME_OUT - Static variable in class org.apache.flume.source.ExecSourceConfigurationConstants
Amount of time to wait, if the buffer size was not reached, before to data is pushed downstream: : default 3000 ms
CONFIG_BATCHSIZE - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
Maximum number of events the sink should take from the channel per transaction, if available.
CONFIG_BATCHSIZE - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_BIND - Static variable in class org.apache.flume.source.http.HTTPSourceConfigurationConstants
 
CONFIG_BIND - Static variable in class org.apache.flume.source.ThriftSource
Config param for the hostname to listen on.
CONFIG_CHANNEL - Static variable in class org.apache.flume.conf.BasicConfigurationConstants
 
CONFIG_CHANNELS - Static variable in class org.apache.flume.conf.BasicConfigurationConstants
 
CONFIG_CHANNELS_PREFIX - Static variable in class org.apache.flume.conf.BasicConfigurationConstants
 
CONFIG_CHARSET - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_CLIENT_TYPE - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
Configuration key to specify the RpcClient type to be used.
CONFIG_COALESCE_INCREMENTS - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
 
CONFIG_COLUMN_FAMILY - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
The column family which the sink should use.
CONFIG_COMPRESSION_LEVEL - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
 
CONFIG_COMPRESSION_TYPE - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
The following are const for the NettyAvro Client.
CONFIG_CONFIG - Static variable in class org.apache.flume.conf.BasicConfigurationConstants
 
CONFIG_CONNECT_TIMEOUT - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
Configuration key to specify connection timeout in milliseconds.
CONFIG_CONNECTION_POOL_SIZE - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
Maximum number of connections each Thrift Rpc client can open to a given host.
CONFIG_CREATE_FK - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
 
CONFIG_CREATE_INDEX - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
 
CONFIG_CREATE_SCHEMA - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
 
CONFIG_DATABASE_TYPE - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
 
CONFIG_DATEFORMAT - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_DEFAULT_CHANNEL - Static variable in class org.apache.flume.channel.MultiplexingChannelSelector
 
CONFIG_ENABLE_WAL - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
 
CONFIG_ENTITY_PARSER - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
Parser used to parse Flume Events into Kite entities.
CONFIG_EVENTSIZE - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
Maximum allowable size of events.
CONFIG_EXCLUDE_PROTOCOLS - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
 
CONFIG_FAILURE_POLICY - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
Policy used to handle non-recoverable failures.
CONFIG_FLUSHABLE_COMMIT_ON_BATCH - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
Flag for committing the Flume transaction on each batch for Flushable datasets.
CONFIG_FORMAT_PREFIX - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_HANDLER - Static variable in class org.apache.flume.source.http.HTTPSourceConfigurationConstants
 
CONFIG_HANDLER_PREFIX - Static variable in class org.apache.flume.source.http.HTTPSourceConfigurationConstants
 
CONFIG_HOST - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_HOST_SELECTOR - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
The selector type used by the LoadBalancingRpcClient.
CONFIG_HOSTNAME - Static variable in class org.apache.flume.source.NetcatSourceConfigurationConstants
Hostname to bind to.
CONFIG_HOSTS - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
Hosts configuration key to specify a space delimited list of named hosts.
CONFIG_HOSTS_PREFIX - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
Hosts prefix to specify address of a particular named host.
CONFIG_JDBC_DRIVER_CLASS - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
 
CONFIG_JDBC_PROPS_FILE - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
 
CONFIG_JDBC_SYSPROP_PREFIX - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
 
CONFIG_KEEP_FIELDS - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_KEEP_FIELDS_HOSTNAME - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_KEEP_FIELDS_PRIORITY - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_KEEP_FIELDS_TIMESTAMP - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_KEEP_FIELDS_VERSION - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_KEYTAB - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
 
CONFIG_KITE_BATCH_SIZE - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
Number of records to process from the incoming channel per call to process.
CONFIG_KITE_DATASET_NAME - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
Name of the Kite Dataset to write into.
CONFIG_KITE_DATASET_NAMESPACE - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
Namespace of the Kite Dataset to write into.
CONFIG_KITE_DATASET_URI - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
URI of the Kite Dataset
CONFIG_KITE_ERROR_DATASET_URI - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
The URI to write non-recoverable Flume events to in the case of an error.
CONFIG_KITE_REPO_URI - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
URI of the Kite DatasetRepository.
CONFIG_KITE_ROLL_INTERVAL - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
Maximum time to wait before finishing files.
CONFIG_LOG_STDERR - Static variable in class org.apache.flume.source.ExecSourceConfigurationConstants
Should stderr from the command be logged: default false
CONFIG_MAX_ATTEMPTS - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
Maximum attempts to be made by the FailoverRpcClient in case of failures.
CONFIG_MAX_BACKOFF - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
 
CONFIG_MAX_CAPACITY - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
 
CONFIG_MAX_CONNECTIONS - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
 
CONFIG_MAX_CONSECUTIVE_FAILS - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
 
CONFIG_MAX_LINE_LENGTH - Static variable in class org.apache.flume.source.NetcatSourceConfigurationConstants
Maximum line length per event.
CONFIG_MULTIPLEX_HEADER_NAME - Static variable in class org.apache.flume.channel.MultiplexingChannelSelector
 
CONFIG_NUMPROCESSORS - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
Number of processors used to calculate number of threads to spawn.
CONFIG_OPTIONAL - Static variable in class org.apache.flume.channel.ReplicatingChannelSelector
Configuration to set a subset of the channels as optional.
CONFIG_PASSWORD - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
 
CONFIG_PORT - Static variable in class org.apache.flume.instrumentation.http.HTTPMetricsServer
 
CONFIG_PORT - Static variable in class org.apache.flume.source.http.HTTPSourceConfigurationConstants
 
CONFIG_PORT - Static variable in class org.apache.flume.source.NetcatSourceConfigurationConstants
Port to bind to.
CONFIG_PORT - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_PORT - Static variable in class org.apache.flume.source.ThriftSource
Config param for the port to listen on.
CONFIG_PORT_CHARSET_PREFIX - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_PORT_HEADER - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_PORTS - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
List of ports to listen to.
CONFIG_PREFIX_MAPPING - Static variable in class org.apache.flume.channel.MultiplexingChannelSelector
 
CONFIG_PREFIX_OPTIONAL - Static variable in class org.apache.flume.channel.MultiplexingChannelSelector
 
CONFIG_PRINCIPAL - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
 
CONFIG_PROTOCOL - Static variable in class org.apache.flume.api.ThriftRpcClient
Config param for the thrift protocol to use.
CONFIG_PROTOCOL - Static variable in class org.apache.flume.source.ThriftSource
Config param for the thrift protocol to use.
CONFIG_READBUF_SIZE - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_REGEX - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_REPLACE - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_REQUEST_TIMEOUT - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
Configuration key to specify request timeout in milliseconds.
CONFIG_RESTART - Static variable in class org.apache.flume.source.ExecSourceConfigurationConstants
Should the exec'ed command restarted if it dies: : default false
CONFIG_RESTART_THROTTLE - Static variable in class org.apache.flume.source.ExecSourceConfigurationConstants
Amount of time to wait before attempting a restart: : default 10000 ms
CONFIG_SCHEMA_TYPE_KEY - Static variable in class org.apache.flume.serialization.AvroEventDeserializer
 
CONFIG_SEARCH - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
CONFIG_SELECTOR - Static variable in class org.apache.flume.sink.LoadBalancingSinkProcessor
 
CONFIG_SELECTOR_PREFIX - Static variable in class org.apache.flume.sink.LoadBalancingSinkProcessor
 
CONFIG_SERIALIZER - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
The fully qualified class name of the serializer the sink should use.
CONFIG_SERIALIZER_PREFIX - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
Configuration to pass to the serializer.
CONFIG_SHELL - Static variable in class org.apache.flume.source.ExecSourceConfigurationConstants
Optional shell/command processor used to run command
CONFIG_SINK_PROCESSOR_PREFIX - Static variable in class org.apache.flume.conf.BasicConfigurationConstants
 
CONFIG_SINKGROUPS - Static variable in class org.apache.flume.conf.BasicConfigurationConstants
 
CONFIG_SINKGROUPS_PREFIX - Static variable in class org.apache.flume.conf.BasicConfigurationConstants
 
CONFIG_SINKS - Static variable in class org.apache.flume.conf.BasicConfigurationConstants
 
CONFIG_SINKS_PREFIX - Static variable in class org.apache.flume.conf.BasicConfigurationConstants
 
CONFIG_SOURCE_CHANNELSELECTOR_PREFIX - Static variable in class org.apache.flume.conf.BasicConfigurationConstants
 
CONFIG_SOURCE_ENCODING - Static variable in class org.apache.flume.source.NetcatSourceConfigurationConstants
Encoding for the netcat source
CONFIG_SOURCES - Static variable in class org.apache.flume.conf.BasicConfigurationConstants
 
CONFIG_SOURCES_PREFIX - Static variable in class org.apache.flume.conf.BasicConfigurationConstants
 
CONFIG_SSL - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
Configuration constants for SSL support
CONFIG_SYNCABLE_SYNC_ON_BATCH - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
Flag for syncing the DatasetWriter on each batch for Syncable datasets.
CONFIG_TABLE - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
The Hbase table which the sink should write to.
CONFIG_THREADS - Static variable in class org.apache.flume.source.ThriftSource
Config param for the maximum number of threads this source should use to handle incoming data.
CONFIG_TIMEOUT - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
 
CONFIG_TRUST_ALL_CERTS - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
 
CONFIG_TRUSTSTORE - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
 
CONFIG_TRUSTSTORE_PASSWORD - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
 
CONFIG_TRUSTSTORE_TYPE - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
 
CONFIG_TX_ISOLATION_LEVEL - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
 
CONFIG_TYPE - Static variable in class org.apache.flume.conf.BasicConfigurationConstants
 
CONFIG_URL - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
 
CONFIG_USERNAME - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
 
configFromBytes(byte[]) - Method in class org.apache.flume.node.AbstractZooKeeperConfigurationProvider
 
Configurable - Interface in org.apache.flume.conf
Any class marked as Configurable may have a context including its sub-configuration passed to it, requesting it configure itself.
ConfigurableComponent - Interface in org.apache.flume.conf
 
Configurables - Class in org.apache.flume.conf
Methods for working with Configurables.
Configurables() - Constructor for class org.apache.flume.conf.Configurables
 
ConfigurationConstants - Class in org.apache.flume.channel.jdbc
Contains configuration keys used by the JDBC channel implementation.
ConfigurationException - Exception in org.apache.flume.conf
 
ConfigurationException(String) - Constructor for exception org.apache.flume.conf.ConfigurationException
 
ConfigurationException(Throwable) - Constructor for exception org.apache.flume.conf.ConfigurationException
 
ConfigurationException(String, Throwable) - Constructor for exception org.apache.flume.conf.ConfigurationException
 
ConfigurationProvider - Interface in org.apache.flume.node
 
configure(Map<String, String>) - Method in class org.apache.flume.agent.embedded.EmbeddedAgent
Configures the embedded agent.
configure(Context) - Method in class org.apache.flume.agent.embedded.EmbeddedSource
 
configure(Properties) - Method in class org.apache.flume.api.AbstractRpcClient
Configure the client using the given properties object.
configure(Properties) - Method in class org.apache.flume.api.FailoverRpcClient
 
configure(Properties) - Method in class org.apache.flume.api.LoadBalancingRpcClient
 
configure(Properties) - Method in class org.apache.flume.api.NettyAvroRpcClient
Configure the actual client using the properties.
configure(Properties) - Method in class org.apache.flume.api.SecureThriftRpcClient
 
configure(Properties) - Method in class org.apache.flume.api.ThriftRpcClient
 
configure(Context) - Method in class org.apache.flume.channel.AbstractChannel
 
configure(Context) - Method in class org.apache.flume.channel.ChannelProcessor
The Context of the associated Source is passed.
configure(Context) - Method in class org.apache.flume.channel.file.FileChannel
 
configure(Context) - Method in class org.apache.flume.channel.jdbc.JdbcChannel
 
configure(Context) - Method in class org.apache.flume.channel.kafka.KafkaChannel
 
configure(Context) - Method in class org.apache.flume.channel.MemoryChannel
Read parameters from context capacity = type long that defines the total number of events allowed at one time in the queue.
configure(Context) - Method in class org.apache.flume.channel.MultiplexingChannelSelector
 
configure(Context) - Method in class org.apache.flume.channel.PseudoTxnMemoryChannel
 
configure(Context) - Method in class org.apache.flume.channel.ReplicatingChannelSelector
 
configure(Context) - Method in class org.apache.flume.channel.SpillableMemoryChannel
Read parameters from context memoryCapacity = total number of events allowed at one time in the memory queue.
configure(Context) - Method in class org.apache.flume.conf.channel.ChannelConfiguration
 
configure(Context) - Method in class org.apache.flume.conf.channel.ChannelSelectorConfiguration
 
configure(Context) - Method in class org.apache.flume.conf.ComponentConfiguration
 
configure(Context) - Method in interface org.apache.flume.conf.Configurable
Request the implementing class to (re)configure itself.
configure(ComponentConfiguration) - Method in interface org.apache.flume.conf.ConfigurableComponent
 
configure(Object, Context) - Static method in class org.apache.flume.conf.Configurables
Check that target implements Configurable and, if so, ask it to configure itself using the supplied context.
configure(Object, ComponentConfiguration) - Static method in class org.apache.flume.conf.Configurables
 
configure(Context) - Method in class org.apache.flume.conf.sink.SinkConfiguration
 
configure(Context) - Method in class org.apache.flume.conf.sink.SinkGroupConfiguration
 
configure(Context) - Method in class org.apache.flume.conf.sink.SinkProcessorConfiguration
 
configure(Context) - Method in class org.apache.flume.conf.source.SourceConfiguration
 
configure(Context) - Method in class org.apache.flume.instrumentation.GangliaServer
 
configure(Context) - Method in class org.apache.flume.instrumentation.http.HTTPMetricsServer
 
configure(Context) - Method in class org.apache.flume.interceptor.HostInterceptor.Builder
 
configure(Context) - Method in class org.apache.flume.interceptor.RegexExtractorInterceptor.Builder
 
configure(Context) - Method in class org.apache.flume.interceptor.RegexExtractorInterceptorMillisSerializer
 
configure(ComponentConfiguration) - Method in class org.apache.flume.interceptor.RegexExtractorInterceptorMillisSerializer
 
configure(Context) - Method in class org.apache.flume.interceptor.RegexExtractorInterceptorPassThroughSerializer
 
configure(ComponentConfiguration) - Method in class org.apache.flume.interceptor.RegexExtractorInterceptorPassThroughSerializer
 
configure(Context) - Method in class org.apache.flume.interceptor.RegexFilteringInterceptor.Builder
 
configure(Context) - Method in class org.apache.flume.interceptor.SearchAndReplaceInterceptor.Builder
 
configure(Context) - Method in class org.apache.flume.interceptor.StaticInterceptor.Builder
 
configure(Context) - Method in class org.apache.flume.interceptor.TimestampInterceptor.Builder
 
configure(Context) - Method in class org.apache.flume.serialization.AbstractAvroEventSerializer
 
configure(Context) - Method in class org.apache.flume.sink.AbstractRpcSink
 
configure(Context) - Method in class org.apache.flume.sink.AbstractSinkSelector
 
configure(Context) - Method in class org.apache.flume.sink.DefaultSinkProcessor
 
configure(ComponentConfiguration) - Method in class org.apache.flume.sink.DefaultSinkProcessor
 
configure(Context) - Method in class org.apache.flume.sink.elasticsearch.AbstractElasticSearchIndexRequestBuilderFactory
 
configure(ComponentConfiguration) - Method in class org.apache.flume.sink.elasticsearch.AbstractElasticSearchIndexRequestBuilderFactory
 
configure(Context) - Method in class org.apache.flume.sink.elasticsearch.client.ElasticSearchRestClient
 
configure(Context) - Method in class org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient
 
configure(Context) - Method in class org.apache.flume.sink.elasticsearch.ElasticSearchDynamicSerializer
 
configure(ComponentConfiguration) - Method in class org.apache.flume.sink.elasticsearch.ElasticSearchDynamicSerializer
 
configure(Context) - Method in class org.apache.flume.sink.elasticsearch.ElasticSearchLogStashEventSerializer
 
configure(ComponentConfiguration) - Method in class org.apache.flume.sink.elasticsearch.ElasticSearchLogStashEventSerializer
 
configure(Context) - Method in class org.apache.flume.sink.elasticsearch.ElasticSearchSink
 
configure(Context) - Method in class org.apache.flume.sink.elasticsearch.EventSerializerIndexRequestBuilderFactory
 
configure(ComponentConfiguration) - Method in class org.apache.flume.sink.elasticsearch.EventSerializerIndexRequestBuilderFactory
 
configure(Context) - Method in class org.apache.flume.sink.elasticsearch.SimpleIndexNameBuilder
 
configure(ComponentConfiguration) - Method in class org.apache.flume.sink.elasticsearch.SimpleIndexNameBuilder
 
configure(Context) - Method in class org.apache.flume.sink.elasticsearch.TimeBasedIndexNameBuilder
 
configure(ComponentConfiguration) - Method in class org.apache.flume.sink.elasticsearch.TimeBasedIndexNameBuilder
 
configure(Context) - Method in class org.apache.flume.sink.FailoverSinkProcessor
 
configure(Context) - Method in class org.apache.flume.sink.hbase.AsyncHBaseSink
 
configure(Context) - Method in class org.apache.flume.sink.hbase.HBaseSink
 
configure(Context) - Method in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
 
configure(ComponentConfiguration) - Method in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
 
configure(Context) - Method in class org.apache.flume.sink.hbase.SimpleAsyncHbaseEventSerializer
 
configure(ComponentConfiguration) - Method in class org.apache.flume.sink.hbase.SimpleAsyncHbaseEventSerializer
 
configure(Context) - Method in class org.apache.flume.sink.hbase.SimpleHbaseEventSerializer
 
configure(ComponentConfiguration) - Method in class org.apache.flume.sink.hbase.SimpleHbaseEventSerializer
 
configure(Context) - Method in class org.apache.flume.sink.hdfs.AbstractHDFSWriter
 
configure(Context) - Method in class org.apache.flume.sink.hdfs.AvroEventSerializer
 
configure(Context) - Method in class org.apache.flume.sink.hdfs.HDFSCompressedDataStream
 
configure(Context) - Method in class org.apache.flume.sink.hdfs.HDFSDataStream
 
configure(Context) - Method in class org.apache.flume.sink.hdfs.HDFSEventSink
 
configure(Context) - Method in class org.apache.flume.sink.hdfs.HDFSSequenceFile
 
configure(Context) - Method in class org.apache.flume.sink.hive.HiveDelimitedTextSerializer
 
configure(Context) - Method in class org.apache.flume.sink.hive.HiveJsonSerializer
 
configure(Context) - Method in class org.apache.flume.sink.hive.HiveSink
 
configure(Context) - Method in class org.apache.flume.sink.irc.IRCSink
 
configure(Context) - Method in class org.apache.flume.sink.kafka.KafkaSink
We configure the sink and generate properties for the Kafka Producer Kafka producer properties is generated as follows: 1.
configure(Context) - Method in class org.apache.flume.sink.kite.DatasetSink
 
configure(Context) - Method in class org.apache.flume.sink.LoadBalancingSinkProcessor
 
configure(Context) - Method in class org.apache.flume.sink.LoggerSink
 
configure(Context) - Method in class org.apache.flume.sink.NullSink
 
configure(Context) - Method in class org.apache.flume.sink.RollingFileSink
 
configure(Context) - Method in class org.apache.flume.sink.SinkGroup
 
configure(ComponentConfiguration) - Method in class org.apache.flume.sink.SinkGroup
 
configure(Context) - Method in class org.apache.flume.sink.solr.morphline.BlobHandler
 
configure(Context) - Method in class org.apache.flume.sink.solr.morphline.MorphlineHandlerImpl
 
configure(Context) - Method in class org.apache.flume.sink.solr.morphline.MorphlineInterceptor.Builder
 
configure(Context) - Method in class org.apache.flume.sink.solr.morphline.MorphlineSink
 
configure(Context) - Method in class org.apache.flume.sink.solr.morphline.MorphlineSolrSink
 
configure(Context) - Method in class org.apache.flume.sink.solr.morphline.UUIDInterceptor.Builder
 
configure(Context) - Method in class org.apache.flume.source.AbstractPollableSource
 
configure(Context) - Method in class org.apache.flume.source.avroLegacy.AvroLegacySource
 
configure(Context) - Method in class org.apache.flume.source.AvroSource
 
configure(Context) - Method in class org.apache.flume.source.BasicSourceSemantics
 
configure(Context) - Method in class org.apache.flume.source.ExecSource
 
configure(Context) - Method in class org.apache.flume.source.http.BLOBHandler
 
configure(Context) - Method in class org.apache.flume.source.http.HTTPSource
 
configure(Context) - Method in class org.apache.flume.source.http.JSONHandler
 
configure(Context) - Method in class org.apache.flume.source.MultiportSyslogTCPSource
 
configure(Context) - Method in class org.apache.flume.source.NetcatSource
 
configure(Context) - Method in class org.apache.flume.source.scribe.ScribeSource
 
configure(Context) - Method in class org.apache.flume.source.SpoolDirectorySource
 
configure(Context) - Method in class org.apache.flume.source.SyslogTcpSource
Deprecated.
 
configure(Context) - Method in class org.apache.flume.source.SyslogUDPSource
 
configure(Context) - Method in class org.apache.flume.source.taildir.TaildirSource
 
configure(Context) - Method in class org.apache.flume.source.thriftLegacy.ThriftLegacySource
 
configure(Context) - Method in class org.apache.flume.source.ThriftSource
 
configure(Context) - Method in class org.apache.flume.source.twitter.TwitterSource
 
configured - Variable in class org.apache.flume.conf.ComponentConfiguration
 
CONNECTION_FACTORY - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
CONNECTION_FACTORY_DEFAULT - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
connectTimeout - Variable in class org.apache.flume.api.AbstractRpcClient
 
Constants - Class in org.apache.flume
 
CONSUME_ORDER - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
consumeOrder(SpoolDirectorySourceConfigurationConstants.ConsumeOrder) - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
 
CONSUMER_TIMEOUT - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
containsKey(String) - Method in class org.apache.flume.Context
Returns true if this Context contains a mapping for key.
containsTag(String) - Static method in class org.apache.flume.formatter.output.BucketPath
Deprecated.
ContentBuilderUtil - Class in org.apache.flume.sink.elasticsearch
Utility methods for using ElasticSearch XContentBuilder
Context - Class in org.apache.flume
The context is a key-value store used to pass configuration information throughout the system.
Context() - Constructor for class org.apache.flume.Context
 
Context(Map<String, String>) - Constructor for class org.apache.flume.Context
 
convert(Event) - Method in class org.apache.flume.serialization.AbstractAvroEventSerializer
Simple conversion routine used to convert an Event to a type of your choosing.
convert(Event) - Method in class org.apache.flume.serialization.FlumeEventAvroEventSerializer
A no-op for this simple, special-case implementation
convert(Message) - Method in class org.apache.flume.source.jms.DefaultJMSMessageConverter
 
convert(Message) - Method in interface org.apache.flume.source.jms.JMSMessageConverter
 
CONVERTER - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
CONVERTER_CHARSET - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
CONVERTER_CHARSET_DEFAULT - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
CONVERTER_TYPE - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
CONVERTER_TYPE_DEFAULT - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
copyFile(File, File) - Static method in class org.apache.flume.channel.file.Serialization
Copy a file using a 64K size buffer.
CorruptEventException - Exception in org.apache.flume.channel.file
 
CorruptEventException() - Constructor for exception org.apache.flume.channel.file.CorruptEventException
 
CorruptEventException(String) - Constructor for exception org.apache.flume.channel.file.CorruptEventException
 
CorruptEventException(String, Throwable) - Constructor for exception org.apache.flume.channel.file.CorruptEventException
 
COUNT_FIELD_NUMBER - Static variable in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog
 
CounterGroup - Class in org.apache.flume
Used for counting events, collecting metrics, etc.
CounterGroup() - Constructor for class org.apache.flume.CounterGroup
 
create(List<Channel>, Map<String, String>) - Static method in class org.apache.flume.channel.ChannelSelectorFactory
 
create(List<Channel>, ChannelSelectorConfiguration) - Static method in class org.apache.flume.channel.ChannelSelectorFactory
 
create(String, String) - Method in class org.apache.flume.channel.DefaultChannelFactory
 
create(String, String) - Method in interface org.apache.flume.ChannelFactory
 
create(String, String, ComponentConfiguration.ComponentType) - Static method in class org.apache.flume.conf.ComponentConfigurationFactory
 
create(String, String) - Method in class org.apache.flume.sink.DefaultSinkFactory
 
create(String, String) - Method in interface org.apache.flume.SinkFactory
 
create(String, String) - Method in class org.apache.flume.source.DefaultSourceFactory
 
create(Properties) - Method in class org.apache.flume.source.jms.InitialContextFactory
 
create(String, String) - Method in interface org.apache.flume.SourceFactory
 
createClient() - Method in class org.apache.flume.node.AbstractZooKeeperConfigurationProvider
 
createGangliaMessage(String, String) - Method in class org.apache.flume.instrumentation.GangliaServer
 
createGangliaMessage31(String, String) - Method in class org.apache.flume.instrumentation.GangliaServer
 
createHostIterator() - Method in interface org.apache.flume.api.LoadBalancingRpcClient.HostSelector
 
createIndexRequest(Client, String, String, Event) - Method in class org.apache.flume.sink.elasticsearch.AbstractElasticSearchIndexRequestBuilderFactory
Creates and prepares an IndexRequestBuilder from the supplied Client via delegation to the subclass-hook template methods AbstractElasticSearchIndexRequestBuilderFactory.getIndexName(String, long) and AbstractElasticSearchIndexRequestBuilderFactory.prepareIndexRequest(IndexRequestBuilder, String, String, Event)
createIndexRequest(Client, String, String, Event) - Method in interface org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory
 
createIterator() - Method in class org.apache.flume.util.OrderSelector
 
createIterator() - Method in class org.apache.flume.util.RandomOrderSelector
 
createIterator() - Method in class org.apache.flume.util.RoundRobinOrderSelector
 
createRecordWriter(HiveEndPoint) - Method in class org.apache.flume.sink.hive.HiveDelimitedTextSerializer
 
createRecordWriter(HiveEndPoint) - Method in interface org.apache.flume.sink.hive.HiveEventSerializer
 
createRecordWriter(HiveEndPoint) - Method in class org.apache.flume.sink.hive.HiveJsonSerializer
 
createSchemaObjects(boolean, boolean) - Method in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler
 
createSchemaObjects(boolean, boolean) - Method in class org.apache.flume.channel.jdbc.impl.MySQLSchemaHandler
 
createSchemaObjects(boolean, boolean) - Method in interface org.apache.flume.channel.jdbc.impl.SchemaHandler
Creates the schema.
createSinkIterator() - Method in interface org.apache.flume.sink.LoadBalancingSinkProcessor.SinkSelector
 
createTransaction() - Method in class org.apache.flume.channel.BasicChannelSemantics
Called to create new Transaction objects, which must extend BasicTransactionSemantics.
createTransaction() - Method in class org.apache.flume.channel.file.FileChannel
 
createTransaction() - Method in class org.apache.flume.channel.kafka.KafkaChannel
 
createTransaction() - Method in class org.apache.flume.channel.MemoryChannel
 
createTransaction() - Method in class org.apache.flume.channel.SpillableMemoryChannel
 
CTX_PREFIX - Static variable in interface org.apache.flume.formatter.output.PathManager
Context prefix
CTX_PREFIX - Static variable in interface org.apache.flume.serialization.EventSerializer
Context prefix
currentFile - Variable in class org.apache.flume.formatter.output.DefaultPathManager
 
currentTimeMillis() - Method in interface org.apache.flume.Clock
 
currentTimeMillis() - Method in class org.apache.flume.SystemClock
 

D

DATA_DIRS - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
Directories data files will be written in.
DatabaseType - Enum in org.apache.flume.channel.jdbc
 
DatasetSink - Class in org.apache.flume.sink.kite
Sink that writes events to a Kite Dataset.
DatasetSink() - Constructor for class org.apache.flume.sink.kite.DatasetSink
 
DatasetSinkConstants - Class in org.apache.flume.sink.kite
 
DatasetSinkConstants() - Constructor for class org.apache.flume.sink.kite.DatasetSinkConstants
 
DATE_FORMAT - Static variable in class org.apache.flume.sink.elasticsearch.TimeBasedIndexNameBuilder
 
DECODE_ERROR_POLICY - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
What to do when there is a character set decoding error.
decodeErrorPolicy(DecodeErrorPolicy) - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
 
DecodeErrorPolicy - Enum in org.apache.flume.serialization
 
decompressFile(File, File) - Static method in class org.apache.flume.channel.file.Serialization
Decompress file using Snappy
decrypt(byte[]) - Method in class org.apache.flume.channel.file.encryption.CipherProvider.Decryptor
 
DecryptionFailureException - Exception in org.apache.flume.channel.file.encryption
Exception that is thrown when the channel is unable to decrypt an even read from the channel.
DecryptionFailureException(String) - Constructor for exception org.apache.flume.channel.file.encryption.DecryptionFailureException
 
DecryptionFailureException(String, Throwable) - Constructor for exception org.apache.flume.channel.file.encryption.DecryptionFailureException
 
deepCopy() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
deepCopy() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args
 
deepCopy() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args
 
deepCopy() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result
 
deepCopy() - Method in class org.apache.flume.source.scribe.LogEntry
 
deepCopy() - Method in class org.apache.flume.source.scribe.Scribe.Log_args
 
deepCopy() - Method in class org.apache.flume.source.scribe.Scribe.Log_result
 
deepCopy() - Method in class org.apache.flume.thrift.ThriftFlumeEvent
 
deepCopy() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_args
 
deepCopy() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_result
 
deepCopy() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
 
deepCopy() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result
 
DEFAULT_ACKS - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
DEFAULT_ACKS - Static variable in class org.apache.flume.sink.kafka.KafkaSinkConstants
 
DEFAULT_AUTO_COMMIT - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants
 
DEFAULT_AUTO_OFFSET_RESET - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
DEFAULT_AVRO_EVENT - Static variable in class org.apache.flume.sink.kafka.KafkaSinkConstants
 
DEFAULT_AVRO_EVENT - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants
 
DEFAULT_BACKOFF - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
 
DEFAULT_BACKOFF_SLEEP_INCREMENT - Static variable in class org.apache.flume.source.PollableSourceConstants
 
DEFAULT_BASENAME_HEADER - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_BASENAME_HEADER_KEY - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_BATCH_DURATION - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants
 
DEFAULT_BATCH_SIZE - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
Default batch size.
DEFAULT_BATCH_SIZE - Static variable in class org.apache.flume.sink.kafka.KafkaSinkConstants
 
DEFAULT_BATCH_SIZE - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
 
DEFAULT_BATCH_SIZE - Static variable in class org.apache.flume.source.ExecSourceConfigurationConstants
 
DEFAULT_BATCH_SIZE - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants
 
DEFAULT_BATCH_SIZE - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_BATCH_SIZE - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
 
DEFAULT_BATCH_TIME_OUT - Static variable in class org.apache.flume.source.ExecSourceConfigurationConstants
 
DEFAULT_BATCHSIZE - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
DEFAULT_BIND - Static variable in class org.apache.flume.source.http.HTTPSourceConfigurationConstants
 
DEFAULT_BUF_SIZE - Static variable in class org.apache.flume.serialization.ResettableFileInputStream
 
DEFAULT_BUFFER_MAX_LINE_LENGTH - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
Deprecated.
DEFAULT_BUFFER_MAX_LINES - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
Deprecated.
DEFAULT_BYTE_OFFSET_HEADER - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
 
DEFAULT_CACHE_PATTERN_MATCHING - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
 
DEFAULT_CAPACITY - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
DEFAULT_CHARSET - Static variable in class org.apache.flume.source.ExecSourceConfigurationConstants
 
DEFAULT_CHARSET - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
DEFAULT_CHECKPOINT_INTERVAL - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
DEFAULT_CHKPT_ONCLOSE - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
DEFAULT_CLIENT_TYPE - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
The default client type to be created if no explicit type is specified.
DEFAULT_CLIENT_TYPE - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
 
DEFAULT_CLUSTER_NAME - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
 
DEFAULT_COALESCE_INCREMENTS - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
 
DEFAULT_COMPRESS_BACKUP_CHECKPOINT - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
DEFAULT_COMPRESSION_CODEC - Static variable in class org.apache.flume.serialization.AvroEventSerializerConfigurationConstants
 
DEFAULT_COMPRESSION_LEVEL - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
 
DEFAULT_CONNECT_TIMEOUT_MILLIS - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
Default connection, handshake, and initial request timeout in milliseconds.
DEFAULT_CONNECTION_POOL_SIZE - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
 
DEFAULT_CONSUME_ORDER - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_DATE_FORMAT - Static variable in class org.apache.flume.sink.elasticsearch.TimeBasedIndexNameBuilder
 
DEFAULT_DECODE_ERROR_POLICY - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_DELETE_POLICY - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_DESERIALIZER - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_DMAX - Static variable in class org.apache.flume.instrumentation.GangliaServer
 
DEFAULT_ENABLE_WAL - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
 
DEFAULT_ENCODING - Static variable in class org.apache.flume.source.NetcatSourceConfigurationConstants
 
DEFAULT_ENTITY_PARSER - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
 
DEFAULT_EXCLUDE_EVENTS - Static variable in class org.apache.flume.interceptor.RegexFilteringInterceptor.Constants
 
DEFAULT_FAILURE_POLICY - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
 
DEFAULT_FILE_HEADER - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_FILE_HEADER - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
 
DEFAULT_FILENAME_HEADER_KEY - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_FILENAME_HEADER_KEY - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
 
DEFAULT_FLUSHABLE_COMMIT_ON_BATCH - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
 
DEFAULT_FSYNC_INTERVAL - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
DEFAULT_FSYNC_PRE_TXN - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
DEFAULT_GROUP_ID - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
DEFAULT_GROUP_ID - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants
 
DEFAULT_HANDLER - Static variable in class org.apache.flume.source.http.HTTPSourceConfigurationConstants
 
DEFAULT_IDLE_TIMEOUT - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
 
DEFAULT_IGNORE_PAT - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_INCLUDE_PAT - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_INDEX_NAME - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
 
DEFAULT_INDEX_NAME_BUILDER_CLASS - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
 
DEFAULT_INDEX_TYPE - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
 
DEFAULT_INITIAL_SIZE - Static variable in class org.apache.flume.source.SyslogUDPSource
 
DEFAULT_INPUT_CHARSET - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_KEEP_ALIVE - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
DEFAULT_KEEP_FIELDS - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
DEFAULT_KEY_DESERIALIZER - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
DEFAULT_KEY_DESERIALIZER - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants
 
DEFAULT_KEY_SERIALIZER - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
DEFAULT_KEY_SERIALIZER - Static variable in class org.apache.flume.sink.kafka.KafkaSinkConstants
 
DEFAULT_LOG_STDERR - Static variable in class org.apache.flume.source.ExecSourceConfigurationConstants
 
DEFAULT_MANDATORY_PARAMETERS - Static variable in class org.apache.flume.source.http.BLOBHandler
 
DEFAULT_MAX_BACKOFF - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_MAX_BACKOFF_SLEEP - Static variable in class org.apache.flume.source.PollableSourceConstants
 
DEFAULT_MAX_BYTE_DUMP - Static variable in class org.apache.flume.sink.LoggerSink
 
DEFAULT_MAX_CONSECUTIVE_FAILS - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
 
DEFAULT_MAX_FILE_SIZE - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
DEFAULT_MAX_LINE_LENGTH - Static variable in class org.apache.flume.source.NetcatSourceConfigurationConstants
 
DEFAULT_MIGRATE_ZOOKEEPER_OFFSETS - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
DEFAULT_MIGRATE_ZOOKEEPER_OFFSETS - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants
 
DEFAULT_MIN_SIZE - Static variable in class org.apache.flume.source.SyslogUDPSource
 
DEFAULT_MINIMUM_REQUIRED_SPACE - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
Minimum space required defaults to 500MB
DEFAULT_MULTIPLEX_HEADER - Static variable in class org.apache.flume.channel.MultiplexingChannelSelector
 
DEFAULT_NAMESPACE - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
 
DEFAULT_PARSE_AS_FLUME_EVENT - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
DEFAULT_POLL_DELAY - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_POLL_FREQUENCY - Variable in class org.apache.flume.instrumentation.GangliaServer
 
DEFAULT_POLL_TIMEOUT - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
DEFAULT_PORT - Static variable in class org.apache.flume.instrumentation.http.HTTPMetricsServer
 
DEFAULT_PORT - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
DEFAULTS USED BY THE SINK
DEFAULT_PORT_HEADER - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
DEFAULT_POSITION_FILE - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
 
DEFAULT_READ_SMALLEST_OFFSET - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
DEFAULT_READBUF_SIZE - Static variable in class org.apache.flume.source.SyslogSourceConfigurationConstants
 
DEFAULT_RECURSIVE_DIRECTORY_SEARCH - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_REGEX - Static variable in class org.apache.flume.interceptor.RegexFilteringInterceptor.Constants
 
DEFAULT_REQUEST_TIMEOUT_MILLIS - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
Default request timeout in milliseconds.
DEFAULT_RESTART - Static variable in class org.apache.flume.source.ExecSourceConfigurationConstants
 
DEFAULT_RESTART_THROTTLE - Static variable in class org.apache.flume.source.ExecSourceConfigurationConstants
 
DEFAULT_ROLL_INTERVAL - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
 
DEFAULT_SERIALIZER_CLASS - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
 
DEFAULT_SIZE - Static variable in class org.apache.flume.source.SyslogUtils
 
DEFAULT_SKIP_TO_END - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
 
DEFAULT_SLOPE - Static variable in class org.apache.flume.instrumentation.GangliaServer
 
DEFAULT_SPOOLED_FILE_SUFFIX - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_STATIC_SCHEMA_URL - Static variable in class org.apache.flume.serialization.AvroEventSerializerConfigurationConstants
 
DEFAULT_SYNC_INTERVAL_BYTES - Static variable in class org.apache.flume.serialization.AvroEventSerializerConfigurationConstants
 
DEFAULT_SYNCABLE_SYNC_ON_BATCH - Static variable in class org.apache.flume.sink.kite.DatasetSinkConstants
 
DEFAULT_TIME_ZONE - Static variable in class org.apache.flume.sink.elasticsearch.TimeBasedIndexNameBuilder
 
DEFAULT_TIMEOUT - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
DEFAULT_TIMEOUT - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
 
DEFAULT_TMAX - Static variable in class org.apache.flume.instrumentation.GangliaServer
 
DEFAULT_TOPIC - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
DEFAULT_TOPIC - Static variable in class org.apache.flume.sink.kafka.KafkaSinkConstants
 
DEFAULT_TRACKER_DIR - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
DEFAULT_TRANSACTION_CAPACITY - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
DEFAULT_TTL - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
 
DEFAULT_UNITS - Static variable in class org.apache.flume.instrumentation.GangliaServer
 
DEFAULT_USE_DUAL_CHECKPOINTS - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
DEFAULT_USE_FAST_REPLAY - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
DEFAULT_USE_LOG_REPLAY_V1 - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
DEFAULT_VALUE_DESERIAIZER - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
DEFAULT_VALUE_DESERIALIZER - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants
 
DEFAULT_VALUE_SERIAIZER - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
DEFAULT_VALUE_SERIAIZER - Static variable in class org.apache.flume.sink.kafka.KafkaSinkConstants
 
DEFAULT_WRITE_POS_INTERVAL - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
 
DEFAULT_ZK_ZNODE_PARENT - Static variable in class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
 
DefaultChannelFactory - Class in org.apache.flume.channel
 
DefaultChannelFactory() - Constructor for class org.apache.flume.channel.DefaultChannelFactory
 
defaultDelimiter - Static variable in class org.apache.flume.sink.hive.HiveDelimitedTextSerializer
 
DefaultJMSMessageConverter - Class in org.apache.flume.source.jms
Converts BytesMessage, TextMessage, and ObjectMessage to a Flume Event.
DefaultJMSMessageConverter.Builder - Class in org.apache.flume.source.jms
 
DefaultJMSMessageConverter.Builder() - Constructor for class org.apache.flume.source.jms.DefaultJMSMessageConverter.Builder
 
defaultMemoryCapacity - Static variable in class org.apache.flume.channel.SpillableMemoryChannel
 
defaultOverflowCapacity - Static variable in class org.apache.flume.channel.SpillableMemoryChannel
 
defaultOverflowDeactivationThreshold - Static variable in class org.apache.flume.channel.SpillableMemoryChannel
 
defaultOverflowTimeout - Static variable in class org.apache.flume.channel.SpillableMemoryChannel
 
DefaultPathManager - Class in org.apache.flume.formatter.output
 
DefaultPathManager(Context) - Constructor for class org.apache.flume.formatter.output.DefaultPathManager
 
DefaultPathManager.Builder - Class in org.apache.flume.formatter.output
 
DefaultPathManager.Builder() - Constructor for class org.apache.flume.formatter.output.DefaultPathManager.Builder
 
DefaultSinkFactory - Class in org.apache.flume.sink
 
DefaultSinkFactory() - Constructor for class org.apache.flume.sink.DefaultSinkFactory
 
DefaultSinkProcessor - Class in org.apache.flume.sink
Default sink processor that only accepts a single sink, passing on process results without any additional handling.
DefaultSinkProcessor() - Constructor for class org.apache.flume.sink.DefaultSinkProcessor
 
DefaultSourceFactory - Class in org.apache.flume.source
 
DefaultSourceFactory() - Constructor for class org.apache.flume.source.DefaultSourceFactory
 
DELETE_POLICY - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
 
deletePolicy(String) - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
 
DEPOSIT_HEADERS_CONFIG - Static variable in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
Whether to deposit event headers into corresponding column qualifiers
DEPOSIT_HEADERS_DEFAULT - Static variable in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
 
DerbySchemaHandler - Class in org.apache.flume.channel.jdbc.impl
Schema handler for Derby Database.
DerbySchemaHandler(DataSource) - Constructor for class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler
 
DESERIALIZER - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
Deserializer to use to parse the file data into Flume Events
deserializerContext(Context) - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
 
deserializerType(String) - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
 
desiredState - Variable in class org.apache.flume.lifecycle.LifecycleSupervisor.Status
 
DESTINATION_LOCATOR - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
DESTINATION_LOCATOR_DEFAULT - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
DESTINATION_NAME - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
DESTINATION_TYPE - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
DESTINATION_TYPE_QUEUE - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
DESTINATION_TYPE_TOPIC - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
df - Static variable in interface org.apache.flume.sink.elasticsearch.ElasticSearchIndexRequestBuilderFactory
 
didHitChannelException() - Method in class org.apache.flume.source.SpoolDirectorySource
 
didHitChannelFullException() - Method in class org.apache.flume.source.SpoolDirectorySource
 
DirectMemoryUtils - Class in org.apache.flume.tools
 
DirectMemoryUtils() - Constructor for class org.apache.flume.tools.DirectMemoryUtils
 
discard - Variable in class org.apache.flume.lifecycle.LifecycleSupervisor.Status
 
Disposable - Annotation Type in org.apache.flume.annotations
 
doBegin() - Method in class org.apache.flume.channel.BasicTransactionSemantics
 
doClose() - Method in class org.apache.flume.channel.BasicTransactionSemantics
 
doCommit() - Method in class org.apache.flume.channel.BasicTransactionSemantics
 
doConfigure(Context) - Method in class org.apache.flume.source.BasicSourceSemantics
 
doConfigure(Context) - Method in class org.apache.flume.source.jms.JMSSource
 
doConfigure(Context) - Method in class org.apache.flume.source.kafka.KafkaSource
We configure the source and generate properties for the Kafka Consumer Kafka Consumer properties are generated as follows: 1.
doConfigure(Context) - Method in class org.apache.flume.source.SequenceGeneratorSource
Read parameters from context batchSize = type int that defines the size of event batches
doConfigure(Context) - Method in class org.apache.flume.source.StressSource
Read parameters from context -maxTotalEvents = type long that defines the total number of Events to be sent -maxSuccessfulEvents = type long that defines the number of successful Events -size = type int that defines the number of bytes in each Event -batchSize = type int that defines the number of Events being sent in one batch
doOpen(Configuration, Path, FileSystem) - Method in class org.apache.flume.sink.hdfs.HDFSDataStream
 
doProcess() - Method in class org.apache.flume.source.AbstractPollableSource
 
doProcess() - Method in class org.apache.flume.source.jms.JMSSource
 
doProcess() - Method in class org.apache.flume.source.kafka.KafkaSource
 
doProcess() - Method in class org.apache.flume.source.SequenceGeneratorSource
 
doProcess() - Method in class org.apache.flume.source.StressSource
 
doPut(Event) - Method in class org.apache.flume.channel.BasicTransactionSemantics
 
doRollback() - Method in class org.apache.flume.channel.BasicTransactionSemantics
 
doStart() - Method in class org.apache.flume.source.BasicSourceSemantics
 
doStart() - Method in class org.apache.flume.source.jms.JMSSource
 
doStart() - Method in class org.apache.flume.source.kafka.KafkaSource
 
doStart() - Method in class org.apache.flume.source.SequenceGeneratorSource
 
doStart() - Method in class org.apache.flume.source.StressSource
 
doStop() - Method in class org.apache.flume.source.BasicSourceSemantics
 
doStop() - Method in class org.apache.flume.source.jms.JMSSource
 
doStop() - Method in class org.apache.flume.source.kafka.KafkaSource
 
doStop() - Method in class org.apache.flume.source.SequenceGeneratorSource
 
doStop() - Method in class org.apache.flume.source.StressSource
 
doTake() - Method in class org.apache.flume.channel.BasicTransactionSemantics
 
drainOrder - Variable in class org.apache.flume.channel.SpillableMemoryChannel
 
Dummy - Class in org.apache.flume
Placeholder class so the git mirror does not leave out the src/main/java dir
Dummy() - Constructor for class org.apache.flume.Dummy
 
dump() - Method in class org.apache.flume.channel.SpillableMemoryChannel.DrainOrderQueue
 
dumpEvent(Event) - Static method in class org.apache.flume.event.EventHelper
 
dumpEvent(Event, int) - Static method in class org.apache.flume.event.EventHelper
 
DurablePositionTracker - Class in org.apache.flume.serialization

Class that stores object state in an avro container file.

E

ElasticSearchClient - Interface in org.apache.flume.sink.elasticsearch.client
Interface for an ElasticSearch client which is responsible for sending bulks of events to ElasticSearch.
ElasticSearchClientFactory - Class in org.apache.flume.sink.elasticsearch.client
Internal ElasticSearch client factory.
ElasticSearchClientFactory() - Constructor for class org.apache.flume.sink.elasticsearch.client.ElasticSearchClientFactory
 
ElasticSearchDynamicSerializer - Class in org.apache.flume.sink.elasticsearch
Basic serializer that serializes the event body and header fields into individual fields
ElasticSearchDynamicSerializer() - Constructor for class org.apache.flume.sink.elasticsearch.ElasticSearchDynamicSerializer
 
ElasticSearchEventSerializer - Interface in org.apache.flume.sink.elasticsearch
Interface for an event serializer which serializes the headers and body of an event to write them to ElasticSearch.
ElasticSearchIndexRequestBuilderFactory - Interface in org.apache.flume.sink.elasticsearch
Interface for creating ElasticSearch IndexRequestBuilder instances from serialized flume events.
ElasticSearchLogStashEventSerializer - Class in org.apache.flume.sink.elasticsearch
Serialize flume events into the same format LogStash uses
ElasticSearchLogStashEventSerializer() - Constructor for class org.apache.flume.sink.elasticsearch.ElasticSearchLogStashEventSerializer
 
ElasticSearchRestClient - Class in org.apache.flume.sink.elasticsearch.client
Rest ElasticSearch client which is responsible for sending bulks of events to ElasticSearch using ElasticSearch HTTP API.
ElasticSearchRestClient(String[], ElasticSearchEventSerializer) - Constructor for class org.apache.flume.sink.elasticsearch.client.ElasticSearchRestClient
 
ElasticSearchRestClient(String[], ElasticSearchEventSerializer, HttpClient) - Constructor for class org.apache.flume.sink.elasticsearch.client.ElasticSearchRestClient
 
ElasticSearchSink - Class in org.apache.flume.sink.elasticsearch
A sink which reads events from a channel and writes them to ElasticSearch based on the work done by https://github.com/Aconex/elasticflume.git.
ElasticSearchSink() - Constructor for class org.apache.flume.sink.elasticsearch.ElasticSearchSink
Create an ElasticSearchSink configured using the supplied configuration
ElasticSearchSinkConstants - Class in org.apache.flume.sink.elasticsearch
 
ElasticSearchSinkConstants() - Constructor for class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
 
ElasticSearchTransportClient - Class in org.apache.flume.sink.elasticsearch.client
 
ElasticSearchTransportClient(String[], String, ElasticSearchEventSerializer) - Constructor for class org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient
Transport client for external cluster
ElasticSearchTransportClient(String[], String, ElasticSearchIndexRequestBuilderFactory) - Constructor for class org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient
 
ElasticSearchTransportClient(ElasticSearchIndexRequestBuilderFactory) - Constructor for class org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient
Local transport client only for testing
ElasticSearchTransportClient(ElasticSearchEventSerializer) - Constructor for class org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient
Local transport client only for testing
ElasticSearchTransportClient(Client, ElasticSearchEventSerializer) - Constructor for class org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient
Used for testing
ElasticSearchTransportClient(Client, ElasticSearchIndexRequestBuilderFactory) - Constructor for class org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient
Used for testing
EmbeddedAgent - Class in org.apache.flume.agent.embedded
EmbeddedAgent gives Flume users the ability to embed simple agents in applications.
EmbeddedAgent(String) - Constructor for class org.apache.flume.agent.embedded.EmbeddedAgent
 
EmbeddedAgentConfiguration - Class in org.apache.flume.agent.embedded
Stores publicly accessible configuration constants and private configuration constants and methods.
EmbeddedSource - Class in org.apache.flume.agent.embedded
Simple source used to allow direct access to the channel for the Embedded Agent.
EmbeddedSource() - Constructor for class org.apache.flume.agent.embedded.EmbeddedSource
 
encrypt(byte[]) - Method in class org.apache.flume.channel.file.encryption.CipherProvider.Encryptor
 
ENCRYPTION_FIELD_NUMBER - Static variable in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
 
ENCRYPTION_PREFIX - Static variable in class org.apache.flume.channel.file.encryption.EncryptionConfiguration
 
EncryptionConfiguration - Class in org.apache.flume.channel.file.encryption
 
enforceConstraints(Context) - Static method in class org.apache.flume.tools.HTTPServerConstraintUtil
Impose constraints on the Context passed in.
ensureOptionalNonNull(Context, String...) - Static method in class org.apache.flume.conf.Configurables
 
ensureRequiredNonNull(Context, String...) - Static method in class org.apache.flume.conf.Configurables
 
EntityParser<E> - Interface in org.apache.flume.sink.kite.parser
 
EntityParser.Builder<E> - Interface in org.apache.flume.sink.kite.parser
Knows how to build EntityParsers.
EntityParserFactory - Class in org.apache.flume.sink.kite.parser
 
EntityParserFactory() - Constructor for class org.apache.flume.sink.kite.parser.EntityParserFactory
 
equals(Object) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
equals(ThriftFlumeEvent) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
equals(Object) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args
 
equals(ThriftFlumeEventServer.append_args) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args
 
equals(Object) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args
 
equals(ThriftFlumeEventServer.close_args) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args
 
equals(Object) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result
 
equals(ThriftFlumeEventServer.close_result) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result
 
equals(Object) - Method in class org.apache.flume.auth.KerberosUser
 
equals(Object) - Method in class org.apache.flume.sink.hdfs.KerberosUser
 
equals(Object) - Method in class org.apache.flume.source.scribe.LogEntry
 
equals(LogEntry) - Method in class org.apache.flume.source.scribe.LogEntry
 
equals(Object) - Method in class org.apache.flume.source.scribe.Scribe.Log_args
 
equals(Scribe.Log_args) - Method in class org.apache.flume.source.scribe.Scribe.Log_args
 
equals(Object) - Method in class org.apache.flume.source.scribe.Scribe.Log_result
 
equals(Scribe.Log_result) - Method in class org.apache.flume.source.scribe.Scribe.Log_result
 
equals(Object) - Method in class org.apache.flume.source.taildir.TaildirMatcher
 
equals(Object) - Method in class org.apache.flume.thrift.ThriftFlumeEvent
 
equals(ThriftFlumeEvent) - Method in class org.apache.flume.thrift.ThriftFlumeEvent
 
equals(Object) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_args
 
equals(ThriftSourceProtocol.append_args) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_args
 
equals(Object) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_result
 
equals(ThriftSourceProtocol.append_result) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_result
 
equals(Object) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
 
equals(ThriftSourceProtocol.appendBatch_args) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
 
equals(Object) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result
 
equals(ThriftSourceProtocol.appendBatch_result) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result
 
error - Variable in class org.apache.flume.lifecycle.LifecycleSupervisor.Status
 
ERROR_THRESHOLD - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
ERROR_THRESHOLD_DEFAULT - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
errors - Variable in class org.apache.flume.conf.ComponentConfiguration
 
escapeString(String, Map<String, String>) - Static method in class org.apache.flume.formatter.output.BucketPath
Replace all substrings of form %{tagname} with get(tagname).toString() and all shorthand substrings of form %x with a special value.
escapeString(String, Map<String, String>, boolean, int, int) - Static method in class org.apache.flume.formatter.output.BucketPath
A wrapper around BucketPath.escapeString(String, Map, TimeZone, boolean, int, int, boolean) with the timezone set to the default.
escapeString(String, Map<String, String>, TimeZone, boolean, int, int, boolean) - Static method in class org.apache.flume.formatter.output.BucketPath
Replace all substrings of form %{tagname} with get(tagname).toString() and all shorthand substrings of form %x with a special value.
Event - Interface in org.apache.flume
Basic representation of a data object in Flume.
event - Variable in class org.apache.flume.thrift.ThriftSourceProtocol.append_args
 
EVENT_FIELD_NUMBER - Static variable in class org.apache.flume.channel.file.proto.ProtosFactory.Put
 
EVENT_STATUS - Static variable in class org.apache.flume.source.SyslogUtils
 
EventBuilder - Class in org.apache.flume.event
 
EventBuilder() - Constructor for class org.apache.flume.event.EventBuilder
 
EventDeliveryException - Exception in org.apache.flume
An event delivery exception is raised whenever an Event fails to reach at least one of its intended (next-hop) destinations.
EventDeliveryException() - Constructor for exception org.apache.flume.EventDeliveryException
 
EventDeliveryException(String) - Constructor for exception org.apache.flume.EventDeliveryException
 
EventDeliveryException(String, Throwable) - Constructor for exception org.apache.flume.EventDeliveryException
 
EventDeliveryException(Throwable) - Constructor for exception org.apache.flume.EventDeliveryException
 
EventDeserializer - Interface in org.apache.flume.serialization
Establishes a contract for reading events stored in arbitrary formats from reliable, resettable streams.
EventDeserializer.Builder - Interface in org.apache.flume.serialization
Knows how to construct this deserializer.
Note: Implementations MUST provide a public a no-arg constructor.
EventDeserializerFactory - Class in org.apache.flume.serialization
 
EventDeserializerFactory() - Constructor for class org.apache.flume.serialization.EventDeserializerFactory
 
EventDeserializerType - Enum in org.apache.flume.serialization
 
EventDrivenSource - Interface in org.apache.flume
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.
EventDrivenSourceRunner - Class in org.apache.flume.source
Starts, stops, and manages event-driven sources.
EventDrivenSourceRunner() - Constructor for class org.apache.flume.source.EventDrivenSourceRunner
 
EventFormatter - Interface in org.apache.flume.formatter.output
Deprecated.
EventHelper - Class in org.apache.flume.event
 
EventHelper() - Constructor for class org.apache.flume.event.EventHelper
 
EventReader - Interface in org.apache.flume.client.avro
A line reader produces a stream of lines for the AvroCLIClient to ingest into Flume.
events - Variable in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
 
EventSerDe - Interface in org.apache.flume.serialization

A class that is able to both serialize and deserialize events.

EventSerDe.Builder - Interface in org.apache.flume.serialization
Knows how to construct this serde.
Note: Implementations MUST provide a public a no-arg constructor.
EventSerializer - Interface in org.apache.flume.serialization
This interface provides callbacks for important serialization-related events.
EventSerializer.Builder - Interface in org.apache.flume.serialization
Knows how to construct this event serializer.
Note: Implementations MUST provide a public a no-arg constructor.
EventSerializerFactory - Class in org.apache.flume.serialization
 
EventSerializerFactory() - Constructor for class org.apache.flume.serialization.EventSerializerFactory
 
EventSerializerIndexRequestBuilderFactory - Class in org.apache.flume.sink.elasticsearch
Default implementation of ElasticSearchIndexRequestBuilderFactory.
EventSerializerIndexRequestBuilderFactory(ElasticSearchEventSerializer) - Constructor for class org.apache.flume.sink.elasticsearch.EventSerializerIndexRequestBuilderFactory
 
EventSerializerIndexRequestBuilderFactory(ElasticSearchEventSerializer, FastDateFormat) - Constructor for class org.apache.flume.sink.elasticsearch.EventSerializerIndexRequestBuilderFactory
 
EventSerializerType - Enum in org.apache.flume.serialization
 
EventStatus - Enum in com.cloudera.flume.handlers.thrift
 
EventUtils - Class in org.apache.flume.channel.file
 
EventUtils() - Constructor for class org.apache.flume.channel.file.EventUtils
 
EventValidator - Interface in org.apache.flume.tools
Event Validator interface to be used for validating Events per custom logic
EventValidator.Builder - Interface in org.apache.flume.tools
 
evt - Variable in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args
 
EXCLUDE_EVENTS - Static variable in class org.apache.flume.interceptor.RegexFilteringInterceptor.Constants
 
EXCLUDE_PROTOCOLS - Static variable in class org.apache.flume.source.http.HTTPSourceConfigurationConstants
 
EXCLUDES - Static variable in class org.apache.flume.channel.file.Log
Set of files that should be excluded from backup and restores.
ExecSource - Class in org.apache.flume.source
A Source implementation that executes a Unix process and turns each line of text into an event.
ExecSource() - Constructor for class org.apache.flume.source.ExecSource
 
ExecSourceConfigurationConstants - Class in org.apache.flume.source
 
ExecSourceConfigurationConstants() - Constructor for class org.apache.flume.source.ExecSourceConfigurationConstants
 
execute(PrivilegedExceptionAction<T>) - Method in interface org.apache.flume.auth.PrivilegedExecutor
This method is used to execute a privileged action, the implementor can chose to execute the action using the appropriate privileges
execute(PrivilegedAction<T>) - Method in interface org.apache.flume.auth.PrivilegedExecutor
This method is used to execute a privileged action, the implementor can chose to execute the action using the appropriate privileges
execute() - Method in interface org.apache.flume.sink.elasticsearch.client.ElasticSearchClient
Sends bulk to the elasticsearch cluster
execute() - Method in class org.apache.flume.sink.elasticsearch.client.ElasticSearchRestClient
 
execute() - Method in class org.apache.flume.sink.elasticsearch.client.ElasticSearchTransportClient
 
expandShorthand(char) - Static method in class org.apache.flume.formatter.output.BucketPath
Deprecated.
extractEvent(ChannelBuffer) - Method in class org.apache.flume.source.SyslogUtils
 

F

fail() - Method in class org.apache.flume.lifecycle.LifecycleSupervisor
 
failIfConfigured() - Method in class org.apache.flume.conf.ComponentConfiguration
 
FailoverRpcClient - Class in org.apache.flume.api
Avro/Netty implementation of RpcClient which supports failover.
FailoverRpcClient() - Constructor for class org.apache.flume.api.FailoverRpcClient
 
FailoverSinkProcessor - Class in org.apache.flume.sink
FailoverSinkProcessor maintains a prioritized list of sinks, guarranteeing that so long as one is available events will be processed.
FailoverSinkProcessor() - Constructor for class org.apache.flume.sink.FailoverSinkProcessor
 
FailurePolicy - Interface in org.apache.flume.sink.kite.policy
A policy for dealing with non-recoverable event delivery failures.
FailurePolicy.Builder - Interface in org.apache.flume.sink.kite.policy
Knows how to build FailurePolicys.
FailurePolicyFactory - Class in org.apache.flume.sink.kite.policy
 
FailurePolicyFactory() - Constructor for class org.apache.flume.sink.kite.policy.FailurePolicyFactory
 
failures - Variable in class org.apache.flume.lifecycle.LifecycleSupervisor.Status
 
fastDateFormat - Variable in class org.apache.flume.sink.elasticsearch.AbstractElasticSearchIndexRequestBuilderFactory
fetchAndDeleteEvent(String, Connection) - Method in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler
 
fetchAndDeleteEvent(String, Connection) - Method in class org.apache.flume.channel.jdbc.impl.MySQLSchemaHandler
 
fetchAndDeleteEvent(String, Connection) - Method in interface org.apache.flume.channel.jdbc.impl.SchemaHandler
Retrieves the next persistent event from the database.
fieldForId(int) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
fieldForId(int) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args
 
fieldForId(int) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args
 
fieldForId(int) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result
 
fieldForId(int) - Method in class org.apache.flume.source.scribe.LogEntry
 
fieldForId(int) - Method in class org.apache.flume.source.scribe.Scribe.Log_args
 
fieldForId(int) - Method in class org.apache.flume.source.scribe.Scribe.Log_result
 
fieldForId(int) - Method in class org.apache.flume.thrift.ThriftFlumeEvent
 
fieldForId(int) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_args
 
fieldForId(int) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_result
 
fieldForId(int) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
 
fieldForId(int) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result
 
fields - Variable in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
FILE_GROUPS - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
Mapping for tailing file groups.
FILE_GROUPS_PREFIX - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
 
FILE_LOCK - Static variable in class org.apache.flume.channel.file.Log
 
FileChannel - Class in org.apache.flume.channel.file
A durable Channel implementation that uses the local file system for its storage.
FileChannel() - Constructor for class org.apache.flume.channel.file.FileChannel
 
FileChannelConfiguration - Class in org.apache.flume.channel.file
 
FileChannelConfiguration() - Constructor for class org.apache.flume.channel.file.FileChannelConfiguration
 
FileChannelIntegrityTool - Class in org.apache.flume.tools
 
FileChannelIntegrityTool() - Constructor for class org.apache.flume.tools.FileChannelIntegrityTool
 
FILEID_FIELD_NUMBER - Static variable in class org.apache.flume.channel.file.proto.ProtosFactory.Take
 
FILENAME_HEADER - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
Whether to include absolute path filename in a header.
FILENAME_HEADER - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
Whether to include absolute path filename in a header.
FILENAME_HEADER_KEY - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
Header in which to put absolute path filename.
FILENAME_HEADER_KEY - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
Header in which to put absolute path filename.
fileNameHeader(String) - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
 
fileNameHeader(String) - Method in class org.apache.flume.source.taildir.ReliableTaildirEventReader.Builder
 
filePaths(Map<String, String>) - Method in class org.apache.flume.source.taildir.ReliableTaildirEventReader.Builder
 
findByName(String) - Static method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEvent._Fields
Find the _Fields constant that matches name, or null if its not found.
findByName(String) - Static method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args._Fields
Find the _Fields constant that matches name, or null if its not found.
findByName(String) - Static method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args._Fields
Find the _Fields constant that matches name, or null if its not found.
findByName(String) - Static method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result._Fields
Find the _Fields constant that matches name, or null if its not found.
findByName(String) - Static method in enum org.apache.flume.source.scribe.LogEntry._Fields
Find the _Fields constant that matches name, or null if its not found.
findByName(String) - Static method in enum org.apache.flume.source.scribe.Scribe.Log_args._Fields
Find the _Fields constant that matches name, or null if its not found.
findByName(String) - Static method in enum org.apache.flume.source.scribe.Scribe.Log_result._Fields
Find the _Fields constant that matches name, or null if its not found.
findByName(String) - Static method in enum org.apache.flume.thrift.ThriftFlumeEvent._Fields
Find the _Fields constant that matches name, or null if its not found.
findByName(String) - Static method in enum org.apache.flume.thrift.ThriftSourceProtocol.append_args._Fields
Find the _Fields constant that matches name, or null if its not found.
findByName(String) - Static method in enum org.apache.flume.thrift.ThriftSourceProtocol.append_result._Fields
Find the _Fields constant that matches name, or null if its not found.
findByName(String) - Static method in enum org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args._Fields
Find the _Fields constant that matches name, or null if its not found.
findByName(String) - Static method in enum org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result._Fields
Find the _Fields constant that matches name, or null if its not found.
findByThriftId(int) - Static method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEvent._Fields
Find the _Fields constant that matches fieldId, or null if its not found.
findByThriftId(int) - Static method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args._Fields
Find the _Fields constant that matches fieldId, or null if its not found.
findByThriftId(int) - Static method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args._Fields
Find the _Fields constant that matches fieldId, or null if its not found.
findByThriftId(int) - Static method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result._Fields
Find the _Fields constant that matches fieldId, or null if its not found.
findByThriftId(int) - Static method in enum org.apache.flume.source.scribe.LogEntry._Fields
Find the _Fields constant that matches fieldId, or null if its not found.
findByThriftId(int) - Static method in enum org.apache.flume.source.scribe.Scribe.Log_args._Fields
Find the _Fields constant that matches fieldId, or null if its not found.
findByThriftId(int) - Static method in enum org.apache.flume.source.scribe.Scribe.Log_result._Fields
Find the _Fields constant that matches fieldId, or null if its not found.
findByThriftId(int) - Static method in enum org.apache.flume.thrift.ThriftFlumeEvent._Fields
Find the _Fields constant that matches fieldId, or null if its not found.
findByThriftId(int) - Static method in enum org.apache.flume.thrift.ThriftSourceProtocol.append_args._Fields
Find the _Fields constant that matches fieldId, or null if its not found.
findByThriftId(int) - Static method in enum org.apache.flume.thrift.ThriftSourceProtocol.append_result._Fields
Find the _Fields constant that matches fieldId, or null if its not found.
findByThriftId(int) - Static method in enum org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args._Fields
Find the _Fields constant that matches fieldId, or null if its not found.
findByThriftId(int) - Static method in enum org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result._Fields
Find the _Fields constant that matches fieldId, or null if its not found.
findByThriftIdOrThrow(int) - Static method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEvent._Fields
Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
findByThriftIdOrThrow(int) - Static method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args._Fields
Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
findByThriftIdOrThrow(int) - Static method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args._Fields
Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
findByThriftIdOrThrow(int) - Static method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result._Fields
Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
findByThriftIdOrThrow(int) - Static method in enum org.apache.flume.source.scribe.LogEntry._Fields
Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
findByThriftIdOrThrow(int) - Static method in enum org.apache.flume.source.scribe.Scribe.Log_args._Fields
Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
findByThriftIdOrThrow(int) - Static method in enum org.apache.flume.source.scribe.Scribe.Log_result._Fields
Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
findByThriftIdOrThrow(int) - Static method in enum org.apache.flume.thrift.ThriftFlumeEvent._Fields
Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
findByThriftIdOrThrow(int) - Static method in enum org.apache.flume.thrift.ThriftSourceProtocol.append_args._Fields
Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
findByThriftIdOrThrow(int) - Static method in enum org.apache.flume.thrift.ThriftSourceProtocol.append_result._Fields
Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
findByThriftIdOrThrow(int) - Static method in enum org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args._Fields
Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
findByThriftIdOrThrow(int) - Static method in enum org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result._Fields
Find the _Fields constant that matches fieldId, throwing an exception if it is not found.
findByValue(int) - Static method in enum com.cloudera.flume.handlers.thrift.EventStatus
Find a the enum type by its integer value, as defined in the Thrift IDL.
findByValue(int) - Static method in enum com.cloudera.flume.handlers.thrift.Priority
Find a the enum type by its integer value, as defined in the Thrift IDL.
findByValue(int) - Static method in enum org.apache.flume.source.scribe.ResultCode
Find a the enum type by its integer value, as defined in the Thrift IDL.
findByValue(int) - Static method in enum org.apache.flume.thrift.Status
Find a the enum type by its integer value, as defined in the Thrift IDL.
firstSeen - Variable in class org.apache.flume.lifecycle.LifecycleSupervisor.Status
 
FLOOR_MINIMUM_REQUIRED_SPACE - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
Minimum space floor is 1MB
FlumeAuthenticationUtil - Class in org.apache.flume.auth
FlumeAuthentication utility class that provides methods to get an Authenticator.
FlumeAuthenticator - Interface in org.apache.flume.auth
FlumeAuthenticator extends on a PrivilegedExecutor providing capabilities to proxy as a different user
FlumeConfiguration - Class in org.apache.flume.conf
FlumeConfiguration is an in memory representation of the hierarchical configuration namespace required by the ConfigurationProvider.
FlumeConfiguration(Properties) - Constructor for class org.apache.flume.conf.FlumeConfiguration
Deprecated.
please use the other constructor
FlumeConfiguration(Map<String, String>) - Constructor for class org.apache.flume.conf.FlumeConfiguration
Creates a populated Flume Configuration object.
FlumeConfiguration.AgentConfiguration - Class in org.apache.flume.conf
 
FlumeConfiguration.ComponentNameAndConfigKey - Class in org.apache.flume.conf
 
FlumeConfigurationError - Class in org.apache.flume.conf
 
FlumeConfigurationError(String, String, FlumeConfigurationErrorType, FlumeConfigurationError.ErrorOrWarning) - Constructor for class org.apache.flume.conf.FlumeConfigurationError
Component which had an error, specific key in error(which can be null)
FlumeConfigurationError.ErrorOrWarning - Enum in org.apache.flume.conf
 
FlumeConfigurationErrorType - Enum in org.apache.flume.conf
 
FlumeEventAvroEventSerializer - Class in org.apache.flume.serialization
 
FlumeEventAvroEventSerializer.Builder - Class in org.apache.flume.serialization
 
FlumeEventAvroEventSerializer.Builder() - Constructor for class org.apache.flume.serialization.FlumeEventAvroEventSerializer.Builder
 
FlumeException - Exception in org.apache.flume
Base class of all flume exceptions.
FlumeException(String) - Constructor for exception org.apache.flume.FlumeException
 
FlumeException(String, Throwable) - Constructor for exception org.apache.flume.FlumeException
 
FlumeException(Throwable) - Constructor for exception org.apache.flume.FlumeException
 
FlumeTool - Interface in org.apache.flume.tools
 
FlumeToolsMain - Class in org.apache.flume.tools
 
FlumeToolType - Enum in org.apache.flume.tools
 
flush() - Method in class org.apache.flume.serialization.AbstractAvroEventSerializer
 
flush() - Method in class org.apache.flume.serialization.BodyTextEventSerializer
 
flush() - Method in interface org.apache.flume.serialization.EventSerializer
Hook to flush any internal write buffers to the underlying stream.
flush() - Method in class org.apache.flume.serialization.HeaderAndBodyTextEventSerializer
 
flush() - Method in class org.apache.flume.sink.hdfs.AvroEventSerializer
 
format(Event) - Method in interface org.apache.flume.formatter.output.EventFormatter
Deprecated.
 
format(Event) - Method in class org.apache.flume.formatter.output.TextDelimitedOutputFormatter
Deprecated.
 
forSource(Source) - Static method in class org.apache.flume.SourceRunner
Static factory method to instantiate a source runner implementation that corresponds to the type of Source specified.
front() - Method in class org.apache.flume.channel.SpillableMemoryChannel.DrainOrderQueue
 
FSYNC_INTERVAL - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 
FSYNC_PER_TXN - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
 

G

GANGLIA_DOUBLE_TYPE - Static variable in class org.apache.flume.instrumentation.GangliaServer
 
GangliaServer - Class in org.apache.flume.instrumentation
A Ganglia server that polls JMX based at a configured frequency (defaults to once every 60 seconds).
GangliaServer() - Constructor for class org.apache.flume.instrumentation.GangliaServer
 
GangliaServer.GangliaCollector - Class in org.apache.flume.instrumentation
Worker which polls JMX for all mbeans with ObjectName within the flume namespace: org.apache.flume.
GangliaServer.GangliaCollector() - Constructor for class org.apache.flume.instrumentation.GangliaServer.GangliaCollector
 
generateSkewedMessageList(PartitionTestScenario, int, Map<Integer, List<Event>>, int, int) - Static method in class org.apache.flume.shared.kafka.test.KafkaPartitionTestUtil
This method is can be used to create a list of events for use in Kafka partition tests.
generateUUID() - Method in class org.apache.flume.sink.solr.morphline.UUIDInterceptor
 
get(String) - Method in class org.apache.flume.CounterGroup
 
get(String) - Method in class org.apache.flume.instrumentation.MonitoredCounterGroup
Retrieves the current value for this key
get() - Method in class org.apache.flume.sink.elasticsearch.client.RoundRobinList
 
get() - Method in class org.apache.flume.source.kafka.KafkaSource.Subscriber
 
getActions() - Method in interface org.apache.flume.sink.hbase.AsyncHbaseEventSerializer
Get the actions that should be written out to hbase as a result of this event.
getActions() - Method in interface org.apache.flume.sink.hbase.HbaseEventSerializer
Get the actions that should be written out to hbase as a result of this event.
getActions() - Method in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
 
getActions() - Method in class org.apache.flume.sink.hbase.SimpleAsyncHbaseEventSerializer
 
getActions() - Method in class org.apache.flume.sink.hbase.SimpleHbaseEventSerializer
 
getActiveLogs(int) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
getActiveLogs(int) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
repeated .ActiveLog activeLogs = 5;
getActiveLogs(int) - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
repeated .ActiveLog activeLogs = 5;
getActiveLogsBuilder(int) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
getActiveLogsBuilderList() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
getActiveLogsCount() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
getActiveLogsCount() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
repeated .ActiveLog activeLogs = 5;
getActiveLogsCount() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
repeated .ActiveLog activeLogs = 5;
getActiveLogsList() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
getActiveLogsList() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
repeated .ActiveLog activeLogs = 5;
getActiveLogsList() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
repeated .ActiveLog activeLogs = 5;
getActiveLogsOrBuilder(int) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
getActiveLogsOrBuilder(int) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
repeated .ActiveLog activeLogs = 5;
getActiveLogsOrBuilder(int) - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
repeated .ActiveLog activeLogs = 5;
getActiveLogsOrBuilderList() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
repeated .ActiveLog activeLogs = 5;
getActiveLogsOrBuilderList() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
repeated .ActiveLog activeLogs = 5;
getActiveLogsOrBuilderList() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
repeated .ActiveLog activeLogs = 5;
getAgentName() - Method in class org.apache.flume.node.AbstractConfigurationProvider
 
getAllChannels() - Method in class org.apache.flume.channel.AbstractChannelSelector
 
getAllChannels() - Method in interface org.apache.flume.ChannelSelector
 
getAllMBeans() - Static method in class org.apache.flume.instrumentation.util.JMXPollUtil
 
getAppendAcceptedCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean
 
getAppendAcceptedCount() - Method in class org.apache.flume.instrumentation.SourceCounter
 
getAppendAcceptedCount() - Method in interface org.apache.flume.instrumentation.SourceCounterMBean
 
getAppendBatchAcceptedCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean
 
getAppendBatchAcceptedCount() - Method in class org.apache.flume.instrumentation.SourceCounter
 
getAppendBatchAcceptedCount() - Method in interface org.apache.flume.instrumentation.SourceCounterMBean
 
getAppendBatchReceivedCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean
 
getAppendBatchReceivedCount() - Method in class org.apache.flume.instrumentation.SourceCounter
 
getAppendBatchReceivedCount() - Method in interface org.apache.flume.instrumentation.SourceCounterMBean
 
getAppendReceivedCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean
 
getAppendReceivedCount() - Method in class org.apache.flume.instrumentation.SourceCounter
 
getAppendReceivedCount() - Method in interface org.apache.flume.instrumentation.SourceCounterMBean
 
getAsyncClient(TNonblockingTransport) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncClient.Factory
 
getAsyncClient(TNonblockingTransport) - Method in class org.apache.flume.source.scribe.Scribe.AsyncClient.Factory
 
getAsyncClient(TNonblockingTransport) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.AsyncClient.Factory
 
getAuthenticator(String, String) - Static method in class org.apache.flume.auth.FlumeAuthenticationUtil
If principal and keytab are null, this method returns a SimpleAuthenticator which executes without authentication.
getBackOffSleepIncrement() - Method in interface org.apache.flume.PollableSource
 
getBackOffSleepIncrement() - Method in class org.apache.flume.source.AbstractPollableSource
 
getBackOffSleepIncrement() - Method in class org.apache.flume.source.taildir.TaildirSource
 
getBackupCheckpointPosition() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
optional sfixed64 backupCheckpointPosition = 6;
getBackupCheckpointPosition() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
optional sfixed64 backupCheckpointPosition = 6;
getBackupCheckpointPosition() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
optional sfixed64 backupCheckpointPosition = 6;
getBackupCheckpointWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
optional sfixed64 backupCheckpointWriteOrderID = 7;
getBackupCheckpointWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
optional sfixed64 backupCheckpointWriteOrderID = 7;
getBackupCheckpointWriteOrderID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
optional sfixed64 backupCheckpointWriteOrderID = 7;
getBase() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.SpillableString
 
getBaseDirectory() - Method in class org.apache.flume.formatter.output.DefaultPathManager
 
getBaseDirectory() - Method in interface org.apache.flume.formatter.output.PathManager
 
getBasePayload() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent
 
getBatchCompleteCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean
 
getBatchCompleteCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
getBatchCompleteCount() - Method in interface org.apache.flume.instrumentation.SinkCounterMBean
 
getBatchEmptyCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean
 
getBatchEmptyCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
getBatchEmptyCount() - Method in interface org.apache.flume.instrumentation.SinkCounterMBean
 
getBatchSize() - Method in class org.apache.flume.api.AbstractRpcClient
 
getBatchSize() - Method in interface org.apache.flume.api.RpcClient
Returns the maximum number of events that may be batched at once by appendBatch().
getBatchSize() - Method in class org.apache.flume.api.ThriftRpcClient
 
getBatchSize() - Method in class org.apache.flume.sink.kafka.KafkaSink
 
getBatchUnderflowCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean
 
getBatchUnderflowCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
getBatchUnderflowCount() - Method in interface org.apache.flume.instrumentation.SinkCounterMBean
 
getBody() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
getBody() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
required bytes body = 2;
getBody() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
required bytes body = 2;
getBody() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder
required bytes body = 2;
getBody() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent
 
getBody() - Method in interface org.apache.flume.Event
Returns the raw byte array of the data contained in this event.
getBody() - Method in class org.apache.flume.event.JSONEvent
 
getBody() - Method in class org.apache.flume.event.SimpleEvent
 
getBody() - Method in class org.apache.flume.thrift.ThriftFlumeEvent
 
getBoolean(String, Boolean) - Method in class org.apache.flume.Context
Gets value mapped to key, returning defaultValue if unmapped.
getBoolean(String) - Method in class org.apache.flume.Context
Gets value mapped to key, returning null if unmapped.
getBranch() - Static method in class org.apache.flume.tools.VersionInfo
Get the branch on which this originated.
getBuilderClass() - Method in enum org.apache.flume.channel.file.encryption.KeyProviderType
 
getBuilderClass() - Method in enum org.apache.flume.formatter.output.PathManagerType
 
getBuilderClass() - Method in enum org.apache.flume.interceptor.InterceptorType
 
getBuilderClass() - Method in enum org.apache.flume.serialization.EventDeserializerType
 
getBuilderClass() - Method in enum org.apache.flume.serialization.EventSerializerType
 
getBuilderClass() - Method in enum org.apache.flume.sink.hdfs.SequenceFileSerializerType
 
getBuildVersion() - Static method in class org.apache.flume.tools.VersionInfo
Returns the build version info which includes version, revision, user, date and source checksum
getByName(String) - Static method in enum org.apache.flume.channel.jdbc.DatabaseType
 
getByName(String) - Static method in enum org.apache.flume.channel.jdbc.TransactionIsolation
 
getByName(String) - Static method in enum org.apache.flume.clients.log4jappender.Log4jAvroHeaders
 
getCategory() - Method in class org.apache.flume.source.scribe.LogEntry
 
getChannel() - Method in class org.apache.flume.conf.sink.SinkConfiguration
 
getChannel(String) - Method in class org.apache.flume.conf.sink.SinkConfiguration
 
getChannel() - Method in class org.apache.flume.sink.AbstractSink
 
getChannel() - Method in interface org.apache.flume.Sink
 
getChannelCapacity() - Method in class org.apache.flume.instrumentation.ChannelCounter
 
getChannelCapacity() - Method in interface org.apache.flume.instrumentation.ChannelCounterMBean
 
getChannelCapacity() - Method in interface org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
 
getChannelClassName() - Method in enum org.apache.flume.conf.channel.ChannelType
 
getChannelConfigMap() - Method in class org.apache.flume.conf.FlumeConfiguration.AgentConfiguration
 
getChannelConfigurationType() - Method in enum org.apache.flume.conf.channel.ChannelConfiguration.ChannelConfigurationType
 
getChannelContext() - Method in class org.apache.flume.conf.FlumeConfiguration.AgentConfiguration
 
getChannelFillPercentage() - Method in class org.apache.flume.instrumentation.ChannelCounter
 
getChannelFillPercentage() - Method in interface org.apache.flume.instrumentation.ChannelCounterMBean
 
getChannelFillPercentage() - Method in interface org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
 
getChannelListFromNames(String, Map<String, Channel>) - Method in class org.apache.flume.channel.AbstractChannelSelector
Given a list of channel names as space delimited string, returns list of channels.
getChannelName() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent
 
getChannelNameMap() - Method in class org.apache.flume.channel.AbstractChannelSelector
 
getChannelProcessor() - Method in class org.apache.flume.source.AbstractSource
 
getChannelProcessor() - Method in class org.apache.flume.source.BasicSourceSemantics
 
getChannelProcessor() - Method in interface org.apache.flume.Source
Returns the channel processor that will handle this source's events.
getChannels() - Method in class org.apache.flume.conf.channel.ChannelSelectorConfiguration
 
getChannels() - Method in class org.apache.flume.conf.source.SourceConfiguration
 
getChannels() - Method in interface org.apache.flume.node.MaterializedConfiguration
 
getChannels() - Method in class org.apache.flume.node.SimpleMaterializedConfiguration
 
getChannelSelectorClassName() - Method in enum org.apache.flume.conf.channel.ChannelSelectorType
 
getChannelSelectorConfigurationType() - Method in enum org.apache.flume.conf.channel.ChannelSelectorConfiguration.ChannelSelectorConfigurationType
 
getChannelSet() - Method in class org.apache.flume.conf.FlumeConfiguration.AgentConfiguration
 
getChannelSize(Connection) - Method in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler
 
getChannelSize(Connection) - Method in class org.apache.flume.channel.jdbc.impl.MySQLSchemaHandler
 
getChannelSize(Connection) - Method in interface org.apache.flume.channel.jdbc.impl.SchemaHandler
Returns the current size of the channel using the connection specified that must have an active transaction ongoing.
getChannelSize() - Method in class org.apache.flume.instrumentation.ChannelCounter
 
getChannelSize() - Method in interface org.apache.flume.instrumentation.ChannelCounterMBean
 
getChannelSize() - Method in interface org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
 
getCheckpointPosition() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
required sfixed64 checkpointPosition = 3;
getCheckpointPosition() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
required sfixed64 checkpointPosition = 3;
getCheckpointPosition() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
required sfixed64 checkpointPosition = 3;
getCheckpointWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
required sfixed64 checkpointWriteOrderID = 4;
getCheckpointWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
required sfixed64 checkpointWriteOrderID = 4;
getCheckpointWriteOrderID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
required sfixed64 checkpointWriteOrderID = 4;
getChecksum() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
optional sfixed64 checksum = 2;
getChecksum() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put
optional sfixed64 checksum = 2;
getChecksum() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.PutOrBuilder
optional sfixed64 checksum = 2;
getCipherProvider() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
required string cipherProvider = 1;
getCipherProvider() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
required string cipherProvider = 1;
getCipherProvider() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder
required string cipherProvider = 1;
getCipherProviderBytes() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
required string cipherProvider = 1;
getCipherProviderBytes() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
required string cipherProvider = 1;
getCipherProviderBytes() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder
required string cipherProvider = 1;
getClass(String) - Method in class org.apache.flume.channel.DefaultChannelFactory
 
getClass(String) - Method in interface org.apache.flume.ChannelFactory
 
getClass(String) - Method in class org.apache.flume.sink.DefaultSinkFactory
 
getClass(String) - Method in interface org.apache.flume.SinkFactory
 
getClass(String) - Method in class org.apache.flume.source.DefaultSourceFactory
 
getClass(String) - Method in interface org.apache.flume.SourceFactory
 
getClassInstance() - Method in enum org.apache.flume.tools.FlumeToolType
 
getClient(TProtocol) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Client.Factory
 
getClient(TProtocol, TProtocol) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.Client.Factory
 
getClient(String, String[], String, ElasticSearchEventSerializer, ElasticSearchIndexRequestBuilderFactory) - Method in class org.apache.flume.sink.elasticsearch.client.ElasticSearchClientFactory
 
getClient(TProtocol) - Method in class org.apache.flume.source.scribe.Scribe.Client.Factory
 
getClient(TProtocol, TProtocol) - Method in class org.apache.flume.source.scribe.Scribe.Client.Factory
 
getClient(TProtocol) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.Client.Factory
 
getClient(TProtocol, TProtocol) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.Client.Factory
 
getClientClassName() - Method in enum org.apache.flume.api.RpcClientFactory.ClientType
 
getClock() - Static method in class org.apache.flume.formatter.output.BucketPath
 
getCode() - Method in enum org.apache.flume.channel.jdbc.TransactionIsolation
 
getCodec() - Method in class org.apache.flume.channel.file.encryption.CipherProvider.Decryptor
 
getCodec() - Method in class org.apache.flume.channel.file.encryption.CipherProvider.Encryptor
 
getCommittedCount() - Method in class org.apache.flume.channel.file.Log
 
getComponentName() - Method in class org.apache.flume.conf.ComponentConfiguration
 
getComponentName() - Method in class org.apache.flume.conf.FlumeConfiguration.ComponentNameAndConfigKey
 
getComponentName() - Method in class org.apache.flume.conf.FlumeConfigurationError
 
getComponentType() - Method in enum org.apache.flume.conf.ComponentConfiguration.ComponentType
 
getConfig() - Method in class org.apache.flume.sink.hbase.HBaseSink
 
getConfigKey() - Method in class org.apache.flume.conf.FlumeConfiguration.ComponentNameAndConfigKey
 
getConfiguration(String) - Method in enum org.apache.flume.conf.channel.ChannelConfiguration.ChannelConfigurationType
 
getConfiguration(String) - Method in enum org.apache.flume.conf.channel.ChannelSelectorConfiguration.ChannelSelectorConfigurationType
 
getConfiguration(String) - Method in enum org.apache.flume.conf.sink.SinkConfiguration.SinkConfigurationType
 
getConfiguration(String) - Method in enum org.apache.flume.conf.sink.SinkProcessorConfiguration.SinkProcessorConfigurationType
 
getConfiguration(String) - Method in enum org.apache.flume.conf.source.SourceConfiguration.SourceConfigurationType
 
getConfiguration() - Method in class org.apache.flume.node.AbstractConfigurationProvider
 
getConfiguration() - Method in interface org.apache.flume.node.ConfigurationProvider
 
getConfigurationErrors() - Method in class org.apache.flume.conf.FlumeConfiguration
 
getConfigurationFor(String) - Method in class org.apache.flume.conf.FlumeConfiguration
 
getConnection() - Method in class org.apache.flume.channel.jdbc.impl.JdbcTransactionImpl
 
getConnectionClosedCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean
 
getConnectionClosedCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
getConnectionClosedCount() - Method in interface org.apache.flume.instrumentation.SinkCounterMBean
 
getConnectionCreatedCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean
 
getConnectionCreatedCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
getConnectionCreatedCount() - Method in interface org.apache.flume.instrumentation.SinkCounterMBean
 
getConnectionFailedCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean
 
getConnectionFailedCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
getConnectionFailedCount() - Method in interface org.apache.flume.instrumentation.SinkCounterMBean
 
getConsumerProps() - Method in class org.apache.flume.channel.kafka.KafkaChannel
 
getContentBuilder(Event) - Method in class org.apache.flume.sink.elasticsearch.ElasticSearchDynamicSerializer
 
getContentBuilder(Event) - Method in interface org.apache.flume.sink.elasticsearch.ElasticSearchEventSerializer
Return an BytesStream made up of the serialized flume event
getContentBuilder(Event) - Method in class org.apache.flume.sink.elasticsearch.ElasticSearchLogStashEventSerializer
 
getCount() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
required sfixed32 count = 2;
getCount() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog
required sfixed32 count = 2;
getCount() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder
required sfixed32 count = 2;
getCounter(String) - Method in class org.apache.flume.CounterGroup
 
getCounter() - Method in class org.apache.flume.sink.hive.HiveSink
 
getCounters() - Method in class org.apache.flume.CounterGroup
 
getCurrentFile() - Method in class org.apache.flume.formatter.output.DefaultPathManager
 
getCurrentFile() - Method in interface org.apache.flume.formatter.output.PathManager
 
getDate() - Static method in class org.apache.flume.tools.VersionInfo
The date that Flume was compiled.
getDecrypter(String, Key, byte[]) - Static method in class org.apache.flume.channel.file.encryption.CipherProviderFactory
 
getDefaultInstance(String, Integer) - Static method in class org.apache.flume.api.RpcClientFactory
Returns an instance of RpcClient connected to the specified hostname and port.
getDefaultInstance(String, Integer, Integer) - Static method in class org.apache.flume.api.RpcClientFactory
Returns an instance of RpcClient connected to the specified hostname and port with the specified batchSize.
getDefaultInstance() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog
 
getDefaultInstance() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
 
getDefaultInstance() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit
 
getDefaultInstance() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
 
getDefaultInstance() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
 
getDefaultInstance() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
 
getDefaultInstance() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
 
getDefaultInstance() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Put
 
getDefaultInstance() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback
 
getDefaultInstance() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Take
 
getDefaultInstance() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter
 
getDefaultInstance() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit.Builder
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback.Builder
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter.Builder
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
 
getDefaultInstanceForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
 
getDepth() - Method in class org.apache.flume.channel.file.FileChannel
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit.Builder
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Put
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback.Builder
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.Take
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter.Builder
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
 
getDescriptor() - Static method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
 
getDescriptorForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
 
getDescriptorForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
 
getDescriptorForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit.Builder
 
getDescriptorForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
 
getDescriptorForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
 
getDescriptorForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
 
getDescriptorForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
 
getDescriptorForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
 
getDescriptorForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback.Builder
 
getDescriptorForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
 
getDescriptorForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter.Builder
 
getDescriptorForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
 
getDfs(Configuration, Path) - Method in class org.apache.flume.sink.hdfs.HDFSDataStream
 
getDirectMemorySize() - Static method in class org.apache.flume.tools.DirectMemoryUtils
 
getDirectory() - Method in class org.apache.flume.sink.RollingFileSink
 
getEncrypter(String, Key) - Static method in class org.apache.flume.channel.file.encryption.CipherProviderFactory
 
getEncryption() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
optional .LogFileEncryption encryption = 5;
getEncryption() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
optional .LogFileEncryption encryption = 5;
getEncryption() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
optional .LogFileEncryption encryption = 5;
getEncryptionBuilder() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
optional .LogFileEncryption encryption = 5;
getEncryptionOrBuilder() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
optional .LogFileEncryption encryption = 5;
getEncryptionOrBuilder() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
optional .LogFileEncryption encryption = 5;
getEncryptionOrBuilder() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
optional .LogFileEncryption encryption = 5;
getError() - Method in enum org.apache.flume.conf.FlumeConfigurationErrorType
 
getErrorOrWarning() - Method in class org.apache.flume.conf.FlumeConfigurationError
 
getErrors() - Method in class org.apache.flume.conf.ComponentConfiguration
 
getErrorType() - Method in class org.apache.flume.conf.FlumeConfigurationError
 
getEscapeMapping(String, Map<String, String>) - Static method in class org.apache.flume.formatter.output.BucketPath
Deprecated.
getEscapeMapping(String, Map<String, String>, boolean, int, int) - Static method in class org.apache.flume.formatter.output.BucketPath
Deprecated.
getEvent() - Method in class org.apache.flume.channel.file.LogRecord
 
getEvent() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
required .FlumeEvent event = 1;
getEvent() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put
required .FlumeEvent event = 1;
getEvent() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.PutOrBuilder
required .FlumeEvent event = 1;
getEvent() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_args
 
getEventAcceptedCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean
 
getEventAcceptedCount() - Method in class org.apache.flume.instrumentation.SourceCounter
 
getEventAcceptedCount() - Method in interface org.apache.flume.instrumentation.SourceCounterMBean
 
getEventBuilder() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
required .FlumeEvent event = 1;
getEventDrainAttemptCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean
 
getEventDrainAttemptCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
getEventDrainAttemptCount() - Method in interface org.apache.flume.instrumentation.SinkCounterMBean
 
getEventDrainSuccessCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean
 
getEventDrainSuccessCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
getEventDrainSuccessCount() - Method in interface org.apache.flume.instrumentation.SinkCounterMBean
 
getEventFromTransactionEvent(TransactionEventRecord) - Static method in class org.apache.flume.channel.file.EventUtils
Returns the Event encapsulated by a Put wrapper
getEventId() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent
 
getEventOrBuilder() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
required .FlumeEvent event = 1;
getEventOrBuilder() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put
required .FlumeEvent event = 1;
getEventOrBuilder() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.PutOrBuilder
required .FlumeEvent event = 1;
getEventPutAttemptCount() - Method in class org.apache.flume.instrumentation.ChannelCounter
 
getEventPutAttemptCount() - Method in interface org.apache.flume.instrumentation.ChannelCounterMBean
 
getEventPutAttemptCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
 
getEventPutSuccessCount() - Method in class org.apache.flume.instrumentation.ChannelCounter
 
getEventPutSuccessCount() - Method in interface org.apache.flume.instrumentation.ChannelCounterMBean
 
getEventPutSuccessCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
 
getEventReceivedCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean
 
getEventReceivedCount() - Method in class org.apache.flume.instrumentation.SourceCounter
 
getEventReceivedCount() - Method in interface org.apache.flume.instrumentation.SourceCounterMBean
 
getEvents(HttpServletRequest) - Method in class org.apache.flume.sink.solr.morphline.BlobHandler
 
getEvents(HttpServletRequest) - Method in class org.apache.flume.source.http.BLOBHandler
Takes an HttpServletRequest and returns a list of Flume Events.
getEvents(HttpServletRequest) - Method in interface org.apache.flume.source.http.HTTPSourceHandler
Takes an HttpServletRequest and returns a list of Flume Events.
getEvents(HttpServletRequest) - Method in class org.apache.flume.source.http.JSONHandler
Takes an HttpServletRequest and returns a list of Flume Events.
getEvents() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
 
getEventsIterator() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
 
getEventSize() - Method in class org.apache.flume.source.SyslogUtils
 
getEventsSize() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
 
getEventTakeAttemptCount() - Method in class org.apache.flume.instrumentation.ChannelCounter
 
getEventTakeAttemptCount() - Method in interface org.apache.flume.instrumentation.ChannelCounterMBean
 
getEventTakeAttemptCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
 
getEventTakeSuccessCount() - Method in class org.apache.flume.instrumentation.ChannelCounter
 
getEventTakeSuccessCount() - Method in interface org.apache.flume.instrumentation.ChannelCounterMBean
 
getEventTakeSuccessCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
 
getEvt() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args
 
getExtension() - Method in class org.apache.flume.formatter.output.DefaultPathManager
 
getFieldName() - Method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEvent._Fields
 
getFieldName() - Method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args._Fields
 
getFieldName() - Method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args._Fields
 
getFieldName() - Method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result._Fields
 
getFieldName() - Method in enum org.apache.flume.source.scribe.LogEntry._Fields
 
getFieldName() - Method in enum org.apache.flume.source.scribe.Scribe.Log_args._Fields
 
getFieldName() - Method in enum org.apache.flume.source.scribe.Scribe.Log_result._Fields
 
getFieldName() - Method in enum org.apache.flume.thrift.ThriftFlumeEvent._Fields
 
getFieldName() - Method in enum org.apache.flume.thrift.ThriftSourceProtocol.append_args._Fields
 
getFieldName() - Method in enum org.apache.flume.thrift.ThriftSourceProtocol.append_result._Fields
 
getFieldName() - Method in enum org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args._Fields
 
getFieldName() - Method in enum org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result._Fields
 
getFields() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
getFieldsSize() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
getFieldValue(ThriftFlumeEvent._Fields) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
getFieldValue(ThriftFlumeEventServer.append_args._Fields) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args
 
getFieldValue(ThriftFlumeEventServer.close_args._Fields) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args
 
getFieldValue(ThriftFlumeEventServer.close_result._Fields) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result
 
getFieldValue(LogEntry._Fields) - Method in class org.apache.flume.source.scribe.LogEntry
 
getFieldValue(Scribe.Log_args._Fields) - Method in class org.apache.flume.source.scribe.Scribe.Log_args
 
getFieldValue(Scribe.Log_result._Fields) - Method in class org.apache.flume.source.scribe.Scribe.Log_result
 
getFieldValue(ThriftFlumeEvent._Fields) - Method in class org.apache.flume.thrift.ThriftFlumeEvent
 
getFieldValue(ThriftSourceProtocol.append_args._Fields) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_args
 
getFieldValue(ThriftSourceProtocol.append_result._Fields) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_result
 
getFieldValue(ThriftSourceProtocol.appendBatch_args._Fields) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
 
getFieldValue(ThriftSourceProtocol.appendBatch_result._Fields) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result
 
getFileGroup() - Method in class org.apache.flume.source.taildir.TaildirMatcher
 
getFileHandle() - Method in class org.apache.flume.channel.file.LogFile.SequentialReader
 
getFileID() - Method in class org.apache.flume.channel.file.LogRecord
 
getFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
required sfixed32 fileID = 1;
getFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take
required sfixed32 fileID = 1;
getFileID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.TakeOrBuilder
required sfixed32 fileID = 1;
getFileIndex() - Method in class org.apache.flume.formatter.output.DefaultPathManager
 
getFlumeConfiguration() - Method in class org.apache.flume.node.AbstractConfigurationProvider
 
getFlumeConfiguration() - Method in class org.apache.flume.node.PollingZooKeeperConfigurationProvider
 
getFlumeConfiguration() - Method in class org.apache.flume.node.PropertiesFileConfigurationProvider
 
getFlumeConfiguration() - Method in class org.apache.flume.node.StaticZooKeeperConfigurationProvider
 
getFsDesiredReplication() - Method in class org.apache.flume.sink.hdfs.AbstractHDFSWriter
 
getHandler(DatabaseType, DataSource) - Static method in class org.apache.flume.channel.jdbc.impl.SchemaHandlerFactory
 
getHeaderEntries() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent
 
getHeaders(int) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
getHeaders(int) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
repeated .FlumeEventHeader headers = 1;
getHeaders(int) - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder
repeated .FlumeEventHeader headers = 1;
getHeaders() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent
 
getHeaders() - Method in interface org.apache.flume.Event
Returns a map of name-value pairs describing the data stored in the body.
getHeaders() - Method in class org.apache.flume.event.JSONEvent
 
getHeaders() - Method in class org.apache.flume.event.SimpleEvent
 
getHeaders() - Method in class org.apache.flume.source.taildir.TailFile
 
getHeaders() - Method in class org.apache.flume.thrift.ThriftFlumeEvent
 
getHeadersBuilder(int) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
getHeadersBuilderList() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
getHeadersCount() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
getHeadersCount() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
repeated .FlumeEventHeader headers = 1;
getHeadersCount() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder
repeated .FlumeEventHeader headers = 1;
getHeadersList() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
getHeadersList() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
repeated .FlumeEventHeader headers = 1;
getHeadersList() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder
repeated .FlumeEventHeader headers = 1;
getHeadersOrBuilder(int) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
getHeadersOrBuilder(int) - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
repeated .FlumeEventHeader headers = 1;
getHeadersOrBuilder(int) - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder
repeated .FlumeEventHeader headers = 1;
getHeadersOrBuilderList() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
repeated .FlumeEventHeader headers = 1;
getHeadersOrBuilderList() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
repeated .FlumeEventHeader headers = 1;
getHeadersOrBuilderList() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder
repeated .FlumeEventHeader headers = 1;
getHeadersSize() - Method in class org.apache.flume.thrift.ThriftFlumeEvent
 
getHost() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
getHostInfoList(Properties) - Static method in class org.apache.flume.api.HostInfo
 
getHostName() - Method in class org.apache.flume.api.HostInfo
 
getId() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.HeaderEntry
 
getIncrements() - Method in interface org.apache.flume.sink.hbase.AsyncHbaseEventSerializer
Get the increments that should be made in hbase as a result of this event.
getIncrements() - Method in interface org.apache.flume.sink.hbase.HbaseEventSerializer
 
getIncrements() - Method in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
 
getIncrements() - Method in class org.apache.flume.sink.hbase.SimpleAsyncHbaseEventSerializer
 
getIncrements() - Method in class org.apache.flume.sink.hbase.SimpleHbaseEventSerializer
 
getIndexList() - Method in class org.apache.flume.util.OrderSelector
 
getIndexName(String, long) - Method in class org.apache.flume.sink.elasticsearch.AbstractElasticSearchIndexRequestBuilderFactory
Gets the name of the index to use for an index request
getIndexName(Event) - Method in interface org.apache.flume.sink.elasticsearch.IndexNameBuilder
Gets the name of the index to use for an index request
getIndexName(Event) - Method in class org.apache.flume.sink.elasticsearch.SimpleIndexNameBuilder
 
getIndexName(Event) - Method in class org.apache.flume.sink.elasticsearch.TimeBasedIndexNameBuilder
Gets the name of the index to use for an index request
getIndexPrefix(Event) - Method in interface org.apache.flume.sink.elasticsearch.IndexNameBuilder
Gets the prefix of index to use for an index request.
getIndexPrefix(Event) - Method in class org.apache.flume.sink.elasticsearch.SimpleIndexNameBuilder
 
getIndexPrefix(Event) - Method in class org.apache.flume.sink.elasticsearch.TimeBasedIndexNameBuilder
 
getInode() - Method in class org.apache.flume.source.taildir.TailFile
 
getInstance(Properties) - Static method in class org.apache.flume.api.RpcClientFactory
Returns an instance of RpcClient, optionally with failover.
getInstance(File) - Static method in class org.apache.flume.api.RpcClientFactory
Delegates to RpcClientFactory.getInstance(Properties props), given a File path to a Properties file.
getInstance(String, Integer) - Static method in class org.apache.flume.api.RpcClientFactory
Deprecated. 
getInstance(String, Integer, Integer) - Static method in class org.apache.flume.api.RpcClientFactory
Deprecated. 
getInstance(String, Context) - Static method in class org.apache.flume.channel.file.encryption.KeyProviderFactory
 
getInstance(String, Context) - Static method in class org.apache.flume.formatter.output.PathManagerFactory
 
getInstance(File, String) - Static method in class org.apache.flume.serialization.DurablePositionTracker
If the file exists at startup, then read it, roll it, and open a new one.
getInstance(String, Context, ResettableInputStream) - Static method in class org.apache.flume.serialization.EventDeserializerFactory
 
getInstance(String, Context, OutputStream) - Static method in class org.apache.flume.serialization.EventSerializerFactory
 
getInteger(String, Integer) - Method in class org.apache.flume.Context
Gets value mapped to key, returning defaultValue if unmapped.
getInteger(String) - Method in class org.apache.flume.Context
Gets value mapped to key, returning null if unmapped.
GetJavaProperty - Class in org.apache.flume.tools
A generic way for querying Java properties.
GetJavaProperty() - Constructor for class org.apache.flume.tools.GetJavaProperty
 
getKafkaCommitTimer() - Method in class org.apache.flume.instrumentation.kafka.KafkaChannelCounter
 
getKafkaCommitTimer() - Method in interface org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
 
getKafkaCommitTimer() - Method in class org.apache.flume.instrumentation.kafka.KafkaSourceCounter
 
getKafkaCommitTimer() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean
 
getKafkaEmptyCount() - Method in class org.apache.flume.instrumentation.kafka.KafkaSourceCounter
 
getKafkaEmptyCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean
 
getKafkaEventGetTimer() - Method in class org.apache.flume.instrumentation.kafka.KafkaChannelCounter
 
getKafkaEventGetTimer() - Method in interface org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
 
getKafkaEventGetTimer() - Method in class org.apache.flume.instrumentation.kafka.KafkaSourceCounter
 
getKafkaEventGetTimer() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean
 
getKafkaEventSendTimer() - Method in class org.apache.flume.instrumentation.kafka.KafkaChannelCounter
 
getKafkaEventSendTimer() - Method in interface org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
 
getKafkaEventSendTimer() - Method in class org.apache.flume.instrumentation.kafka.KafkaSinkCounter
 
getKafkaEventSendTimer() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean
 
getKafkaProps() - Method in class org.apache.flume.sink.kafka.KafkaSink
 
getKey(String) - Method in class org.apache.flume.channel.file.encryption.JCEFileKeyProvider
 
getKey(String) - Method in class org.apache.flume.channel.file.encryption.KeyProvider
Returns a non-null Key
getKey() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
required string key = 1;
getKey() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
required string key = 1;
getKey() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeaderOrBuilder
required string key = 1;
getKey() - Method in class org.apache.flume.conf.FlumeConfigurationError
 
getKey() - Method in class org.apache.flume.sink.hdfs.SequenceFileSerializer.Record
 
getKeyAlias() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
required string keyAlias = 2;
getKeyAlias() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
required string keyAlias = 2;
getKeyAlias() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder
required string keyAlias = 2;
getKeyAliasBytes() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
required string keyAlias = 2;
getKeyAliasBytes() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
required string keyAlias = 2;
getKeyAliasBytes() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder
required string keyAlias = 2;
getKeyBytes() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
required string key = 1;
getKeyBytes() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
required string key = 1;
getKeyBytes() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeaderOrBuilder
required string key = 1;
getKeyClass() - Method in class org.apache.flume.sink.hdfs.HDFSTextSerializer
 
getKeyClass() - Method in class org.apache.flume.sink.hdfs.HDFSWritableSerializer
 
getKeyClass() - Method in interface org.apache.flume.sink.hdfs.SequenceFileSerializer
 
getKeyProvider() - Method in class org.apache.flume.channel.file.LogFile.SequentialReader
 
getKeyTab() - Method in class org.apache.flume.auth.KerberosUser
 
getKeyTab() - Method in class org.apache.flume.sink.hdfs.KerberosUser
 
getLastConnectedServerAddress() - Method in class org.apache.flume.api.FailoverRpcClient
Get the last socket address this client connected to.
getLastFileRead() - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader
Return the filename which generated the data from the last successful ReliableSpoolingFileEventReader.readEvents(int) call.
getLastUpdated() - Method in class org.apache.flume.source.taildir.TailFile
 
getLifecycleState() - Method in class org.apache.flume.channel.AbstractChannel
 
getLifecycleState() - Method in interface org.apache.flume.lifecycle.LifecycleAware
Return the current state of the service or component.
getLifecycleState() - Method in class org.apache.flume.lifecycle.LifecycleSupervisor
 
getLifecycleState() - Method in class org.apache.flume.node.PollingPropertiesFileConfigurationProvider
 
getLifecycleState() - Method in class org.apache.flume.node.PollingZooKeeperConfigurationProvider
 
getLifecycleState() - Method in class org.apache.flume.sink.AbstractSink
 
getLifecycleState() - Method in class org.apache.flume.sink.AbstractSinkProcessor
 
getLifecycleState() - Method in class org.apache.flume.sink.AbstractSinkSelector
 
getLifecycleState() - Method in class org.apache.flume.sink.DefaultSinkProcessor
 
getLifecycleState() - Method in class org.apache.flume.SinkRunner
 
getLifecycleState() - Method in class org.apache.flume.source.AbstractSource
 
getLifecycleState() - Method in class org.apache.flume.source.BasicSourceSemantics
 
getLifecycleState() - Method in class org.apache.flume.source.EventDrivenSourceRunner
 
getLifecycleState() - Method in class org.apache.flume.source.PollableSourceRunner
 
getLineReadPos() - Method in class org.apache.flume.source.taildir.TailFile
 
getLocalClient(String, ElasticSearchEventSerializer, ElasticSearchIndexRequestBuilderFactory) - Method in class org.apache.flume.sink.elasticsearch.client.ElasticSearchClientFactory
Used for tests only.
getLogFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
required sfixed32 logFileID = 1;
getLogFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog
required sfixed32 logFileID = 1;
getLogFileID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder
required sfixed32 logFileID = 1;
getLogFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
required sfixed32 logFileID = 2;
getLogFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
required sfixed32 logFileID = 2;
getLogFileID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
required sfixed32 logFileID = 2;
getLong(String, Long) - Method in class org.apache.flume.Context
Gets value mapped to key, returning defaultValue if unmapped.
getLong(String) - Method in class org.apache.flume.Context
Gets value mapped to key, returning null if unmapped.
getMarkPosition() - Method in interface org.apache.flume.serialization.RemoteMarkable
Return the saved mark position without moving the mark pointer.
getMarkPosition() - Method in class org.apache.flume.serialization.ResettableFileInputStream
 
getMaxBackOffSleepInterval() - Method in interface org.apache.flume.PollableSource
 
getMaxBackOffSleepInterval() - Method in class org.apache.flume.source.AbstractPollableSource
 
getMaxBackOffSleepInterval() - Method in class org.apache.flume.source.taildir.TaildirSource
 
getMaxMemQueueSize() - Method in class org.apache.flume.channel.SpillableMemoryChannel
 
getMaxTimeOut() - Method in class org.apache.flume.util.OrderSelector
 
getMaxTries() - Method in class org.apache.flume.api.FailoverRpcClient
Get the maximum number of "failed" hosts the client will try to establish connection to before throwing an exception.
getMemoryCapacity() - Method in class org.apache.flume.channel.SpillableMemoryChannel
 
getMessage() - Method in class org.apache.flume.source.scribe.LogEntry
 
getMessages() - Method in class org.apache.flume.source.scribe.Scribe.Log_args
 
getMessagesIterator() - Method in class org.apache.flume.source.scribe.Scribe.Log_args
 
getMessagesSize() - Method in class org.apache.flume.source.scribe.Scribe.Log_args
 
getMonitorClass() - Method in enum org.apache.flume.instrumentation.MonitoringType
 
getName() - Method in class org.apache.flume.channel.AbstractChannel
 
getName() - Method in class org.apache.flume.channel.AbstractChannelSelector
 
getName() - Method in enum org.apache.flume.channel.jdbc.DatabaseType
 
getName() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.HeaderEntry
 
getName() - Method in enum org.apache.flume.channel.jdbc.TransactionIsolation
 
getName() - Method in enum org.apache.flume.clients.log4jappender.Log4jAvroHeaders
 
getName() - Method in class org.apache.flume.CounterGroup
 
getName() - Method in interface org.apache.flume.NamedComponent
 
getName() - Method in class org.apache.flume.sink.AbstractSink
 
getName() - Method in class org.apache.flume.source.AbstractSource
 
getName() - Method in class org.apache.flume.source.BasicSourceSemantics
 
getNames() - Static method in enum org.apache.flume.tools.FlumeToolType
 
getNameString() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.HeaderEntry
 
getNanos() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
getNanoTimestampKey(String) - Static method in class org.apache.flume.sink.hbase.SimpleRowKeyGenerator
 
getNumCurrentReplicas() - Method in class org.apache.flume.sink.hdfs.AbstractHDFSWriter
This method gets the datanode replication count for the current open file.
getObjects() - Method in class org.apache.flume.util.OrderSelector
Get the list of objects to be ordered.
getOffset() - Method in class org.apache.flume.channel.file.LogRecord
 
getOffset() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
required sfixed32 offset = 2;
getOffset() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take
required sfixed32 offset = 2;
getOffset() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.TakeOrBuilder
required sfixed32 offset = 2;
getOpenConnectionCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean
 
getOpenConnectionCount() - Method in class org.apache.flume.instrumentation.SourceCounter
 
getOpenConnectionCount() - Method in interface org.apache.flume.instrumentation.SourceCounterMBean
 
getOptionalChannels(Event) - Method in class org.apache.flume.channel.MultiplexingChannelSelector
 
getOptionalChannels(Event) - Method in class org.apache.flume.channel.ReplicatingChannelSelector
 
getOptionalChannels(Event) - Method in interface org.apache.flume.ChannelSelector
Returns a list of optional channels.
getOutputStream() - Method in class org.apache.flume.serialization.AbstractAvroEventSerializer
Returns the stream to serialize data into.
getOutputStream() - Method in class org.apache.flume.serialization.FlumeEventAvroEventSerializer
 
getOverflowCapacity() - Method in class org.apache.flume.channel.SpillableMemoryChannel
 
getOverflowTimeout() - Method in class org.apache.flume.channel.SpillableMemoryChannel
 
getParameters() - Method in class org.apache.flume.channel.file.encryption.CipherProvider.Encryptor
 
getParameters() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
optional bytes parameters = 3;
getParameters() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
optional bytes parameters = 3;
getParameters() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder
optional bytes parameters = 3;
getParameters() - Method in class org.apache.flume.Context
Gets a copy of the backing map structure.
getParserForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog
 
getParserForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
 
getParserForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit
 
getParserForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
 
getParserForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
 
getParserForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
 
getParserForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
 
getParserForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put
 
getParserForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback
 
getParserForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take
 
getParserForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter
 
getParserForType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
 
getPath() - Method in class org.apache.flume.source.taildir.TailFile
 
getPolicy() - Method in class org.apache.flume.SinkRunner
 
getPollFrequency() - Method in class org.apache.flume.instrumentation.GangliaServer
 
getPortNumber() - Method in class org.apache.flume.api.HostInfo
 
getPos() - Method in class org.apache.flume.source.taildir.TailFile
 
getPosition() - Method in class org.apache.flume.channel.file.LogFile.SequentialReader
 
getPosition() - Method in class org.apache.flume.serialization.DurablePositionTracker
 
getPosition() - Method in interface org.apache.flume.serialization.PositionTracker
 
getPostvalidationConfig() - Method in class org.apache.flume.conf.FlumeConfiguration.AgentConfiguration
 
getPrefix() - Method in class org.apache.flume.formatter.output.DefaultPathManager
 
getPrefix() - Method in class org.apache.flume.sink.solr.morphline.UUIDInterceptor
 
getPrevalidationConfig() - Method in class org.apache.flume.conf.FlumeConfiguration.AgentConfiguration
 
getPrincipal() - Method in class org.apache.flume.auth.KerberosUser
 
getPrincipal() - Method in class org.apache.flume.sink.hdfs.KerberosUser
 
getPriority() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
getProcessor() - Method in class org.apache.flume.sink.SinkGroup
 
getProcessor(Context, List<Sink>) - Static method in class org.apache.flume.sink.SinkProcessorFactory
Creates a sink processor and configures it using the provided context
getProcessor(ComponentConfiguration, List<Sink>) - Static method in class org.apache.flume.sink.SinkProcessorFactory
 
getProcessorContext() - Method in class org.apache.flume.conf.sink.SinkGroupConfiguration
 
getProducerProps() - Method in class org.apache.flume.channel.kafka.KafkaChannel
 
getProvider(Context, String) - Static method in class org.apache.flume.channel.jdbc.JdbcChannelProviderFactory
 
getProviderClass() - Method in enum org.apache.flume.channel.file.encryption.CipherProviderType
 
getPutCount() - Method in class org.apache.flume.channel.file.Log
 
getQueueHead() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
required sfixed32 queueHead = 4;
getQueueHead() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
required sfixed32 queueHead = 4;
getQueueHead() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
required sfixed32 queueHead = 4;
getQueueSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
required sfixed32 queueSize = 3;
getQueueSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
required sfixed32 queueSize = 3;
getQueueSize() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
required sfixed32 queueSize = 3;
getRaf() - Method in class org.apache.flume.source.taildir.TailFile
 
getRandomKey(String) - Static method in class org.apache.flume.sink.hbase.SimpleRowKeyGenerator
 
getReadCount() - Method in class org.apache.flume.channel.file.Log
 
getRecursiveDirectorySearch() - Method in class org.apache.flume.source.SpoolDirectorySource
 
getReferenceName() - Method in class org.apache.flume.api.HostInfo
 
getRequiredChannels(Event) - Method in class org.apache.flume.channel.MultiplexingChannelSelector
 
getRequiredChannels(Event) - Method in class org.apache.flume.channel.ReplicatingChannelSelector
 
getRequiredChannels(Event) - Method in interface org.apache.flume.ChannelSelector
Returns a list of required channels.
getResult() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncClient.append_call
 
getResult() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.AsyncClient.close_call
 
getResult() - Method in class org.apache.flume.source.scribe.Scribe.AsyncClient.Log_call
 
getResult() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.AsyncClient.append_call
 
getResult() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.AsyncClient.appendBatch_call
 
getRevision() - Static method in class org.apache.flume.tools.VersionInfo
Get the subversion revision number for the root directory
getRollbackCount() - Method in class org.apache.flume.channel.file.Log
 
getRollbackCount() - Method in class org.apache.flume.instrumentation.kafka.KafkaChannelCounter
 
getRollbackCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
 
getRollbackCount() - Method in class org.apache.flume.instrumentation.kafka.KafkaSinkCounter
 
getRollbackCount() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean
 
getRollInterval() - Method in class org.apache.flume.sink.RollingFileSink
 
getRowKey(Calendar) - Method in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
Returns a row-key with the following format: [time in millis]-[random key]-[nonce]
getRowKey() - Method in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
 
getSaslGssCallbackHandler() - Static method in class org.apache.flume.auth.FlumeAuthenticationUtil
Returns the standard SaslGssCallbackHandler from the hadoop common module
getSchema() - Method in class org.apache.flume.serialization.AbstractAvroEventSerializer
Returns the parsed Avro schema corresponding to the data being written and the parameterized type specified.
getSchema() - Method in class org.apache.flume.serialization.FlumeEventAvroEventSerializer
 
getSelector() - Method in class org.apache.flume.channel.ChannelProcessor
 
getSelectorConfiguration() - Method in class org.apache.flume.conf.source.SourceConfiguration
 
getSerializedSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog
 
getSerializedSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
 
getSerializedSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit
 
getSerializedSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
 
getSerializedSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
 
getSerializedSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
 
getSerializedSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
 
getSerializedSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put
 
getSerializedSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback
 
getSerializedSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take
 
getSerializedSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter
 
getSerializedSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
 
getSeriesTimestamp() - Method in class org.apache.flume.formatter.output.DefaultPathManager
 
getSimpleDateFormat(String) - Static method in class org.apache.flume.formatter.output.BucketPath
 
getSinkClassName() - Method in enum org.apache.flume.conf.sink.SinkType
 
getSinkConfigMap() - Method in class org.apache.flume.conf.FlumeConfiguration.AgentConfiguration
 
getSinkConfigurationType() - Method in enum org.apache.flume.conf.sink.SinkConfiguration.SinkConfigurationType
 
getSinkContext() - Method in class org.apache.flume.conf.FlumeConfiguration.AgentConfiguration
 
getSinkGroupConfigMap() - Method in class org.apache.flume.conf.FlumeConfiguration.AgentConfiguration
 
getSinkgroupSet() - Method in class org.apache.flume.conf.FlumeConfiguration.AgentConfiguration
 
getSinkProcessorClassName() - Method in enum org.apache.flume.conf.sink.SinkProcessorType
 
getSinkProcessorConfiguration() - Method in class org.apache.flume.conf.sink.SinkGroupConfiguration
 
getSinkProcessorConfigurationType() - Method in enum org.apache.flume.conf.sink.SinkProcessorConfiguration.SinkProcessorConfigurationType
 
getSinkRunners() - Method in interface org.apache.flume.node.MaterializedConfiguration
 
getSinkRunners() - Method in class org.apache.flume.node.SimpleMaterializedConfiguration
 
getSinks() - Method in class org.apache.flume.conf.sink.SinkGroupConfiguration
 
getSinks() - Method in class org.apache.flume.conf.sink.SinkProcessorConfiguration
 
getSinks() - Method in class org.apache.flume.sink.AbstractSinkProcessor
 
getSinks() - Method in class org.apache.flume.sink.AbstractSinkSelector
 
getSinkSet() - Method in class org.apache.flume.conf.FlumeConfiguration.AgentConfiguration
 
getSource() - Method in class org.apache.flume.SourceRunner
 
getSourceClassName() - Method in enum org.apache.flume.conf.source.SourceType
 
getSourceConfigMap() - Method in class org.apache.flume.conf.FlumeConfiguration.AgentConfiguration
 
getSourceConfigurationType() - Method in enum org.apache.flume.conf.source.SourceConfiguration.SourceConfigurationType
 
getSourceContext() - Method in class org.apache.flume.conf.FlumeConfiguration.AgentConfiguration
 
getSourceCounter() - Method in class org.apache.flume.source.SpoolDirectorySource
 
getSourceCounter() - Method in class org.apache.flume.source.taildir.TaildirSource
 
getSourceRunners() - Method in interface org.apache.flume.node.MaterializedConfiguration
 
getSourceRunners() - Method in class org.apache.flume.node.SimpleMaterializedConfiguration
 
getSourceSet() - Method in class org.apache.flume.conf.FlumeConfiguration.AgentConfiguration
 
getSpill() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.SpillableString
 
getSpillPayload() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent
 
getSrcChecksum() - Static method in class org.apache.flume.tools.VersionInfo
Get the checksum of the source files from which Flume was built.
getStartException() - Method in class org.apache.flume.source.BasicSourceSemantics
 
getStartTime() - Method in interface org.apache.flume.instrumentation.ChannelCounterMBean
 
getStartTime() - Method in interface org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
 
getStartTime() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean
 
getStartTime() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean
 
getStartTime() - Method in class org.apache.flume.instrumentation.MonitoredCounterGroup
Returns when this component was first started
getStartTime() - Method in interface org.apache.flume.instrumentation.SinkCounterMBean
 
getStartTime() - Method in interface org.apache.flume.instrumentation.SourceCounterMBean
 
getState() - Method in class org.apache.flume.channel.BasicTransactionSemantics
 
getStopTime() - Method in interface org.apache.flume.instrumentation.ChannelCounterMBean
 
getStopTime() - Method in interface org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
 
getStopTime() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean
 
getStopTime() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean
 
getStopTime() - Method in class org.apache.flume.instrumentation.MonitoredCounterGroup
Returns when this component was stopped
getStopTime() - Method in interface org.apache.flume.instrumentation.SinkCounterMBean
 
getStopTime() - Method in interface org.apache.flume.instrumentation.SourceCounterMBean
 
getString() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.SpillableString
 
getString(String, String) - Method in class org.apache.flume.Context
Gets value mapped to key, returning defaultValue if unmapped.
getString(String) - Method in class org.apache.flume.Context
Gets value mapped to key, returning null if unmapped.
getSubProperties(String) - Method in class org.apache.flume.Context
Get properties which start with a prefix.
getSuccess() - Method in class org.apache.flume.source.scribe.Scribe.Log_result
 
getSuccess() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_result
 
getSuccess() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result
 
getSyslogStatus() - Method in enum org.apache.flume.source.SyslogUtils.SyslogStatus
 
getTailFiles() - Method in class org.apache.flume.source.taildir.ReliableTaildirEventReader
 
getTakeCount() - Method in class org.apache.flume.channel.file.Log
 
getTarget() - Method in class org.apache.flume.serialization.DurablePositionTracker
 
getTarget() - Method in interface org.apache.flume.serialization.PositionTracker
 
getThriftFieldId() - Method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEvent._Fields
 
getThriftFieldId() - Method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args._Fields
 
getThriftFieldId() - Method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args._Fields
 
getThriftFieldId() - Method in enum com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result._Fields
 
getThriftFieldId() - Method in enum org.apache.flume.source.scribe.LogEntry._Fields
 
getThriftFieldId() - Method in enum org.apache.flume.source.scribe.Scribe.Log_args._Fields
 
getThriftFieldId() - Method in enum org.apache.flume.source.scribe.Scribe.Log_result._Fields
 
getThriftFieldId() - Method in enum org.apache.flume.thrift.ThriftFlumeEvent._Fields
 
getThriftFieldId() - Method in enum org.apache.flume.thrift.ThriftSourceProtocol.append_args._Fields
 
getThriftFieldId() - Method in enum org.apache.flume.thrift.ThriftSourceProtocol.append_result._Fields
 
getThriftFieldId() - Method in enum org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args._Fields
 
getThriftFieldId() - Method in enum org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result._Fields
 
getThriftInstance(String, Integer, Integer) - Static method in class org.apache.flume.api.RpcClientFactory
Return an RpcClient that uses Thrift for communicating with the next hop.
getThriftInstance(String, Integer) - Static method in class org.apache.flume.api.RpcClientFactory
Return an RpcClient that uses Thrift for communicating with the next hop.
getThriftInstance(Properties) - Static method in class org.apache.flume.api.RpcClientFactory
Return an RpcClient that uses Thrift for communicating with the next hop.
getThriftInstance(Properties) - Static method in class org.apache.flume.api.SecureRpcClientFactory
Return a secure RpcClient that uses Thrift for communicating with the next hop.
getTimeout() - Method in class org.apache.flume.clients.log4jappender.Log4jAppender
 
getTimestamp() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
getTimestampKey(String) - Static method in class org.apache.flume.sink.hbase.SimpleRowKeyGenerator
 
getTopic() - Method in class org.apache.flume.sink.kafka.KafkaSink
 
getTotalStored() - Method in class org.apache.flume.channel.SpillableMemoryChannel
 
getTransaction() - Method in class org.apache.flume.channel.BasicChannelSemantics
Initializes the channel if it is not already, then checks to see if there is an open transaction for this thread, creating a new one via createTransaction if not.
getTransaction() - Method in interface org.apache.flume.Channel
 
getTransaction() - Method in class org.apache.flume.channel.jdbc.impl.JdbcChannelProviderImpl
 
getTransaction() - Method in class org.apache.flume.channel.jdbc.JdbcChannel
 
getTransaction() - Method in interface org.apache.flume.channel.jdbc.JdbcChannelProvider
 
getTransaction() - Method in class org.apache.flume.channel.PseudoTxnMemoryChannel
 
getTransactionID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
required sfixed64 transactionID = 2;
getTransactionID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
required sfixed64 transactionID = 2;
getTransactionID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeaderOrBuilder
required sfixed64 transactionID = 2;
getTransport(TSocket) - Method in class org.apache.flume.api.SecureThriftRpcClient
 
getTransport(TSocket) - Method in class org.apache.flume.api.ThriftRpcClient
 
getType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit.Builder
required sfixed32 type = 1;
getType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit
required sfixed32 type = 1;
getType() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CommitOrBuilder
required sfixed32 type = 1;
getType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
required sfixed32 type = 1;
getType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
required sfixed32 type = 1;
getType() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeaderOrBuilder
required sfixed32 type = 1;
getType() - Method in class org.apache.flume.conf.ComponentConfiguration
 
getType() - Method in interface org.apache.flume.instrumentation.ChannelCounterMBean
 
getType() - Method in interface org.apache.flume.instrumentation.kafka.KafkaChannelCounterMBean
 
getType() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSinkCounterMBean
 
getType() - Method in interface org.apache.flume.instrumentation.kafka.KafkaSourceCounterMBean
 
getType() - Method in class org.apache.flume.instrumentation.MonitoredCounterGroup
 
getType() - Method in interface org.apache.flume.instrumentation.SinkCounterMBean
 
getType() - Method in interface org.apache.flume.instrumentation.SourceCounterMBean
 
getUnknownFields() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog
 
getUnknownFields() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
 
getUnknownFields() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit
 
getUnknownFields() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
 
getUnknownFields() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
 
getUnknownFields() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
 
getUnknownFields() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
 
getUnknownFields() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put
 
getUnknownFields() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback
 
getUnknownFields() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take
 
getUnknownFields() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter
 
getUnknownFields() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
 
getUnsafeMode() - Method in class org.apache.flume.clients.log4jappender.Log4jAppender
 
getUrl() - Static method in class org.apache.flume.tools.VersionInfo
Get the subversion URL for the root Flume directory.
getUser() - Static method in class org.apache.flume.tools.VersionInfo
The user that compiled Flume.
getUUIDKey(String) - Static method in class org.apache.flume.sink.hbase.SimpleRowKeyGenerator
 
getValidationQuery() - Method in enum org.apache.flume.channel.jdbc.DatabaseType
 
getValue() - Method in enum com.cloudera.flume.handlers.thrift.EventStatus
Get the integer value of this enum value, as defined in the Thrift IDL.
getValue() - Method in enum com.cloudera.flume.handlers.thrift.Priority
Get the integer value of this enum value, as defined in the Thrift IDL.
getValue() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
required string value = 2;
getValue() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
required string value = 2;
getValue() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeaderOrBuilder
required string value = 2;
getValue() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.HeaderEntry
 
getValue() - Method in class org.apache.flume.sink.hdfs.SequenceFileSerializer.Record
 
getValue() - Method in enum org.apache.flume.source.scribe.ResultCode
Get the integer value of this enum value, as defined in the Thrift IDL.
getValue() - Method in enum org.apache.flume.thrift.Status
Get the integer value of this enum value, as defined in the Thrift IDL.
getValueBytes() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
required string value = 2;
getValueBytes() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
required string value = 2;
getValueBytes() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeaderOrBuilder
required string value = 2;
getValueClass() - Method in class org.apache.flume.sink.hdfs.HDFSTextSerializer
 
getValueClass() - Method in class org.apache.flume.sink.hdfs.HDFSWritableSerializer
 
getValueClass() - Method in interface org.apache.flume.sink.hdfs.SequenceFileSerializer
 
getValueString() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.HeaderEntry
 
getVersion() - Method in class org.apache.flume.channel.file.LogFileV3.SequentialReader
 
getVersion() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
required sfixed32 version = 1;
getVersion() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
required sfixed32 version = 1;
getVersion() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
required sfixed32 version = 1;
getVersion() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
required sfixed32 version = 1;
getVersion() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
required sfixed32 version = 1;
getVersion() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
required sfixed32 version = 1;
getVersion() - Static method in class org.apache.flume.tools.VersionInfo
Get the Flume version.
getWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
required sfixed64 writeOrderID = 2;
getWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
required sfixed64 writeOrderID = 2;
getWriteOrderID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
required sfixed64 writeOrderID = 2;
getWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
required sfixed64 writeOrderID = 3;
getWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
required sfixed64 writeOrderID = 3;
getWriteOrderID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeaderOrBuilder
required sfixed64 writeOrderID = 3;
getWriter(String) - Method in class org.apache.flume.sink.hdfs.HDFSWriterFactory
 
GROUP_ID_FLUME - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 

H

handle(Event, Throwable) - Method in interface org.apache.flume.sink.kite.policy.FailurePolicy
Handle a non-recoverable event.
handle(Event, Throwable) - Method in class org.apache.flume.sink.kite.policy.RetryPolicy
 
handle(Event, Throwable) - Method in class org.apache.flume.sink.kite.policy.SavePolicy
 
handleConfigurationEvent(MaterializedConfiguration) - Method in class org.apache.flume.node.Application
 
HANDLER_CLASS - Static variable in class org.apache.flume.sink.solr.morphline.MorphlineSink
 
hasBackupCheckpointPosition() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
optional sfixed64 backupCheckpointPosition = 6;
hasBackupCheckpointPosition() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
optional sfixed64 backupCheckpointPosition = 6;
hasBackupCheckpointPosition() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
optional sfixed64 backupCheckpointPosition = 6;
hasBackupCheckpointWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
optional sfixed64 backupCheckpointWriteOrderID = 7;
hasBackupCheckpointWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
optional sfixed64 backupCheckpointWriteOrderID = 7;
hasBackupCheckpointWriteOrderID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
optional sfixed64 backupCheckpointWriteOrderID = 7;
hasBody() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
required bytes body = 2;
hasBody() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
required bytes body = 2;
hasBody() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventOrBuilder
required bytes body = 2;
hasCheckpointPosition() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
required sfixed64 checkpointPosition = 3;
hasCheckpointPosition() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
required sfixed64 checkpointPosition = 3;
hasCheckpointPosition() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
required sfixed64 checkpointPosition = 3;
hasCheckpointWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
required sfixed64 checkpointWriteOrderID = 4;
hasCheckpointWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
required sfixed64 checkpointWriteOrderID = 4;
hasCheckpointWriteOrderID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
required sfixed64 checkpointWriteOrderID = 4;
hasChecksum() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
optional sfixed64 checksum = 2;
hasChecksum() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put
optional sfixed64 checksum = 2;
hasChecksum() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.PutOrBuilder
optional sfixed64 checksum = 2;
hasCipherProvider() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
required string cipherProvider = 1;
hasCipherProvider() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
required string cipherProvider = 1;
hasCipherProvider() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder
required string cipherProvider = 1;
hasCount() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
required sfixed32 count = 2;
hasCount() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog
required sfixed32 count = 2;
hasCount() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder
required sfixed32 count = 2;
hasEncryption() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
optional .LogFileEncryption encryption = 5;
hasEncryption() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
optional .LogFileEncryption encryption = 5;
hasEncryption() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
optional .LogFileEncryption encryption = 5;
hasEvent() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
required .FlumeEvent event = 1;
hasEvent() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put
required .FlumeEvent event = 1;
hasEvent() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.PutOrBuilder
required .FlumeEvent event = 1;
hasFatalError() - Method in class org.apache.flume.source.SpoolDirectorySource
 
hasFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
required sfixed32 fileID = 1;
hasFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take
required sfixed32 fileID = 1;
hasFileID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.TakeOrBuilder
required sfixed32 fileID = 1;
hashCode() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
hashCode() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args
 
hashCode() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args
 
hashCode() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result
 
hashCode() - Method in class org.apache.flume.auth.KerberosUser
 
hashCode() - Method in class org.apache.flume.sink.hdfs.KerberosUser
 
hashCode() - Method in class org.apache.flume.source.scribe.LogEntry
 
hashCode() - Method in class org.apache.flume.source.scribe.Scribe.Log_args
 
hashCode() - Method in class org.apache.flume.source.scribe.Scribe.Log_result
 
hashCode() - Method in class org.apache.flume.source.taildir.TaildirMatcher
 
hashCode() - Method in class org.apache.flume.thrift.ThriftFlumeEvent
 
hashCode() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_args
 
hashCode() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_result
 
hashCode() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
 
hashCode() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result
 
hasKey() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
required string key = 1;
hasKey() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
required string key = 1;
hasKey() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeaderOrBuilder
required string key = 1;
hasKeyAlias() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
required string keyAlias = 2;
hasKeyAlias() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
required string keyAlias = 2;
hasKeyAlias() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder
required string keyAlias = 2;
hasLogFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
required sfixed32 logFileID = 1;
hasLogFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog
required sfixed32 logFileID = 1;
hasLogFileID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.ActiveLogOrBuilder
required sfixed32 logFileID = 1;
hasLogFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
required sfixed32 logFileID = 2;
hasLogFileID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
required sfixed32 logFileID = 2;
hasLogFileID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
required sfixed32 logFileID = 2;
hasNext() - Method in class org.apache.flume.util.SpecificOrderIterator
 
hasOffset() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
required sfixed32 offset = 2;
hasOffset() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take
required sfixed32 offset = 2;
hasOffset() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.TakeOrBuilder
required sfixed32 offset = 2;
hasParameters() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
optional bytes parameters = 3;
hasParameters() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
optional bytes parameters = 3;
hasParameters() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryptionOrBuilder
optional bytes parameters = 3;
hasQueueHead() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
required sfixed32 queueHead = 4;
hasQueueHead() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
required sfixed32 queueHead = 4;
hasQueueHead() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
required sfixed32 queueHead = 4;
hasQueueSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
required sfixed32 queueSize = 3;
hasQueueSize() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
required sfixed32 queueSize = 3;
hasQueueSize() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
required sfixed32 queueSize = 3;
hasSpill() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.SpillableString
 
hasTransactionID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
required sfixed64 transactionID = 2;
hasTransactionID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
required sfixed64 transactionID = 2;
hasTransactionID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeaderOrBuilder
required sfixed64 transactionID = 2;
hasType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit.Builder
required sfixed32 type = 1;
hasType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit
required sfixed32 type = 1;
hasType() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CommitOrBuilder
required sfixed32 type = 1;
hasType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
required sfixed32 type = 1;
hasType() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
required sfixed32 type = 1;
hasType() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeaderOrBuilder
required sfixed32 type = 1;
hasValue() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
required string value = 2;
hasValue() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
required string value = 2;
hasValue() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeaderOrBuilder
required string value = 2;
hasVersion() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
required sfixed32 version = 1;
hasVersion() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
required sfixed32 version = 1;
hasVersion() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
required sfixed32 version = 1;
hasVersion() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
required sfixed32 version = 1;
hasVersion() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
required sfixed32 version = 1;
hasVersion() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaDataOrBuilder
required sfixed32 version = 1;
hasWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
required sfixed64 writeOrderID = 2;
hasWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
required sfixed64 writeOrderID = 2;
hasWriteOrderID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.CheckpointOrBuilder
required sfixed64 writeOrderID = 2;
hasWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
required sfixed64 writeOrderID = 3;
hasWriteOrderID() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
required sfixed64 writeOrderID = 3;
hasWriteOrderID() - Method in interface org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeaderOrBuilder
required sfixed64 writeOrderID = 3;
HbaseEventSerializer - Interface in org.apache.flume.sink.hbase
Interface for an event serializer which serializes the headers and body of an event to write them to hbase.
HBaseSink - Class in org.apache.flume.sink.hbase
A simple sink which reads events from a channel and writes them to HBase.
HBaseSink() - Constructor for class org.apache.flume.sink.hbase.HBaseSink
 
HBaseSink(Configuration) - Constructor for class org.apache.flume.sink.hbase.HBaseSink
 
HBaseSinkConfigurationConstants - Class in org.apache.flume.sink.hbase
Constants used for configuration of HBaseSink and AsyncHBaseSink
HBaseSinkConfigurationConstants() - Constructor for class org.apache.flume.sink.hbase.HBaseSinkConfigurationConstants
 
HDFSCompressedDataStream - Class in org.apache.flume.sink.hdfs
 
HDFSCompressedDataStream() - Constructor for class org.apache.flume.sink.hdfs.HDFSCompressedDataStream
 
HDFSDataStream - Class in org.apache.flume.sink.hdfs
 
HDFSDataStream() - Constructor for class org.apache.flume.sink.hdfs.HDFSDataStream
 
HDFSEventSink - Class in org.apache.flume.sink.hdfs
 
HDFSEventSink() - Constructor for class org.apache.flume.sink.hdfs.HDFSEventSink
 
HDFSEventSink(HDFSWriterFactory) - Constructor for class org.apache.flume.sink.hdfs.HDFSEventSink
 
HDFSEventSink.WriterCallback - Interface in org.apache.flume.sink.hdfs
 
HDFSSequenceFile - Class in org.apache.flume.sink.hdfs
 
HDFSSequenceFile() - Constructor for class org.apache.flume.sink.hdfs.HDFSSequenceFile
 
HDFSTextSerializer - Class in org.apache.flume.sink.hdfs
 
HDFSTextSerializer() - Constructor for class org.apache.flume.sink.hdfs.HDFSTextSerializer
 
HDFSTextSerializer.Builder - Class in org.apache.flume.sink.hdfs
 
HDFSTextSerializer.Builder() - Constructor for class org.apache.flume.sink.hdfs.HDFSTextSerializer.Builder
 
HDFSWritableSerializer - Class in org.apache.flume.sink.hdfs
 
HDFSWritableSerializer() - Constructor for class org.apache.flume.sink.hdfs.HDFSWritableSerializer
 
HDFSWritableSerializer.Builder - Class in org.apache.flume.sink.hdfs
 
HDFSWritableSerializer.Builder() - Constructor for class org.apache.flume.sink.hdfs.HDFSWritableSerializer.Builder
 
HDFSWriter - Interface in org.apache.flume.sink.hdfs
 
HDFSWriterFactory - Class in org.apache.flume.sink.hdfs
 
HDFSWriterFactory() - Constructor for class org.apache.flume.sink.hdfs.HDFSWriterFactory
 
HEADER_NAME - Static variable in class org.apache.flume.sink.solr.morphline.UUIDInterceptor
 
HEADER_NAME_LENGTH_THRESHOLD - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
The length of header name in bytes that will be stored inline.
HEADER_NAME_SPILL_MAX_LENGTH - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
The maximum spill size for header names.
HEADER_VALUE_LENGTH_THRESHOLD - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
The length of header value in bytes that will be stored inline.
HEADER_VALUE_SPILL_MAX_LENGTH - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants
The maximum spill size for header values.
HeaderAndBodyTextEventSerializer - Class in org.apache.flume.serialization
This class simply writes the body of the event to the output stream and appends a newline after each event.
HeaderAndBodyTextEventSerializer.Builder - Class in org.apache.flume.serialization
 
HeaderAndBodyTextEventSerializer.Builder() - Constructor for class org.apache.flume.serialization.HeaderAndBodyTextEventSerializer.Builder
 
headers - Variable in class org.apache.flume.thrift.ThriftFlumeEvent
 
HEADERS_FIELD_NUMBER - Static variable in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
 
HEADERS_PREFIX - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
Mapping for putting headers to events grouped by file groups.
headerTable(Table<String, String, String>) - Method in class org.apache.flume.source.taildir.ReliableTaildirEventReader.Builder
 
HEART_BEAT_INTERVAL - Static variable in class org.apache.flume.sink.hive.Config
 
hflushOrSync(FSDataOutputStream) - Method in class org.apache.flume.sink.hdfs.AbstractHDFSWriter
If hflush is available in this version of HDFS, then this method calls hflush, else it calls sync.
HIVE_DATABASE - Static variable in class org.apache.flume.sink.hive.Config
 
HIVE_METASTORE - Static variable in class org.apache.flume.sink.hive.Config
 
HIVE_PARTITION - Static variable in class org.apache.flume.sink.hive.Config
 
HIVE_TABLE - Static variable in class org.apache.flume.sink.hive.Config
 
HIVE_TXNS_PER_BATCH_ASK - Static variable in class org.apache.flume.sink.hive.Config
 
HiveDelimitedTextSerializer - Class in org.apache.flume.sink.hive
Forwards the incoming event body to Hive unmodified Sets up the delimiter and the field to column mapping
HiveDelimitedTextSerializer() - Constructor for class org.apache.flume.sink.hive.HiveDelimitedTextSerializer
 
HiveEventSerializer - Interface in org.apache.flume.sink.hive
 
HiveJsonSerializer - Class in org.apache.flume.sink.hive
Forwards the incoming event body to Hive unmodified Sets up the delimiter and the field to column mapping
HiveJsonSerializer() - Constructor for class org.apache.flume.sink.hive.HiveJsonSerializer
 
HiveSink - Class in org.apache.flume.sink.hive
 
HiveSink() - Constructor for class org.apache.flume.sink.hive.HiveSink
 
host - Variable in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
 
HOST - Static variable in class org.apache.flume.interceptor.HostInterceptor.Constants
 
HOST - Static variable in class org.apache.flume.source.avroLegacy.AvroLegacySource
 
HOST_HEADER - Static variable in class org.apache.flume.interceptor.HostInterceptor.Constants
 
HOST_SELECTOR_RANDOM - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
 
HOST_SELECTOR_ROUND_ROBIN - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
 
HostInfo - Class in org.apache.flume.api
A convenience class that holds the property reference name along with the hostname and port number of a specified host address.
HostInfo(String, String, int) - Constructor for class org.apache.flume.api.HostInfo
 
HostInterceptor - Class in org.apache.flume.interceptor
Simple Interceptor class that sets the host name or IP on all events that are intercepted.
HostInterceptor.Builder - Class in org.apache.flume.interceptor
Builder which builds new instances of the HostInterceptor.
HostInterceptor.Builder() - Constructor for class org.apache.flume.interceptor.HostInterceptor.Builder
 
HostInterceptor.Constants - Class in org.apache.flume.interceptor
 
HostInterceptor.Constants() - Constructor for class org.apache.flume.interceptor.HostInterceptor.Constants
 
HOSTNAMES - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
Comma separated list of hostname:port, if the port is not present the default port '9300' will be used
HOUR - Static variable in class org.apache.flume.sink.hive.Config
 
HTTPBadRequestException - Exception in org.apache.flume.source.http
Exception thrown by an HTTP Handler if the request was not parsed correctly into an event because the request was not in the expected format.
HTTPBadRequestException(String) - Constructor for exception org.apache.flume.source.http.HTTPBadRequestException
 
HTTPBadRequestException(String, Throwable) - Constructor for exception org.apache.flume.source.http.HTTPBadRequestException
 
HTTPBadRequestException(Throwable) - Constructor for exception org.apache.flume.source.http.HTTPBadRequestException
 
HTTPMetricsServer - Class in org.apache.flume.instrumentation.http
A Monitor service implementation that runs a web server on a configurable port and returns the metrics for components in JSON format.
HTTPMetricsServer() - Constructor for class org.apache.flume.instrumentation.http.HTTPMetricsServer
 
HTTPServerConstraintUtil - Class in org.apache.flume.tools
Utility class to impose constraints on Jetty HTTP servers
HTTPSource - Class in org.apache.flume.source.http
A source which accepts Flume Events by HTTP POST and GET.
HTTPSource() - Constructor for class org.apache.flume.source.http.HTTPSource
 
HTTPSourceConfigurationConstants - Class in org.apache.flume.source.http
 
HTTPSourceConfigurationConstants() - Constructor for class org.apache.flume.source.http.HTTPSourceConfigurationConstants
 
HTTPSourceHandler - Interface in org.apache.flume.source.http
 

I

IDLE_TIMEOUT - Static variable in class org.apache.flume.sink.hive.Config
 
IDLE_TIMEOUT - Static variable in class org.apache.flume.source.taildir.TaildirSourceConfigurationConstants
Time (ms) to close idle files.
IGNORE_CASE_CONFIG - Static variable in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
Whether to ignore case when performing regex matches.
IGNORE_PAT - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
Pattern of files to ignore
ignorePattern(String) - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
 
INCLUDE_PAT - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
Pattern of files to include
includePattern(String) - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
 
increment(String) - Method in class org.apache.flume.instrumentation.MonitoredCounterGroup
Atomically increments the current value for this key by one
incrementAndGet(String) - Method in class org.apache.flume.CounterGroup
 
incrementAppendAcceptedCount() - Method in class org.apache.flume.instrumentation.SourceCounter
 
incrementAppendBatchAcceptedCount() - Method in class org.apache.flume.instrumentation.SourceCounter
 
incrementAppendBatchReceivedCount() - Method in class org.apache.flume.instrumentation.SourceCounter
 
incrementAppendReceivedCount() - Method in class org.apache.flume.instrumentation.SourceCounter
 
incrementBatchCompleteCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
incrementBatchEmptyCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
incrementBatchUnderflowCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
incrementConnectionClosedCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
incrementConnectionCreatedCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
incrementConnectionFailedCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
incrementEventAcceptedCount() - Method in class org.apache.flume.instrumentation.SourceCounter
 
incrementEventDrainAttemptCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
incrementEventDrainSuccessCount() - Method in class org.apache.flume.instrumentation.SinkCounter
 
incrementEventPutAttemptCount() - Method in class org.apache.flume.instrumentation.ChannelCounter
 
incrementEventReceivedCount() - Method in class org.apache.flume.instrumentation.SourceCounter
 
incrementEventTakeAttemptCount() - Method in class org.apache.flume.instrumentation.ChannelCounter
 
incrementKafkaEmptyCount() - Method in class org.apache.flume.instrumentation.kafka.KafkaSourceCounter
 
incrementPersistedEventCount() - Method in class org.apache.flume.channel.jdbc.impl.JdbcTransactionImpl
 
incrementRemovedEventCount() - Method in class org.apache.flume.channel.jdbc.impl.JdbcTransactionImpl
 
incrementRollbackCount() - Method in class org.apache.flume.instrumentation.kafka.KafkaSinkCounter
 
INDENTSTEP - Static variable in class org.apache.flume.conf.FlumeConfiguration
 
INDEX_NAME - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
The name to index the document to, defaults to 'flume'
INDEX_NAME_BUILDER - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
The fully qualified class name of the index name builder the sink should use to determine name of index where the event should be sent.
INDEX_NAME_BUILDER_PREFIX - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
The fully qualified class name of the index name builder the sink should use to determine name of index where the event should be sent.
INDEX_TYPE - Static variable in class org.apache.flume.sink.elasticsearch.ElasticSearchSinkConstants
The type to index the document to, defaults to 'log'
IndexNameBuilder - Interface in org.apache.flume.sink.elasticsearch
 
informFailure(HostInfo) - Method in interface org.apache.flume.api.LoadBalancingRpcClient.HostSelector
 
informFailure(T) - Method in class org.apache.flume.util.OrderSelector
Inform this class of the failure of an object so it can be backed off.
informSinkFailed(Sink) - Method in class org.apache.flume.sink.AbstractSinkSelector
 
informSinkFailed(Sink) - Method in interface org.apache.flume.sink.LoadBalancingSinkProcessor.SinkSelector
 
INGORE_CASE_DEFAULT - Static variable in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
 
INITIAL_CONTEXT_FACTORY - Static variable in class org.apache.flume.source.jms.JMSSourceConfiguration
 
InitialContextFactory - Class in org.apache.flume.source.jms
 
InitialContextFactory() - Constructor for class org.apache.flume.source.jms.InitialContextFactory
 
initialize() - Method in class org.apache.flume.channel.BasicChannelSemantics
Called upon first getTransaction() request, while synchronized on this Channel instance.
initialize() - Method in class org.apache.flume.channel.ChannelProcessor
 
initialize(Context) - Method in class org.apache.flume.channel.jdbc.impl.JdbcChannelProviderImpl
 
initialize(Context) - Method in interface org.apache.flume.channel.jdbc.JdbcChannelProvider
Initializes the channel provider.
initialize() - Method in class org.apache.flume.interceptor.HostInterceptor
 
initialize() - Method in interface org.apache.flume.interceptor.Interceptor
Any initialization / startup needed by the Interceptor.
initialize() - Method in class org.apache.flume.interceptor.InterceptorChain
 
initialize() - Method in class org.apache.flume.interceptor.RegexExtractorInterceptor
 
initialize() - Method in class org.apache.flume.interceptor.RegexFilteringInterceptor
 
initialize() - Method in class org.apache.flume.interceptor.SearchAndReplaceInterceptor
 
initialize() - Method in class org.apache.flume.interceptor.StaticInterceptor
 
initialize() - Method in class org.apache.flume.interceptor.TimestampInterceptor
 
initialize(byte[], byte[]) - Method in interface org.apache.flume.sink.hbase.AsyncHbaseEventSerializer
Initialize the event serializer.
initialize(Event, byte[]) - Method in interface org.apache.flume.sink.hbase.HbaseEventSerializer
Initialize the event serializer.
initialize(Event, byte[]) - Method in class org.apache.flume.sink.hbase.RegexHbaseEventSerializer
 
initialize(byte[], byte[]) - Method in class org.apache.flume.sink.hbase.SimpleAsyncHbaseEventSerializer
 
initialize(Event, byte[]) - Method in class org.apache.flume.sink.hbase.SimpleHbaseEventSerializer
 
initialize() - Method in class org.apache.flume.sink.solr.morphline.MorphlineInterceptor
 
initialize() - Method in class org.apache.flume.sink.solr.morphline.UUIDInterceptor
 
initializeRpcClient(Properties) - Method in class org.apache.flume.sink.AbstractRpcSink
Returns a new RpcClient instance configured using the given Properties object.
initializeRpcClient(Properties) - Method in class org.apache.flume.sink.AvroSink
 
initializeRpcClient(Properties) - Method in class org.apache.flume.sink.ThriftSink
 
initialValue() - Method in class org.apache.flume.channel.jdbc.impl.JdbcTransactionFactory
 
INPUT_CHARSET - Static variable in class org.apache.flume.source.SpoolDirectorySourceConfigurationConstants
Character set used when reading the input.
inputCharset(String) - Method in class org.apache.flume.client.avro.ReliableSpoolingFileEventReader.Builder
 
intercept(Event) - Method in class org.apache.flume.interceptor.HostInterceptor
Modifies events in-place.
intercept(List<Event>) - Method in class org.apache.flume.interceptor.HostInterceptor
Delegates to HostInterceptor.intercept(Event) in a loop.
intercept(Event) - Method in interface org.apache.flume.interceptor.Interceptor
Interception of a single Event.
intercept(List<Event>) - Method in interface org.apache.flume.interceptor.Interceptor
Interception of a batch of events.
intercept(Event) - Method in class org.apache.flume.interceptor.InterceptorChain
 
intercept(List<Event>) - Method in class org.apache.flume.interceptor.InterceptorChain
 
intercept(Event) - Method in class org.apache.flume.interceptor.RegexExtractorInterceptor
 
intercept(List<Event>) - Method in class org.apache.flume.interceptor.RegexExtractorInterceptor
 
intercept(Event) - Method in class org.apache.flume.interceptor.RegexFilteringInterceptor
 
intercept(List<Event>) - Method in class org.apache.flume.interceptor.RegexFilteringInterceptor
Returns the set of events which pass filters, according to RegexFilteringInterceptor.intercept(Event).
intercept(Event) - Method in class org.apache.flume.interceptor.SearchAndReplaceInterceptor
 
intercept(List<Event>) - Method in class org.apache.flume.interceptor.SearchAndReplaceInterceptor
 
intercept(Event) - Method in class org.apache.flume.interceptor.StaticInterceptor
Modifies events in-place.
intercept(List<Event>) - Method in class org.apache.flume.interceptor.StaticInterceptor
Delegates to StaticInterceptor.intercept(Event) in a loop.
intercept(Event) - Method in class org.apache.flume.interceptor.TimestampInterceptor
Modifies events in-place.
intercept(List<Event>) - Method in class org.apache.flume.interceptor.TimestampInterceptor
intercept(List<Event>) - Method in class org.apache.flume.sink.solr.morphline.MorphlineInterceptor
 
intercept(Event) - Method in class org.apache.flume.sink.solr.morphline.MorphlineInterceptor
 
intercept(Event) - Method in class org.apache.flume.sink.solr.morphline.UUIDInterceptor
 
intercept(List<Event>) - Method in class org.apache.flume.sink.solr.morphline.UUIDInterceptor
 
Interceptor - Interface in org.apache.flume.interceptor
 
Interceptor.Builder - Interface in org.apache.flume.interceptor
Builder implementations MUST have a no-arg constructor
InterceptorBuilderFactory - Class in org.apache.flume.interceptor
Factory used to register instances of Interceptors & their builders, as well as to instantiate the builders.
InterceptorBuilderFactory() - Constructor for class org.apache.flume.interceptor.InterceptorBuilderFactory
 
InterceptorChain - Class in org.apache.flume.interceptor
Implementation of Interceptor that calls a list of other Interceptors serially.
InterceptorChain() - Constructor for class org.apache.flume.interceptor.InterceptorChain
 
InterceptorType - Enum in org.apache.flume.interceptor
 
InterfaceAudience - Class in org.apache.flume.annotations
Annotation to inform users of a package, class or method's intended audience.
InterfaceAudience.LimitedPrivate - Annotation Type in org.apache.flume.annotations
Intended only for the project(s) specified in the annotation.
InterfaceAudience.Private - Annotation Type in org.apache.flume.annotations
Intended for use only within Flume
InterfaceAudience.Public - Annotation Type in org.apache.flume.annotations
Intended for use by any project or application.
InterfaceStability - Class in org.apache.flume.annotations
Annotation to inform users of how much to rely on a particular package, class or method not changing over time.
InterfaceStability() - Constructor for class org.apache.flume.annotations.InterfaceStability
 
InterfaceStability.Evolving - Annotation Type in org.apache.flume.annotations
Evolving, but can break compatibility at minor release (i.e.
InterfaceStability.Stable - Annotation Type in org.apache.flume.annotations
Can evolve while retaining compatibility for minor release boundaries.; can break compatibility only at major release (ie.
InterfaceStability.Unstable - Annotation Type in org.apache.flume.annotations
No guarantee is provided as to reliability or stability across any level of release granularity.
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
 
internalGetFieldAccessorTable() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
 
IRCSink - Class in org.apache.flume.sink.irc
 
IRCSink() - Constructor for class org.apache.flume.sink.irc.IRCSink
 
IRCSink.IRCConnectionListener - Class in org.apache.flume.sink.irc
 
IRCSink.IRCConnectionListener() - Constructor for class org.apache.flume.sink.irc.IRCSink.IRCConnectionListener
 
isActive() - Method in class org.apache.flume.api.AbstractRpcClient
 
isActive() - Method in class org.apache.flume.api.FailoverRpcClient
 
isActive() - Method in class org.apache.flume.api.LoadBalancingRpcClient
 
isActive() - Method in class org.apache.flume.api.NettyAvroRpcClient
 
isActive() - Method in interface org.apache.flume.api.RpcClient
Returns true if this object appears to be in a usable state, and it returns false if this object is permanently disabled.
isActive() - Method in class org.apache.flume.api.ThriftRpcClient
 
isAuthenticated() - Method in interface org.apache.flume.auth.FlumeAuthenticator
Returns true, if the underlying Authenticator was obtained by successful kerberos authentication
isComponentInErrorState(LifecycleAware) - Method in class org.apache.flume.lifecycle.LifecycleSupervisor
 
isEmpty() - Method in class org.apache.flume.channel.SpillableMemoryChannel.DrainOrderQueue
 
isGanglia3() - Method in class org.apache.flume.instrumentation.GangliaServer
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog.Builder
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.ActiveLog
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint.Builder
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Checkpoint
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit.Builder
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Commit
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent.Builder
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEvent
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader.Builder
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption.Builder
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileEncryption
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData.Builder
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.LogFileMetaData
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put.Builder
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Put
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback.Builder
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Rollback
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take.Builder
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.Take
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter.Builder
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventFooter
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader.Builder
 
isInitialized() - Method in class org.apache.flume.channel.file.proto.ProtosFactory.TransactionEventHeader
 
isMatch(Event) - Method in class org.apache.flume.sink.solr.morphline.UUIDInterceptor
 
isNotFoundConfigClass() - Method in class org.apache.flume.conf.ComponentConfiguration
 
isOpen() - Method in class org.apache.flume.channel.file.FileChannel
 
isOverflowDisabled() - Method in class org.apache.flume.channel.SpillableMemoryChannel
 
isSet(ThriftFlumeEvent._Fields) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
isSet(ThriftFlumeEventServer.append_args._Fields) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
isSet(ThriftFlumeEventServer.close_args._Fields) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_args
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
isSet(ThriftFlumeEventServer.close_result._Fields) - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.close_result
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
isSet(LogEntry._Fields) - Method in class org.apache.flume.source.scribe.LogEntry
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
isSet(Scribe.Log_args._Fields) - Method in class org.apache.flume.source.scribe.Scribe.Log_args
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
isSet(Scribe.Log_result._Fields) - Method in class org.apache.flume.source.scribe.Scribe.Log_result
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
isSet(ThriftFlumeEvent._Fields) - Method in class org.apache.flume.thrift.ThriftFlumeEvent
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
isSet(ThriftSourceProtocol.append_args._Fields) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_args
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
isSet(ThriftSourceProtocol.append_result._Fields) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_result
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
isSet(ThriftSourceProtocol.appendBatch_args._Fields) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
isSet(ThriftSourceProtocol.appendBatch_result._Fields) - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result
Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise
isSetBody() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
Returns true if field body is set (has been assigned a value) and false otherwise
isSetBody() - Method in class org.apache.flume.thrift.ThriftFlumeEvent
Returns true if field body is set (has been assigned a value) and false otherwise
isSetCategory() - Method in class org.apache.flume.source.scribe.LogEntry
Returns true if field category is set (has been assigned a value) and false otherwise
isSetEvent() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_args
Returns true if field event is set (has been assigned a value) and false otherwise
isSetEvents() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_args
Returns true if field events is set (has been assigned a value) and false otherwise
isSetEvt() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEventServer.append_args
Returns true if field evt is set (has been assigned a value) and false otherwise
isSetFields() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
Returns true if field fields is set (has been assigned a value) and false otherwise
isSetHeaders() - Method in class org.apache.flume.thrift.ThriftFlumeEvent
Returns true if field headers is set (has been assigned a value) and false otherwise
isSetHost() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
Returns true if field host is set (has been assigned a value) and false otherwise
isSetMessage() - Method in class org.apache.flume.source.scribe.LogEntry
Returns true if field message is set (has been assigned a value) and false otherwise
isSetMessages() - Method in class org.apache.flume.source.scribe.Scribe.Log_args
Returns true if field messages is set (has been assigned a value) and false otherwise
isSetNanos() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
Returns true if field nanos is set (has been assigned a value) and false otherwise
isSetPriority() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
Returns true if field priority is set (has been assigned a value) and false otherwise
isSetSuccess() - Method in class org.apache.flume.source.scribe.Scribe.Log_result
Returns true if field success is set (has been assigned a value) and false otherwise
isSetSuccess() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.append_result
Returns true if field success is set (has been assigned a value) and false otherwise
isSetSuccess() - Method in class org.apache.flume.thrift.ThriftSourceProtocol.appendBatch_result
Returns true if field success is set (has been assigned a value) and false otherwise
isSetTimestamp() - Method in class com.cloudera.flume.handlers.thrift.ThriftFlumeEvent
Returns true if field timestamp is set (has been assigned a value) and false otherwise
isShouldBackOff() - Method in class org.apache.flume.util.OrderSelector
 
isStarted() - Method in class org.apache.flume.source.BasicSourceSemantics
 
isUnderReplicated() - Method in class org.apache.flume.sink.hdfs.AbstractHDFSWriter
Contract for subclasses: Call registerCurrentStream() on open, unregisterCurrentStream() on close, and the base class takes care of the rest.
isUnderReplicated() - Method in interface org.apache.flume.sink.hdfs.HDFSWriter
 
isWindows() - Static method in class org.apache.flume.tools.PlatformDetect
Detects whether we are running under Microsoft Windows.

J

JCE_FILE_KEY_PASSWORD_FILE - Static variable in class org.apache.flume.channel.file.encryption.EncryptionConfiguration
Path to key password file is: keys.aliasName.passwordFile
JCE_FILE_KEY_STORE_FILE - Static variable in class org.apache.flume.channel.file.encryption.EncryptionConfiguration
Path to a jceks key store
JCE_FILE_KEY_STORE_PASSWORD_FILE - Static variable in class org.apache.flume.channel.file.encryption.EncryptionConfiguration
Path to a jceks key store password file
JCE_FILE_KEYS - Static variable in class org.apache.flume.channel.file.encryption.EncryptionConfiguration
Space separated list of keys which are needed for the current set of logs plus the one specified in keyAlias
JCEFileKeyProvider - Class in org.apache.flume.channel.file.encryption
 
JCEFileKeyProvider(File, File, Map<String, File>) - Constructor for class org.apache.flume.channel.file.encryption.JCEFileKeyProvider
 
JCEFileKeyProvider.Builder - Class in org.apache.flume.channel.file.encryption
 
JCEFileKeyProvider.Builder() - Constructor for class org.apache.flume.channel.file.encryption.JCEFileKeyProvider.Builder
 
JdbcChannel - Class in org.apache.flume.channel.jdbc
A JDBC based channel implementation.
JdbcChannel() - Constructor for class org.apache.flume.channel.jdbc.JdbcChannel
Instantiates a new JDBC Channel.
JdbcChannelException - Exception in org.apache.flume.channel.jdbc
 
JdbcChannelException(String) - Constructor for exception org.apache.flume.channel.jdbc.JdbcChannelException
 
JdbcChannelException(String, Exception) - Constructor for exception org.apache.flume.channel.jdbc.JdbcChannelException
 
JdbcChannelException(Exception) - Constructor for exception org.apache.flume.channel.jdbc.JdbcChannelException
 
JdbcChannelProvider - Interface in org.apache.flume.channel.jdbc
Service provider interface for JDBC channel providers.
JdbcChannelProviderFactory - Class in org.apache.flume.channel.jdbc
 
JdbcChannelProviderImpl - Class in org.apache.flume.channel.jdbc.impl
 
JdbcChannelProviderImpl() - Constructor for class org.apache.flume.channel.jdbc.impl.JdbcChannelProviderImpl
 
JdbcTransactionFactory - Class in org.apache.flume.channel.jdbc.impl
 
JdbcTransactionFactory(DataSource, JdbcChannelProviderImpl) - Constructor for class org.apache.flume.channel.jdbc.impl.JdbcTransactionFactory
 
JdbcTransactionImpl - Class in org.apache.flume.channel.jdbc.impl
 
JdbcTransactionImpl(DataSource, JdbcTransactionFactory, JdbcChannelProviderImpl) - Constructor for class org.apache.flume.channel.jdbc.impl.JdbcTransactionImpl
 
JMSDestinationLocator - Enum in org.apache.flume.source.jms
 
JMSDestinationType - Enum in org.apache.flume.source.jms
 
JMSMessageConsumerFactory - Class in org.apache.flume.source.jms
 
JMSMessageConsumerFactory() - Constructor for class org.apache.flume.source.jms.JMSMessageConsumerFactory
 
JMSMessageConverter - Interface in org.apache.flume.source.jms
Converts a JMS Message to an Event.
JMSMessageConverter.Builder - Interface in org.apache.flume.source.jms
Implementors of JMSMessageConverter must either provide a suitable builder or implement the Configurable interface.
JMSSource - Class in org.apache.flume.source.jms
 
JMSSource() - Constructor for class org.apache.flume.source.jms.JMSSource
 
JMSSource(JMSMessageConsumerFactory, InitialContextFactory) - Constructor for class org.apache.flume.source.jms.JMSSource
 
JMSSourceConfiguration - Class in org.apache.flume.source.jms
 
JMSSourceConfiguration() - Constructor for class org.apache.flume.source.jms.JMSSourceConfiguration
 
JMXPollUtil - Class in org.apache.flume.instrumentation.util
 
JMXPollUtil() - Constructor for class org.apache.flume.instrumentation.util.JMXPollUtil
 
JSONEvent - Class in org.apache.flume.event
 
JSONEvent() - Constructor for class org.apache.flume.event.JSONEvent
 
JSONHandler - Class in org.apache.flume.source.http
JSONHandler for HTTPSource that accepts an array of events.
JSONHandler() - Constructor for class org.apache.flume.source.http.JSONHandler
 

K

KAFKA_CONSUMER_PREFIX - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
KAFKA_CONSUMER_PREFIX - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants
 
KAFKA_PREFIX - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
KAFKA_PREFIX - Static variable in class org.apache.flume.sink.kafka.KafkaSinkConstants
 
KAFKA_PREFIX - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants
 
KAFKA_PRODUCER_PREFIX - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
KAFKA_PRODUCER_PREFIX - Static variable in class org.apache.flume.sink.kafka.KafkaSinkConstants
 
KafkaChannel - Class in org.apache.flume.channel.kafka
 
KafkaChannel() - Constructor for class org.apache.flume.channel.kafka.KafkaChannel
 
KafkaChannelConfiguration - Class in org.apache.flume.channel.kafka
 
KafkaChannelConfiguration() - Constructor for class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
KafkaChannelCounter - Class in org.apache.flume.instrumentation.kafka
 
KafkaChannelCounter(String) - Constructor for class org.apache.flume.instrumentation.kafka.KafkaChannelCounter
 
KafkaChannelCounterMBean - Interface in org.apache.flume.instrumentation.kafka
 
KafkaPartitionTestUtil - Class in org.apache.flume.shared.kafka.test
 
KafkaPartitionTestUtil() - Constructor for class org.apache.flume.shared.kafka.test.KafkaPartitionTestUtil
 
KafkaSink - Class in org.apache.flume.sink.kafka
A Flume Sink that can publish messages to Kafka.
KafkaSink() - Constructor for class org.apache.flume.sink.kafka.KafkaSink
 
KafkaSinkConstants - Class in org.apache.flume.sink.kafka
 
KafkaSinkConstants() - Constructor for class org.apache.flume.sink.kafka.KafkaSinkConstants
 
KafkaSinkCounter - Class in org.apache.flume.instrumentation.kafka
 
KafkaSinkCounter(String) - Constructor for class org.apache.flume.instrumentation.kafka.KafkaSinkCounter
 
KafkaSinkCounterMBean - Interface in org.apache.flume.instrumentation.kafka
 
KafkaSource - Class in org.apache.flume.source.kafka
A Source for Kafka which reads messages from kafka topics.
KafkaSource() - Constructor for class org.apache.flume.source.kafka.KafkaSource
 
KafkaSource.Subscriber<T> - Class in org.apache.flume.source.kafka
This class is a helper to subscribe for topics by using different strategies
KafkaSource.Subscriber() - Constructor for class org.apache.flume.source.kafka.KafkaSource.Subscriber
 
KafkaSourceConstants - Class in org.apache.flume.source.kafka
 
KafkaSourceConstants() - Constructor for class org.apache.flume.source.kafka.KafkaSourceConstants
 
KafkaSourceCounter - Class in org.apache.flume.instrumentation.kafka
 
KafkaSourceCounter(String) - Constructor for class org.apache.flume.instrumentation.kafka.KafkaSourceCounter
 
KafkaSourceCounterMBean - Interface in org.apache.flume.instrumentation.kafka
 
KEEP_ALIVE - Static variable in class org.apache.flume.channel.file.FileChannelConfiguration
The length of time we will wait for space available to do a Put.
KEEP_ALIVE - Static variable in class org.apache.flume.channel.SpillableMemoryChannel
file channel setting that is overriden by Spillable Channel
KEEP_FIELDS_ALL - Static variable in class org.apache.flume.source.SyslogUtils
 
keepAllFields(Set<String>) - Static method in class org.apache.flume.source.SyslogUtils
 
KERBEROS_KEY - Static variable in class org.apache.flume.api.RpcClientConfigurationConstants
 
KerberosUser - Class in org.apache.flume.auth
Simple Pair class used to define a unique (principal, keyTab) combination.
KerberosUser(String, String) - Constructor for class org.apache.flume.auth.KerberosUser
 
KerberosUser - Class in org.apache.flume.sink.hdfs
Simple Pair class used to define a unique (principal, keyTab) combination.
KerberosUser(String, String) - Constructor for class org.apache.flume.sink.hdfs.KerberosUser
 
key - Variable in class org.apache.flume.channel.file.encryption.CipherProvider.Decryptor.Builder
 
key - Variable in class org.apache.flume.channel.file.encryption.CipherProvider.Encryptor.Builder
 
KEY - Static variable in class org.apache.flume.interceptor.StaticInterceptor.Constants
 
KEY_DEFAULT - Static variable in class org.apache.flume.interceptor.StaticInterceptor.Constants
 
KEY_FIELD_NUMBER - Static variable in class org.apache.flume.channel.file.proto.ProtosFactory.FlumeEventHeader
 
KEY_HEADER - Static variable in class org.apache.flume.channel.kafka.KafkaChannelConfiguration
 
KEY_HEADER - Static variable in class org.apache.flume.sink.kafka.KafkaSinkConstants
 
KEY_HEADER - Static variable in class org.apache.flume.source.kafka.KafkaSourceConstants