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

A

abort() - Method in class org.apache.flume.sink.hdfs.BucketWriter

AbstractFileConfigurationProvider - Class in org.apache.flume.conf.file

AbstractFileConfigurationProvider() - Constructor for class org.apache.flume.conf.file.AbstractFileConfigurationProvider

AbstractFileConfigurationProvider.FileWatcherRunnable - Class in org.apache.flume.conf.file

AbstractFileConfigurationProvider.FileWatcherRunnable() - Constructor for class org.apache.flume.conf.file.AbstractFileConfigurationProvider.FileWatcherRunnable

AbstractLogicalNodeManager - Class in org.apache.flume.node.nodemanager

AbstractLogicalNodeManager() - Constructor for class org.apache.flume.node.nodemanager.AbstractLogicalNodeManager

AbstractSink - Class in org.apache.flume.sink

AbstractSink() - Constructor for class org.apache.flume.sink.AbstractSink

AbstractSource - Class in org.apache.flume.source

AbstractSource() - Constructor for class org.apache.flume.source.AbstractSource

add(CounterGroup) - Method in class org.apache.flume.CounterGroup

add(LifecycleAware) - Method in class org.apache.flume.node.nodemanager.AbstractLogicalNodeManager

add(LifecycleAware) - Method in interface org.apache.flume.node.NodeManager

add(LifecycleAware) - Method in class org.apache.flume.node.nodemanager.DefaultLogicalNodeManager

addAndGet(String, Long) - Method in class org.apache.flume.CounterGroup

addFanout(Channel) - Method in class org.apache.flume.channel.FanoutChannel

append(Event) - Method in class org.apache.flume.sink.hdfs.BucketWriter

append(Event, FlumeFormatter) - Method in class org.apache.flume.sink.hdfs.HDFSCompressedDataStream

append(Event, FlumeFormatter) - Method in class org.apache.flume.sink.hdfs.HDFSDataStream

append(Event, FlumeFormatter) - Method in class org.apache.flume.sink.hdfs.HDFSSequenceFile

append(Event, FlumeFormatter) - Method in interface org.apache.flume.sink.hdfs.HDFSWriter

append(AvroFlumeEvent) - Method in interface org.apache.flume.source.avro.AvroSourceProtocol

append(AvroFlumeEvent, Callback<Status>) - Method in interface org.apache.flume.source.avro.AvroSourceProtocol.Callback

append(AvroFlumeEvent) - Method in class org.apache.flume.source.AvroSource

appendBatch(List<AvroFlumeEvent>) - Method in interface org.apache.flume.source.avro.AvroSourceProtocol

appendBatch(List<AvroFlumeEvent>, Callback<Status>) - Method in interface org.apache.flume.source.avro.AvroSourceProtocol.Callback

appendBatch(List<AvroFlumeEvent>) - Method in class org.apache.flume.source.AvroSource

Application - Class in org.apache.flume.node

Application() - Constructor for class org.apache.flume.node.Application

AvroCLIClient - Class in org.apache.flume.client.avro

AvroCLIClient() - Constructor for class org.apache.flume.client.avro.AvroCLIClient

AvroFlumeEvent - Class in org.apache.flume.source.avro

AvroFlumeEvent() - Constructor for class org.apache.flume.source.avro.AvroFlumeEvent

AvroFlumeEvent.Builder - Class in org.apache.flume.source.avro

RecordBuilder for AvroFlumeEvent instances.

AvroSink - Class in org.apache.flume.sink

A Sink implementation that can send events to an Avro 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

AvroSourceProtocol - Interface in org.apache.flume.source.avro

AvroSourceProtocol.Callback - Interface in org.apache.flume.source.avro

B

begin() - Method in class org.apache.flume.channel.FanoutChannel.wrapperTransaction

begin() - Method in class org.apache.flume.channel.file.FileChannel.FileBackedTransaction

begin() - Method in class org.apache.flume.channel.jdbc.impl.JdbcTransactionImpl

begin() - Method in class org.apache.flume.channel.MemoryChannel.MemTransaction

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.

body - Variable in class org.apache.flume.source.avro.AvroFlumeEvent

Deprecated.

BucketPath - Class in org.apache.flume.formatter.output

BucketPath() - Constructor for class org.apache.flume.formatter.output.BucketPath

BucketWriter - Class in org.apache.flume.sink.hdfs

BucketWriter(long, long, long, long) - Constructor for class org.apache.flume.sink.hdfs.BucketWriter

BucketWriter.BucketFlushStatus - Enum in org.apache.flume.sink.hdfs

build() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.Builder

build() - Method in class org.apache.flume.source.avro.AvroFlumeEvent.Builder

C

Channel - Interface in org.apache.flume

A channel connects a Source to a Sink.

CHANNEL_NAME_MAX_LENGTH - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants

The maximum length of channel name.

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(Exception) - Constructor for exception org.apache.flume.ChannelException

ChannelException(String, Exception) - Constructor for exception org.apache.flume.ChannelException

ChannelFactory - Interface in org.apache.flume

clear() - Method in class org.apache.flume.Context

clearBody() - Method in class org.apache.flume.source.avro.AvroFlumeEvent.Builder

Clears the value of the 'body' field

clearHeaders() - Method in class org.apache.flume.source.avro.AvroFlumeEvent.Builder

Clears the value of the 'headers' field

close() - Method in class org.apache.flume.channel.FanoutChannel.wrapperTransaction

close() - Method in class org.apache.flume.channel.file.FileChannel.FileBackedTransaction

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.MemoryChannel.MemTransaction

close() - Method in class org.apache.flume.channel.PseudoTxnMemoryChannel.NoOpTransaction

close() - Method in class org.apache.flume.sink.hdfs.BucketWriter

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.Transaction

Ends a transaction boundary for the current channel operation.

COLUMN_LOOKUP_QUERY - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

commit() - Method in class org.apache.flume.channel.FanoutChannel.wrapperTransaction

commit() - Method in class org.apache.flume.channel.file.FileChannel.FileBackedTransaction

commit() - Method in class org.apache.flume.channel.jdbc.impl.JdbcTransactionImpl

commit() - Method in class org.apache.flume.channel.MemoryChannel.MemTransaction

commit() - Method in class org.apache.flume.channel.PseudoTxnMemoryChannel.NoOpTransaction

commit() - Method in interface org.apache.flume.Transaction

Indicates that the transaction can be successfully committed.

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_JDBC_DRIVER_CLASS - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants

CONFIG_JDBC_PROPERTIES_FILE - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants

CONFIG_JDBC_SYSPRO_PREFIX - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants

CONFIG_MAX_CAPACITY - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants

CONFIG_MAX_CONNECTION - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants

CONFIG_PASSWORD - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants

CONFIG_TX_ISOLATION_LEVEL - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants

CONFIG_URL - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants

CONFIG_USERNAME - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants

Configurable - 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.

ConfigurationProvider - Interface in org.apache.flume.node

configure(Context) - Method in class org.apache.flume.channel.jdbc.JdbcChannel

configure(Context) - Method in class org.apache.flume.channel.MemoryChannel

set the event queue capacity

configure(Context) - Method in class org.apache.flume.channel.PseudoTxnMemoryChannel

configure(Context) - Method in interface org.apache.flume.conf.Configurable

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(Context) - Method in class org.apache.flume.sink.AvroSink

configure(Context) - Method in class org.apache.flume.sink.hdfs.HDFSEventSink

configure(Context) - Method in class org.apache.flume.sink.RollingFileSink

configure(Context) - Method in class org.apache.flume.source.AvroSource

configure(Context) - Method in class org.apache.flume.source.ExecSource

configure(Context) - Method in class org.apache.flume.source.NetcatSource

Constants - Class in org.apache.flume

containsTag(String) - Static method in class org.apache.flume.formatter.output.BucketPath

Returns true if in contains a substring matching TAG_REGEX (i.e.

Context - Class in org.apache.flume

Context() - Constructor for class org.apache.flume.Context

CounterGroup - Class in org.apache.flume

CounterGroup() - Constructor for class org.apache.flume.CounterGroup

create(String) - Method in class org.apache.flume.channel.DefaultChannelFactory

create(String) - Method in interface org.apache.flume.ChannelFactory

create(String) - Method in class org.apache.flume.sink.DefaultSinkFactory

create(String) - Method in interface org.apache.flume.SinkFactory

create(String) - Method in class org.apache.flume.source.DefaultSourceFactory

create(String) - Method in interface org.apache.flume.SourceFactory

createFanout(String, Map<String, Channel>) - Method in class org.apache.flume.channel.DefaultChannelFactory

createFanout(String, Map<String, Channel>) - Method in interface org.apache.flume.ChannelFactory

createSchemaObjects(boolean) - Method in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

createSchemaObjects(boolean) - Method in class org.apache.flume.channel.jdbc.impl.MySQLSchemaHandler

createSchemaObjects(boolean) - Method in interface org.apache.flume.channel.jdbc.impl.SchemaHandler

Creates the schema.

D

DatabaseType - Enum in org.apache.flume.channel.jdbc

DefaultChannelFactory - Class in org.apache.flume.channel

DefaultChannelFactory() - Constructor for class org.apache.flume.channel.DefaultChannelFactory

DefaultLogicalNodeManager - Class in org.apache.flume.node.nodemanager

DefaultLogicalNodeManager() - Constructor for class org.apache.flume.node.nodemanager.DefaultLogicalNodeManager

DefaultSinkFactory - Class in org.apache.flume.sink

DefaultSinkFactory() - Constructor for class org.apache.flume.sink.DefaultSinkFactory

DefaultSourceFactory - Class in org.apache.flume.source

DefaultSourceFactory() - Constructor for class org.apache.flume.source.DefaultSourceFactory

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

desiredState - Variable in class org.apache.flume.lifecycle.LifecycleSupervisor.Status

discard - Variable in class org.apache.flume.lifecycle.LifecycleSupervisor.Status

E

ensureOptionalNonNull(Context, String...) - Static method in class org.apache.flume.conf.Configurables

ensureRequiredNonNull(Context, String...) - Static method in class org.apache.flume.conf.Configurables

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.

Event - Interface in org.apache.flume

EventBuilder - Class in org.apache.flume.event

EventBuilder() - Constructor for class org.apache.flume.event.EventBuilder

EventDeliveryException - Exception in org.apache.flume

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

EventDrivenSource - Interface in org.apache.flume

EventDrivenSourceRunner - Class in org.apache.flume.source

EventDrivenSourceRunner() - Constructor for class org.apache.flume.source.EventDrivenSourceRunner

EventFormatter - Interface in org.apache.flume.formatter.output

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

expandShorthand(char) - Static method in class org.apache.flume.formatter.output.BucketPath

F

fail() - Method in class org.apache.flume.lifecycle.LifecycleSupervisor

failures - Variable in class org.apache.flume.lifecycle.LifecycleSupervisor.Status

FanoutChannel - Class in org.apache.flume.channel

FanoutChannel() - Constructor for class org.apache.flume.channel.FanoutChannel

FanoutChannel.wrapperTransaction - Class in org.apache.flume.channel

A wrapper transaction that does the operation on all channels.

FanoutChannel.wrapperTransaction() - Constructor for class org.apache.flume.channel.FanoutChannel.wrapperTransaction

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.

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

FileChannel.FileBackedTransaction - Class in org.apache.flume.channel.file

An implementation of Transaction for FileChannels.

FileChannel.FileBackedTransaction() - Constructor for class org.apache.flume.channel.file.FileChannel.FileBackedTransaction

findTransaction() - Method in class org.apache.flume.channel.MemoryChannel

firstSeen - Variable in class org.apache.flume.lifecycle.LifecycleSupervisor.Status

FlumeConfiguration - Class in org.apache.flume.conf.properties

FlumeConfiguration is an in memory representation of the hierarchical configuration namespace required by the PropertiesFileConfgurationProvider.

FlumeConfiguration(Properties) - Constructor for class org.apache.flume.conf.properties.FlumeConfiguration

Creates an empty Flume Configuration object.

FlumeConfiguration.AgentConfiguration - Class in org.apache.flume.conf.properties

FlumeConfiguration.ComponentConfiguration - Class in org.apache.flume.conf.properties

FlumeConfiguration.ComponentNameAndConfigKey - Class in org.apache.flume.conf.properties

FlumeFormatter - Interface in org.apache.flume.sink

FlumeNode - Class in org.apache.flume.node

FlumeNode() - Constructor for class org.apache.flume.node.FlumeNode

flush() - Method in class org.apache.flume.sink.hdfs.BucketWriter

forgetTransaction(MemoryChannel.MemTransaction) - Method in class org.apache.flume.channel.MemoryChannel

Remove the given transaction from the list of open transactions

format(Event) - Method in interface org.apache.flume.formatter.output.EventFormatter

format(Event) - Method in class org.apache.flume.formatter.output.TextDelimitedOutputFormatter

forSink(Sink) - Static method in class org.apache.flume.SinkRunner

forSource(Source) - Static method in class org.apache.flume.SourceRunner

G

get(String, Class<? extends T>) - Method in class org.apache.flume.Context

get(String, Class<? extends T>, T) - Method in class org.apache.flume.Context

get(String) - Method in class org.apache.flume.CounterGroup

get(int) - Method in class org.apache.flume.source.avro.AvroFlumeEvent

getArgs() - Method in class org.apache.flume.node.Application

getBase() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.SpillableString

getBaseDirectory() - Method in class org.apache.flume.formatter.output.PathManager

getBasePayload() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent

getBody() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent

getBody() - Method in interface org.apache.flume.Event

getBody() - Method in class org.apache.flume.event.SimpleEvent

getBody() - Method in class org.apache.flume.source.avro.AvroFlumeEvent.Builder

Gets the value of the 'body' field

getBody() - Method in class org.apache.flume.source.avro.AvroFlumeEvent

Gets the value of the 'body' field.

getByName(String) - Static method in enum org.apache.flume.channel.jdbc.DatabaseType

getByName(String) - Static method in enum org.apache.flume.channel.jdbc.TransactionIsolation

getBytes(Event) - Method in interface org.apache.flume.sink.FlumeFormatter

getBytes(Event) - Method in class org.apache.flume.sink.hdfs.HDFSTextFormatter

getBytes(Event) - Method in class org.apache.flume.sink.hdfs.HDFSWritableFormatter

getChannel() - Method in class org.apache.flume.sink.AbstractSink

getChannel() - Method in interface org.apache.flume.Sink

getChannel() - Method in class org.apache.flume.source.AbstractSource

getChannel() - Method in interface org.apache.flume.Source

getChannelFactory() - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

getChannelName() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent

getChannelNames() - Method in class org.apache.flume.channel.DefaultChannelFactory

getChannelNames() - Method in interface org.apache.flume.ChannelFactory

getChannelRegistry() - Method in class org.apache.flume.channel.DefaultChannelFactory

getChannels() - Method in class org.apache.flume.conf.file.SimpleNodeConfiguration

getChannels() - Method in class org.apache.flume.conf.properties.FlumeConfiguration.AgentConfiguration

getChannels() - Method in interface org.apache.flume.node.NodeConfiguration

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.

getCode() - Method in enum org.apache.flume.channel.jdbc.TransactionIsolation

getCompleteDirectory() - Method in class org.apache.flume.channel.file.FileChannel

getComponentName() - Method in class org.apache.flume.conf.properties.FlumeConfiguration.ComponentConfiguration

getComponentName() - Method in class org.apache.flume.conf.properties.FlumeConfiguration.ComponentNameAndConfigKey

getConfigKey() - Method in class org.apache.flume.conf.properties.FlumeConfiguration.ComponentNameAndConfigKey

getConfiguration() - Method in class org.apache.flume.conf.properties.FlumeConfiguration.ComponentConfiguration

getConfigurationAware() - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

getConfigurationFor(String) - Method in class org.apache.flume.conf.properties.FlumeConfiguration

getConfigurationProvider() - Method in class org.apache.flume.node.FlumeNode

getConnection() - Method in class org.apache.flume.channel.jdbc.impl.JdbcTransactionImpl

getCounter(String) - Method in class org.apache.flume.CounterGroup

getCounters() - Method in class org.apache.flume.CounterGroup

getCurrentFile() - Method in class org.apache.flume.formatter.output.PathManager

getDirectory() - Method in class org.apache.flume.channel.file.FileChannel

getDirectory() - Method in class org.apache.flume.sink.RollingFileSink

getEscapeMapping(String, Map<String, String>) - Static method in class org.apache.flume.formatter.output.BucketPath

Instead of replacing escape sequences in a string, this method returns a mapping of an attribute name to the value based on the escape sequence found in the argument string.

getFile() - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

getFileIndex() - Method in class org.apache.flume.formatter.output.PathManager

getFilePath() - Method in class org.apache.flume.sink.hdfs.BucketWriter

getFormatter() - Method in class org.apache.flume.sink.RollingFileSink

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() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent

getHeaders() - Method in interface org.apache.flume.Event

getHeaders() - Method in class org.apache.flume.event.SimpleEvent

getHeaders() - Method in class org.apache.flume.source.avro.AvroFlumeEvent.Builder

Gets the value of the 'headers' field

getHeaders() - Method in class org.apache.flume.source.avro.AvroFlumeEvent

Gets the value of the 'headers' field.

getId() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.HeaderEntry

getKey(Event) - Method in interface org.apache.flume.sink.FlumeFormatter

getKey(Event) - Method in class org.apache.flume.sink.hdfs.HDFSTextFormatter

getKey(Event) - Method in class org.apache.flume.sink.hdfs.HDFSWritableFormatter

getKeyClass() - Method in interface org.apache.flume.sink.FlumeFormatter

getKeyClass() - Method in class org.apache.flume.sink.hdfs.HDFSTextFormatter

getKeyClass() - Method in class org.apache.flume.sink.hdfs.HDFSWritableFormatter

getLifecycleState() - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

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.FlumeNode

getLifecycleState() - Method in class org.apache.flume.node.nodemanager.DefaultLogicalNodeManager

getLifecycleState() - Method in class org.apache.flume.sink.AbstractSink

getLifecycleState() - Method in class org.apache.flume.sink.PollableSinkRunner

getLifecycleState() - Method in class org.apache.flume.source.AbstractSource

getLifecycleState() - Method in class org.apache.flume.source.EventDrivenSourceRunner

getLifecycleState() - Method in class org.apache.flume.source.PollableSourceRunner

getName() - Method in class org.apache.flume.channel.FanoutChannel

getName() - Method in class org.apache.flume.channel.file.FileChannel

getName() - Method in interface org.apache.flume.Channel

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 class org.apache.flume.channel.jdbc.JdbcChannel

getName() - Method in enum org.apache.flume.channel.jdbc.TransactionIsolation

getName() - Method in class org.apache.flume.channel.MemoryChannel

getName() - Method in class org.apache.flume.channel.PseudoTxnMemoryChannel

getName() - Method in class org.apache.flume.CounterGroup

getName() - Method in class org.apache.flume.node.FlumeNode

getNameString() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.HeaderEntry

getNodeManager() - Method in class org.apache.flume.node.FlumeNode

getNodeName() - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

getNodes() - Method in class org.apache.flume.node.nodemanager.AbstractLogicalNodeManager

getNodes() - Method in interface org.apache.flume.node.NodeManager

getOpenDirectory() - Method in class org.apache.flume.channel.file.FileChannel

getParameters() - Method in class org.apache.flume.Context

getProvider(Context, String) - Static method in class org.apache.flume.channel.jdbc.JdbcChannelProviderFactory

getRollInterval() - Method in class org.apache.flume.sink.RollingFileSink

getSchema() - Method in class org.apache.flume.source.avro.AvroFlumeEvent

getSeriesTimestamp() - Method in class org.apache.flume.formatter.output.PathManager

getSink() - Method in class org.apache.flume.SinkRunner

getSinkFactory() - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

getSinkNames() - Method in class org.apache.flume.sink.DefaultSinkFactory

getSinkNames() - Method in interface org.apache.flume.SinkFactory

getSinkRegistry() - Method in class org.apache.flume.sink.DefaultSinkFactory

getSinkRunners() - Method in class org.apache.flume.conf.file.SimpleNodeConfiguration

getSinkRunners() - Method in interface org.apache.flume.node.NodeConfiguration

getSinks() - Method in class org.apache.flume.conf.properties.FlumeConfiguration.AgentConfiguration

getSource() - Method in class org.apache.flume.SourceRunner

getSourceFactory() - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

getSourceNames() - Method in class org.apache.flume.source.DefaultSourceFactory

getSourceNames() - Method in interface org.apache.flume.SourceFactory

getSourceRegistry() - Method in class org.apache.flume.source.DefaultSourceFactory

getSourceRunners() - Method in class org.apache.flume.conf.file.SimpleNodeConfiguration

getSourceRunners() - Method in interface org.apache.flume.node.NodeConfiguration

getSources() - Method in class org.apache.flume.conf.properties.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

getState() - Method in class org.apache.flume.channel.MemoryChannel.MemTransaction

getString() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.SpillableString

getString(String) - Method in class org.apache.flume.Context

getString(String, String) - Method in class org.apache.flume.Context

getSubProperties(String) - Method in class org.apache.flume.Context

getTransaction() - Method in class org.apache.flume.channel.FanoutChannel

getTransaction() - Method in class org.apache.flume.channel.file.FileChannel

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.MemoryChannel

getTransaction() - Method in class org.apache.flume.channel.PseudoTxnMemoryChannel

getValidationQuery() - Method in enum org.apache.flume.channel.jdbc.DatabaseType

getValue() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.HeaderEntry

getValue(Event) - Method in interface org.apache.flume.sink.FlumeFormatter

getValue(Event) - Method in class org.apache.flume.sink.hdfs.HDFSTextFormatter

getValue(Event) - Method in class org.apache.flume.sink.hdfs.HDFSWritableFormatter

getValueClass() - Method in interface org.apache.flume.sink.FlumeFormatter

getValueClass() - Method in class org.apache.flume.sink.hdfs.HDFSTextFormatter

getValueClass() - Method in class org.apache.flume.sink.hdfs.HDFSWritableFormatter

getValueString() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.HeaderEntry

getWriter(String) - Method in class org.apache.flume.sink.hdfs.HDFSWriterFactory

H

hasBody() - Method in class org.apache.flume.source.avro.AvroFlumeEvent.Builder

Checks whether the 'body' field has been set

hasHeaders() - Method in class org.apache.flume.source.avro.AvroFlumeEvent.Builder

Checks whether the 'headers' field has been set

hasSpill() - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.SpillableString

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

HDFSFormatterFactory - Class in org.apache.flume.sink.hdfs

HDFSSequenceFile - Class in org.apache.flume.sink.hdfs

HDFSSequenceFile() - Constructor for class org.apache.flume.sink.hdfs.HDFSSequenceFile

HDFSTextFormatter - Class in org.apache.flume.sink.hdfs

HDFSTextFormatter() - Constructor for class org.apache.flume.sink.hdfs.HDFSTextFormatter

HDFSWritableFormatter - Class in org.apache.flume.sink.hdfs

HDFSWritableFormatter() - Constructor for class org.apache.flume.sink.hdfs.HDFSWritableFormatter

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_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.

headers - Variable in class org.apache.flume.source.avro.AvroFlumeEvent

Deprecated.

I

incrementAndGet(String) - Method in class org.apache.flume.CounterGroup

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.

initialValue() - Method in class org.apache.flume.channel.jdbc.impl.JdbcTransactionFactory

isInitialized() - Method in class org.apache.flume.channel.file.FileChannel

J

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) - Constructor for class org.apache.flume.channel.jdbc.impl.JdbcTransactionFactory

JdbcTransactionImpl - Class in org.apache.flume.channel.jdbc.impl

JdbcTransactionImpl(DataSource, JdbcTransactionFactory) - Constructor for class org.apache.flume.channel.jdbc.impl.JdbcTransactionImpl

JsonFileConfigurationProvider - Class in org.apache.flume.conf.file

JsonFileConfigurationProvider() - Constructor for class org.apache.flume.conf.file.JsonFileConfigurationProvider

L

lastSeen - Variable in class org.apache.flume.lifecycle.LifecycleSupervisor.Status

lastSeenState - Variable in class org.apache.flume.lifecycle.LifecycleSupervisor.Status

lastTakeStamp() - Method in class org.apache.flume.channel.MemoryChannel.MemTransaction

LifecycleAware - Interface in org.apache.flume.lifecycle

An interface implemented by any class that has a defined, stateful, lifecycle.

lifecycleAware - Variable in class org.apache.flume.lifecycle.LifecycleSupervisor.MonitorRunnable

LifecycleController - Class in org.apache.flume.lifecycle

LifecycleController() - Constructor for class org.apache.flume.lifecycle.LifecycleController

LifecycleException - Exception in org.apache.flume.lifecycle

LifecycleException() - Constructor for exception org.apache.flume.lifecycle.LifecycleException

LifecycleException(String) - Constructor for exception org.apache.flume.lifecycle.LifecycleException

LifecycleException(String, Throwable) - Constructor for exception org.apache.flume.lifecycle.LifecycleException

LifecycleException(Throwable) - Constructor for exception org.apache.flume.lifecycle.LifecycleException

LifecycleState - Enum in org.apache.flume.lifecycle

LifecycleSupervisor - Class in org.apache.flume.lifecycle

LifecycleSupervisor() - Constructor for class org.apache.flume.lifecycle.LifecycleSupervisor

LifecycleSupervisor.MonitorRunnable - Class in org.apache.flume.lifecycle

LifecycleSupervisor.MonitorRunnable() - Constructor for class org.apache.flume.lifecycle.LifecycleSupervisor.MonitorRunnable

LifecycleSupervisor.Status - Class in org.apache.flume.lifecycle

LifecycleSupervisor.Status() - Constructor for class org.apache.flume.lifecycle.LifecycleSupervisor.Status

LifecycleSupervisor.SupervisorPolicy - Class in org.apache.flume.lifecycle

LifecycleSupervisor.SupervisorPolicy() - Constructor for class org.apache.flume.lifecycle.LifecycleSupervisor.SupervisorPolicy

LifecycleSupervisor.SupervisorPolicy.AlwaysRestartPolicy - Class in org.apache.flume.lifecycle

LifecycleSupervisor.SupervisorPolicy.AlwaysRestartPolicy() - Constructor for class org.apache.flume.lifecycle.LifecycleSupervisor.SupervisorPolicy.AlwaysRestartPolicy

LifecycleSupervisor.SupervisorPolicy.OnceOnlyPolicy - Class in org.apache.flume.lifecycle

LifecycleSupervisor.SupervisorPolicy.OnceOnlyPolicy() - Constructor for class org.apache.flume.lifecycle.LifecycleSupervisor.SupervisorPolicy.OnceOnlyPolicy

load() - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

load() - Method in class org.apache.flume.conf.file.JsonFileConfigurationProvider

load() - Method in class org.apache.flume.conf.properties.PropertiesFileConfigurationProvider

loadPlugins() - Method in class org.apache.flume.node.Application

LoggerSink - Class in org.apache.flume.sink

A Sink implementation that logs all events received at the INFO level to the org.apache.flume.sink.LoggerSink logger.

LoggerSink() - Constructor for class org.apache.flume.sink.LoggerSink

logPut(MemoryChannel.StampedEvent, int) - Method in class org.apache.flume.channel.MemoryChannel.MemTransaction

logTake(MemoryChannel.StampedEvent, int) - Method in class org.apache.flume.channel.MemoryChannel.MemTransaction

M

main(String[]) - Static method in class org.apache.flume.client.avro.AvroCLIClient

main(String[]) - Static method in class org.apache.flume.node.Application

MemoryChannel - Class in org.apache.flume.channel

Memory channel that with full transaction support Uses transaction object for each thread (source and sink) attached to channel.

MemoryChannel() - Constructor for class org.apache.flume.channel.MemoryChannel

Channel constructor

MemoryChannel.MemTransaction - Class in org.apache.flume.channel

MemoryChannel.MemTransaction() - Constructor for class org.apache.flume.channel.MemoryChannel.MemTransaction

monitorService - Variable in class org.apache.flume.lifecycle.LifecycleSupervisor.MonitorRunnable

MySQLSchemaHandler - Class in org.apache.flume.channel.jdbc.impl

MySQLSchemaHandler(DataSource) - Constructor for class org.apache.flume.channel.jdbc.impl.MySQLSchemaHandler

N

NetcatSource - Class in org.apache.flume.source

A netcat-like source that listens on a given port and turns each line of text into an event.

NetcatSource() - Constructor for class org.apache.flume.source.NetcatSource

NetcatSource.AcceptHandler - Class in org.apache.flume.source

NetcatSource.AcceptHandler() - Constructor for class org.apache.flume.source.NetcatSource.AcceptHandler

NetcatSource.NetcatSocketHandler - Class in org.apache.flume.source

NetcatSource.NetcatSocketHandler() - Constructor for class org.apache.flume.source.NetcatSource.NetcatSocketHandler

newBuilder() - Static method in class org.apache.flume.source.avro.AvroFlumeEvent

Creates a new AvroFlumeEvent RecordBuilder

newBuilder(AvroFlumeEvent.Builder) - Static method in class org.apache.flume.source.avro.AvroFlumeEvent

Creates a new AvroFlumeEvent RecordBuilder by copying an existing Builder

newBuilder(AvroFlumeEvent) - Static method in class org.apache.flume.source.avro.AvroFlumeEvent

Creates a new AvroFlumeEvent RecordBuilder by copying an existing AvroFlumeEvent instance

nextFile() - Method in class org.apache.flume.formatter.output.PathManager

NodeConfiguration - Interface in org.apache.flume.node

NodeConfigurationAware - Interface in org.apache.flume.node.nodemanager

NodeManager - Interface in org.apache.flume.node

NullSink - Class in org.apache.flume.sink

A Sink implementation that simply discards all events it receives.

NullSink() - Constructor for class org.apache.flume.sink.NullSink

O

onNodeConfigurationChanged(NodeConfiguration) - Method in class org.apache.flume.node.nodemanager.DefaultLogicalNodeManager

onNodeConfigurationChanged(NodeConfiguration) - Method in interface org.apache.flume.node.nodemanager.NodeConfigurationAware

open() - Method in class org.apache.flume.sink.hdfs.BucketWriter

open(String, HDFSWriter, FlumeFormatter) - Method in class org.apache.flume.sink.hdfs.BucketWriter

open(String, CompressionCodec, SequenceFile.CompressionType, HDFSWriter, FlumeFormatter) - Method in class org.apache.flume.sink.hdfs.BucketWriter

open(String, FlumeFormatter) - Method in class org.apache.flume.sink.hdfs.HDFSCompressedDataStream

open(String, CompressionCodec, SequenceFile.CompressionType, FlumeFormatter) - Method in class org.apache.flume.sink.hdfs.HDFSCompressedDataStream

open(String, FlumeFormatter) - Method in class org.apache.flume.sink.hdfs.HDFSDataStream

open(String, CompressionCodec, SequenceFile.CompressionType, FlumeFormatter) - Method in class org.apache.flume.sink.hdfs.HDFSDataStream

open(String, FlumeFormatter) - Method in class org.apache.flume.sink.hdfs.HDFSSequenceFile

open(String, CompressionCodec, SequenceFile.CompressionType, FlumeFormatter) - Method in class org.apache.flume.sink.hdfs.HDFSSequenceFile

open(String, FlumeFormatter) - Method in interface org.apache.flume.sink.hdfs.HDFSWriter

open(String, CompressionCodec, SequenceFile.CompressionType, FlumeFormatter) - Method in interface org.apache.flume.sink.hdfs.HDFSWriter

org.apache.flume - package org.apache.flume

org.apache.flume.channel - package org.apache.flume.channel

org.apache.flume.channel.file - package org.apache.flume.channel.file

org.apache.flume.channel.jdbc - package org.apache.flume.channel.jdbc

org.apache.flume.channel.jdbc.impl - package org.apache.flume.channel.jdbc.impl

org.apache.flume.client.avro - package org.apache.flume.client.avro

org.apache.flume.conf - package org.apache.flume.conf

org.apache.flume.conf.file - package org.apache.flume.conf.file

org.apache.flume.conf.properties - package org.apache.flume.conf.properties

org.apache.flume.event - package org.apache.flume.event

org.apache.flume.formatter.output - package org.apache.flume.formatter.output

org.apache.flume.lifecycle - package org.apache.flume.lifecycle

org.apache.flume.node - package org.apache.flume.node

org.apache.flume.node.nodemanager - package org.apache.flume.node.nodemanager

org.apache.flume.sink - package org.apache.flume.sink

org.apache.flume.sink.hdfs - package org.apache.flume.sink.hdfs

org.apache.flume.source - package org.apache.flume.source

org.apache.flume.source.avro - package org.apache.flume.source.avro

P

parseOptions() - Method in class org.apache.flume.node.Application

PathManager - Class in org.apache.flume.formatter.output

PathManager() - Constructor for class org.apache.flume.formatter.output.PathManager

PAYLOAD_LENGTH_THRESHOLD - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants

The length for payload bytes that will be stored inline.

PersistableEvent - Class in org.apache.flume.channel.jdbc.impl

PersistableEvent(String, Event) - Constructor for class org.apache.flume.channel.jdbc.impl.PersistableEvent

PersistableEvent.Builder - Class in org.apache.flume.channel.jdbc.impl

PersistableEvent.Builder(String, long) - Constructor for class org.apache.flume.channel.jdbc.impl.PersistableEvent.Builder

PersistableEvent.HeaderEntry - Class in org.apache.flume.channel.jdbc.impl

PersistableEvent.HeaderEntry(String, String) - Constructor for class org.apache.flume.channel.jdbc.impl.PersistableEvent.HeaderEntry

PersistableEvent.SpillableString - Class in org.apache.flume.channel.jdbc.impl

PersistableEvent.SpillableString(String, int) - Constructor for class org.apache.flume.channel.jdbc.impl.PersistableEvent.SpillableString

persistEvent(String, Event) - Method in class org.apache.flume.channel.jdbc.impl.JdbcChannelProviderImpl

persistEvent(String, Event) - Method in interface org.apache.flume.channel.jdbc.JdbcChannelProvider

Writes the event to the persistent store.

PollableSink - Interface in org.apache.flume

PollableSink.Status - Enum in org.apache.flume

PollableSinkRunner - Class in org.apache.flume.sink

PollableSinkRunner() - Constructor for class org.apache.flume.sink.PollableSinkRunner

PollableSinkRunner.PollingRunner - Class in org.apache.flume.sink

PollableSinkRunner.PollingRunner() - Constructor for class org.apache.flume.sink.PollableSinkRunner.PollingRunner

PollableSource - Interface in org.apache.flume

PollableSource.Status - Enum in org.apache.flume

PollableSourceRunner - Class in org.apache.flume.source

An implementation of SourceRunner that can drive a PollableSource.

PollableSourceRunner() - Constructor for class org.apache.flume.source.PollableSourceRunner

PollableSourceRunner.PollingRunner - Class in org.apache.flume.source

PollableSourceRunner.PollingRunner() - Constructor for class org.apache.flume.source.PollableSourceRunner.PollingRunner

PREFIX - Static variable in class org.apache.flume.channel.jdbc.ConfigurationConstants

process() - Method in interface org.apache.flume.PollableSink

process() - Method in interface org.apache.flume.PollableSource

process() - Method in class org.apache.flume.sink.AvroSink

process() - Method in class org.apache.flume.sink.hdfs.HDFSEventSink

Pull events out of channel and send it to HDFS - take at the most txnEventMax, that's the maximum #events to hold in channel for a given transaction - find the corresponding bucket for the event, ensure the file is open - extract the pay-load and append to HDFS file

process() - Method in class org.apache.flume.sink.LoggerSink

process() - Method in class org.apache.flume.sink.NullSink

process() - Method in class org.apache.flume.sink.RollingFileSink

process() - Method in class org.apache.flume.source.SequenceGeneratorSource

PropertiesFileConfigurationProvider - Class in org.apache.flume.conf.properties

A configuration provider that uses properties file for specifying configuration.

PropertiesFileConfigurationProvider() - Constructor for class org.apache.flume.conf.properties.PropertiesFileConfigurationProvider

PROTOCOL - Static variable in interface org.apache.flume.source.avro.AvroSourceProtocol.Callback

PROTOCOL - Static variable in interface org.apache.flume.source.avro.AvroSourceProtocol

PseudoTxnMemoryChannel - Class in org.apache.flume.channel

A capacity-capped Channel implementation that supports in-memory buffering and delivery of events.

PseudoTxnMemoryChannel() - Constructor for class org.apache.flume.channel.PseudoTxnMemoryChannel

PseudoTxnMemoryChannel.NoOpTransaction - Class in org.apache.flume.channel

A no-op transaction implementation that does nothing at all.

PseudoTxnMemoryChannel.NoOpTransaction() - Constructor for class org.apache.flume.channel.PseudoTxnMemoryChannel.NoOpTransaction

put(Event) - Method in class org.apache.flume.channel.FanoutChannel

put(Event) - Method in class org.apache.flume.channel.file.FileChannel

put(Event) - Method in class org.apache.flume.channel.jdbc.JdbcChannel

put(Event) - Method in class org.apache.flume.channel.MemoryChannel

put(Event) - Method in class org.apache.flume.channel.PseudoTxnMemoryChannel

put(Event) - Method in interface org.apache.flume.Channel

Puts the given event in the channel.

put(String, Object) - Method in class org.apache.flume.Context

put(int, Object) - Method in class org.apache.flume.source.avro.AvroFlumeEvent

Q

QUERY_CHANNEL_SIZE - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

QUERY_CREATE_INDEX_FLE_CHANNEL - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

QUERY_CREATE_INDEX_FLH_EVENT - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

QUERY_CREATE_INDEX_FLN_HEADER - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

QUERY_CREATE_INDEX_FLP_EVENT - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

QUERY_CREATE_INDEX_FLV_HEADER - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

QUERY_CREATE_SCHEMA_FLUME - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

QUERY_CREATE_TABLE_FL_EVENT - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

QUERY_CREATE_TABLE_FL_HEADER - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

QUERY_CREATE_TABLE_FL_NMSPILL - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

QUERY_CREATE_TABLE_FL_PLSPILL - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

QUERY_CREATE_TABLE_FL_VLSPILL - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

R

register(String, Class<? extends Channel>) - Method in class org.apache.flume.channel.DefaultChannelFactory

register(String, Class<? extends Channel>) - Method in interface org.apache.flume.ChannelFactory

register(String, Class<? extends Sink>) - Method in class org.apache.flume.sink.DefaultSinkFactory

register(String, Class<? extends Sink>) - Method in interface org.apache.flume.SinkFactory

register(String, Class<? extends Source>) - Method in class org.apache.flume.source.DefaultSourceFactory

register(String, Class<? extends Source>) - Method in interface org.apache.flume.SourceFactory

releaseProvider(String) - Static method in class org.apache.flume.channel.jdbc.JdbcChannelProviderFactory

remove(LifecycleAware) - Method in class org.apache.flume.node.nodemanager.AbstractLogicalNodeManager

remove(LifecycleAware) - Method in class org.apache.flume.node.nodemanager.DefaultLogicalNodeManager

remove(LifecycleAware) - Method in interface org.apache.flume.node.NodeManager

removeEvent(String) - Method in class org.apache.flume.channel.jdbc.impl.JdbcChannelProviderImpl

removeEvent(String) - Method in interface org.apache.flume.channel.jdbc.JdbcChannelProvider

Removes the next event for the named channel from the underlying persistent store.

removePut() - Method in class org.apache.flume.channel.MemoryChannel.MemTransaction

removeTake() - Method in class org.apache.flume.channel.MemoryChannel.MemTransaction

replaceShorthand(char, Map<String, String>) - Static method in class org.apache.flume.formatter.output.BucketPath

Hardcoded lookups for %x style escape replacement.

rollback() - Method in class org.apache.flume.channel.FanoutChannel.wrapperTransaction

rollback() - Method in class org.apache.flume.channel.file.FileChannel.FileBackedTransaction

rollback() - Method in class org.apache.flume.channel.jdbc.impl.JdbcTransactionImpl

rollback() - Method in class org.apache.flume.channel.MemoryChannel.MemTransaction

rollback() - Method in class org.apache.flume.channel.PseudoTxnMemoryChannel.NoOpTransaction

rollback() - Method in interface org.apache.flume.Transaction

Indicates that the transaction can must be aborted.

RollingFileSink - Class in org.apache.flume.sink

RollingFileSink() - Constructor for class org.apache.flume.sink.RollingFileSink

rotate() - Method in class org.apache.flume.formatter.output.PathManager

run() - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider.FileWatcherRunnable

run() - Method in class org.apache.flume.lifecycle.LifecycleSupervisor.MonitorRunnable

run() - Method in class org.apache.flume.node.Application

run() - Method in class org.apache.flume.sink.PollableSinkRunner.PollingRunner

run() - Method in class org.apache.flume.source.NetcatSource.AcceptHandler

run() - Method in class org.apache.flume.source.NetcatSource.NetcatSocketHandler

run() - Method in class org.apache.flume.source.PollableSourceRunner.PollingRunner

S

SCHEMA$ - Static variable in class org.apache.flume.source.avro.AvroFlumeEvent

SCHEMA$ - Static variable in enum org.apache.flume.source.avro.Status

schemaExists() - Method in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

schemaExists() - Method in class org.apache.flume.channel.jdbc.impl.MySQLSchemaHandler

schemaExists() - Method in interface org.apache.flume.channel.jdbc.impl.SchemaHandler

SchemaHandler - Interface in org.apache.flume.channel.jdbc.impl

A handler for creating and validating database schema for use by the JDBC channel implementation.

SchemaHandlerFactory - Class in org.apache.flume.channel.jdbc.impl

A factory for SchemaHandlers.

SequenceGeneratorSource - Class in org.apache.flume.source

SequenceGeneratorSource() - Constructor for class org.apache.flume.source.SequenceGeneratorSource

set(String, Long) - Method in class org.apache.flume.CounterGroup

setArgs(String[]) - Method in class org.apache.flume.node.Application

setBaseDirectory(File) - Method in class org.apache.flume.formatter.output.PathManager

setBasePayload(byte[]) - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.Builder

setBody(byte[]) - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent

setBody(byte[]) - Method in interface org.apache.flume.Event

setBody(byte[]) - Method in class org.apache.flume.event.SimpleEvent

setBody(ByteBuffer) - Method in class org.apache.flume.source.avro.AvroFlumeEvent.Builder

Sets the value of the 'body' field

setBody(ByteBuffer) - Method in class org.apache.flume.source.avro.AvroFlumeEvent

Sets the value of the 'body' field.

setChannel(String) - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.Builder

setChannel(Channel) - Method in class org.apache.flume.sink.AbstractSink

setChannel(Channel) - Method in interface org.apache.flume.Sink

setChannel(Channel) - Method in class org.apache.flume.source.AbstractSource

setChannel(Channel) - Method in interface org.apache.flume.Source

setChannelFactory(ChannelFactory) - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

setChannelRegistry(Map<String, Class<? extends Channel>>) - Method in class org.apache.flume.channel.DefaultChannelFactory

setChannels(Map<String, Channel>) - Method in class org.apache.flume.conf.file.SimpleNodeConfiguration

setConfigurationAware(NodeConfigurationAware) - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

setConfigurationProvider(ConfigurationProvider) - Method in class org.apache.flume.node.FlumeNode

setCounters(HashMap<String, AtomicLong>) - Method in class org.apache.flume.CounterGroup

setDesiredState(LifecycleAware, LifecycleState) - Method in class org.apache.flume.lifecycle.LifecycleSupervisor

setDirectory(File) - Method in class org.apache.flume.channel.file.FileChannel

setDirectory(File) - Method in class org.apache.flume.sink.RollingFileSink

setEventId(long) - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.Builder

setEventId(long) - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent

setFile(File) - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

setFormatter(EventFormatter) - Method in class org.apache.flume.sink.RollingFileSink

setHeader(long, String, String) - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.Builder

setHeaderNameSpill(long, String) - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.Builder

setHeaders(Map<String, String>) - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent

setHeaders(Map<String, String>) - Method in interface org.apache.flume.Event

setHeaders(Map<String, String>) - Method in class org.apache.flume.event.SimpleEvent

setHeaders(Map<CharSequence, CharSequence>) - Method in class org.apache.flume.source.avro.AvroFlumeEvent.Builder

Sets the value of the 'headers' field

setHeaders(Map<CharSequence, CharSequence>) - Method in class org.apache.flume.source.avro.AvroFlumeEvent

Sets the value of the 'headers' field.

setHeaderValueSpill(long, String) - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.Builder

setId(long) - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.HeaderEntry

setName(String) - Method in class org.apache.flume.CounterGroup

setName(String) - Method in class org.apache.flume.node.FlumeNode

setNodeManager(NodeManager) - Method in class org.apache.flume.node.FlumeNode

setNodeName(String) - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

setNodes(Set<LifecycleAware>) - Method in class org.apache.flume.node.nodemanager.AbstractLogicalNodeManager

setNodes(Set<LifecycleAware>) - Method in interface org.apache.flume.node.NodeManager

setParameters(Map<String, Object>) - Method in class org.apache.flume.Context

setRollInterval(long) - Method in class org.apache.flume.sink.RollingFileSink

setSink(Sink) - Method in class org.apache.flume.SinkRunner

setSinkFactory(SinkFactory) - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

setSinkRegistry(Map<String, Class<? extends Sink>>) - Method in class org.apache.flume.sink.DefaultSinkFactory

setSinkRunners(Map<String, SinkRunner>) - Method in class org.apache.flume.conf.file.SimpleNodeConfiguration

setSource(Source) - Method in class org.apache.flume.SourceRunner

setSourceFactory(SourceFactory) - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

setSourceRegistry(Map<String, Class<? extends Source>>) - Method in class org.apache.flume.source.DefaultSourceFactory

setSourceRunners(Map<String, SourceRunner>) - Method in class org.apache.flume.conf.file.SimpleNodeConfiguration

setSpillPayload(byte[]) - Method in class org.apache.flume.channel.jdbc.impl.PersistableEvent.Builder

sharedInstance() - Static method in class org.apache.flume.channel.PseudoTxnMemoryChannel.NoOpTransaction

shouldRotate() - Method in class org.apache.flume.sink.hdfs.BucketWriter

shutdown() - Method in class org.apache.flume.channel.FanoutChannel

shutdown() - Method in class org.apache.flume.channel.file.FileChannel

shutdown() - Method in class org.apache.flume.channel.jdbc.JdbcChannel

shutdown() - Method in class org.apache.flume.channel.MemoryChannel

shutdown() - Method in class org.apache.flume.channel.PseudoTxnMemoryChannel

shutdown() - Method in interface org.apache.flume.Channel

Instructs the channel to release any resources held in preparation of shutting down.

SimpleEvent - Class in org.apache.flume.event

SimpleEvent() - Constructor for class org.apache.flume.event.SimpleEvent

SimpleNodeConfiguration - Class in org.apache.flume.conf.file

SimpleNodeConfiguration() - Constructor for class org.apache.flume.conf.file.SimpleNodeConfiguration

Sink - Interface in org.apache.flume

SinkFactory - Interface in org.apache.flume

sinkRegistry - Variable in class org.apache.flume.sink.DefaultSinkFactory

SinkRunner - Class in org.apache.flume

SinkRunner() - Constructor for class org.apache.flume.SinkRunner

Source - Interface in org.apache.flume

SourceFactory - Interface in org.apache.flume

sourceRegistry - Variable in class org.apache.flume.source.DefaultSourceFactory

SourceRunner - Class in org.apache.flume

SourceRunner() - Constructor for class org.apache.flume.SourceRunner

start() - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

start() - Method in interface org.apache.flume.lifecycle.LifecycleAware

Starts a service or component.

start() - Method in class org.apache.flume.lifecycle.LifecycleSupervisor

start() - Method in class org.apache.flume.node.FlumeNode

start() - Method in class org.apache.flume.node.nodemanager.DefaultLogicalNodeManager

start() - Method in class org.apache.flume.sink.AbstractSink

start() - Method in class org.apache.flume.sink.AvroSink

start() - Method in class org.apache.flume.sink.hdfs.HDFSEventSink

start() - Method in class org.apache.flume.sink.NullSink

start() - Method in class org.apache.flume.sink.PollableSinkRunner

start() - Method in class org.apache.flume.sink.RollingFileSink

start() - Method in class org.apache.flume.source.AbstractSource

start() - Method in class org.apache.flume.source.AvroSource

start() - Method in class org.apache.flume.source.EventDrivenSourceRunner

start() - Method in class org.apache.flume.source.ExecSource

start() - Method in class org.apache.flume.source.NetcatSource

start() - Method in class org.apache.flume.source.PollableSourceRunner

start() - Method in class org.apache.flume.source.SequenceGeneratorSource

START_OR_ERROR - Static variable in enum org.apache.flume.lifecycle.LifecycleState

Status - Enum in org.apache.flume.source.avro

STMT_DELETE_EVENT_BASE - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

STMT_DELETE_EVENT_SPILL - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

STMT_DELETE_HEADER_BASE - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

STMT_DELETE_HEADER_NAME_SPILL - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

STMT_DELETE_HEADER_VALUE_SPILL - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

STMT_FETCH_HEADER_BASE - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

STMT_FETCH_HEADER_NAME_SPILL - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

STMT_FETCH_HEADER_VALUE_SPILL - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

STMT_FETCH_PAYLOAD_BASE - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

STMT_FETCH_PAYLOAD_SPILL - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

STMT_INSERT_EVENT_BASE - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

STMT_INSERT_EVENT_SPILL - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

STMT_INSERT_HEADER_BASE - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

STMT_INSERT_HEADER_NAME_SPILL - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

STMT_INSERT_HEADER_VALUE_SPILL - Static variable in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

stop() - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

stop() - Method in interface org.apache.flume.lifecycle.LifecycleAware

Stops a service or component.

stop() - Method in class org.apache.flume.lifecycle.LifecycleSupervisor

stop() - Method in class org.apache.flume.node.FlumeNode

stop() - Method in class org.apache.flume.node.nodemanager.DefaultLogicalNodeManager

stop() - Method in class org.apache.flume.sink.AbstractSink

stop() - Method in class org.apache.flume.sink.AvroSink

stop() - Method in class org.apache.flume.sink.hdfs.HDFSEventSink

stop() - Method in class org.apache.flume.sink.NullSink

stop() - Method in class org.apache.flume.sink.PollableSinkRunner

stop() - Method in class org.apache.flume.sink.RollingFileSink

stop() - Method in class org.apache.flume.source.AbstractSource

stop() - Method in class org.apache.flume.source.AvroSource

stop() - Method in class org.apache.flume.source.EventDrivenSourceRunner

stop() - Method in class org.apache.flume.source.ExecSource

stop() - Method in class org.apache.flume.source.NetcatSource

stop() - Method in class org.apache.flume.source.PollableSourceRunner

stop() - Method in class org.apache.flume.source.SequenceGeneratorSource

STOP_OR_ERROR - Static variable in enum org.apache.flume.lifecycle.LifecycleState

stopAll(List<LifecycleAware>) - Static method in class org.apache.flume.lifecycle.LifecycleController

storeEvent(PersistableEvent, Connection) - Method in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

storeEvent(PersistableEvent, Connection) - Method in class org.apache.flume.channel.jdbc.impl.MySQLSchemaHandler

storeEvent(PersistableEvent, Connection) - Method in interface org.apache.flume.channel.jdbc.impl.SchemaHandler

Inserts the given persistent event into the database.

supervise(LifecycleAware, LifecycleSupervisor.SupervisorPolicy, LifecycleState) - Method in class org.apache.flume.lifecycle.LifecycleSupervisor

supervisoree - Variable in class org.apache.flume.lifecycle.LifecycleSupervisor.MonitorRunnable

sync() - Method in class org.apache.flume.sink.hdfs.BucketWriter

sync() - Method in class org.apache.flume.sink.hdfs.HDFSCompressedDataStream

sync() - Method in class org.apache.flume.sink.hdfs.HDFSDataStream

sync() - Method in class org.apache.flume.sink.hdfs.HDFSSequenceFile

sync() - Method in interface org.apache.flume.sink.hdfs.HDFSWriter

SYSPROP_CALLED_FROM_SERVICE - Static variable in class org.apache.flume.Constants

T

TAG_REGEX - Static variable in class org.apache.flume.formatter.output.BucketPath

These are useful to other classes which might want to search for tags in strings.

tagPattern - Static variable in class org.apache.flume.formatter.output.BucketPath

take() - Method in class org.apache.flume.channel.FanoutChannel

take() - Method in class org.apache.flume.channel.file.FileChannel

take() - Method in class org.apache.flume.channel.jdbc.JdbcChannel

take() - Method in class org.apache.flume.channel.MemoryChannel

take() - Method in class org.apache.flume.channel.PseudoTxnMemoryChannel

take() - Method in interface org.apache.flume.Channel

Returns the next event from the channel if available.

TextDelimitedOutputFormatter - Class in org.apache.flume.formatter.output

TextDelimitedOutputFormatter() - Constructor for class org.apache.flume.formatter.output.TextDelimitedOutputFormatter

toString() - Method in class org.apache.flume.channel.DefaultChannelFactory

toString() - Method in class org.apache.flume.channel.file.FileChannel.FileBackedTransaction

toString() - Method in enum org.apache.flume.channel.jdbc.DatabaseType

toString() - Method in enum org.apache.flume.channel.jdbc.TransactionIsolation

toString() - Method in class org.apache.flume.conf.file.AbstractFileConfigurationProvider

toString() - Method in class org.apache.flume.conf.file.SimpleNodeConfiguration

toString() - Method in class org.apache.flume.conf.properties.FlumeConfiguration.AgentConfiguration

toString() - Method in class org.apache.flume.conf.properties.FlumeConfiguration.ComponentConfiguration

toString() - Method in class org.apache.flume.Context

toString() - Method in class org.apache.flume.CounterGroup

toString() - Method in class org.apache.flume.event.SimpleEvent

toString() - Method in class org.apache.flume.lifecycle.LifecycleSupervisor.Status

toString() - Method in class org.apache.flume.node.FlumeNode

toString() - Method in class org.apache.flume.node.nodemanager.AbstractLogicalNodeManager

toString() - Method in class org.apache.flume.sink.DefaultSinkFactory

toString() - Method in class org.apache.flume.sink.PollableSinkRunner

toString() - Method in class org.apache.flume.source.AvroSource

toString() - Method in class org.apache.flume.source.DefaultSourceFactory

toString() - Method in class org.apache.flume.source.EventDrivenSourceRunner

toString() - Method in class org.apache.flume.source.PollableSourceRunner

Transaction - Interface in org.apache.flume

Provides the transaction boundary while accessing a channel.

Transaction.TransactionState - Enum in org.apache.flume

TransactionIsolation - Enum in org.apache.flume.channel.jdbc

U

undoPut(MemoryChannel.MemTransaction) - Method in class org.apache.flume.channel.MemoryChannel

undo of put for all the events in the undoPut queue, remove those from the event queue

undoTake(MemoryChannel.MemTransaction) - Method in class org.apache.flume.channel.MemoryChannel

undo of take operation for each event in the undoTake list, add it back to the event queue

unregister(String) - Method in class org.apache.flume.channel.DefaultChannelFactory

unregister(String) - Method in interface org.apache.flume.ChannelFactory

unregister(String) - Method in class org.apache.flume.sink.DefaultSinkFactory

unregister(String) - Method in interface org.apache.flume.SinkFactory

unregister(String) - Method in class org.apache.flume.source.DefaultSourceFactory

unregister(String) - Method in interface org.apache.flume.SourceFactory

unsupervise(LifecycleAware) - Method in class org.apache.flume.lifecycle.LifecycleSupervisor

V

validateSchema() - Method in class org.apache.flume.channel.jdbc.impl.DerbySchemaHandler

validateSchema() - Method in class org.apache.flume.channel.jdbc.impl.MySQLSchemaHandler

validateSchema() - Method in interface org.apache.flume.channel.jdbc.impl.SchemaHandler

Validates the schema.

valueOf(String) - Static method in enum org.apache.flume.channel.jdbc.DatabaseType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flume.channel.jdbc.TransactionIsolation

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flume.lifecycle.LifecycleState

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flume.PollableSink.Status

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flume.PollableSource.Status

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flume.sink.hdfs.BucketWriter.BucketFlushStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flume.source.avro.Status

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flume.Transaction.TransactionState

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.flume.channel.jdbc.DatabaseType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flume.channel.jdbc.TransactionIsolation

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flume.lifecycle.LifecycleState

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flume.PollableSink.Status

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flume.PollableSource.Status

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flume.sink.hdfs.BucketWriter.BucketFlushStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flume.source.avro.Status

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flume.Transaction.TransactionState

Returns an array containing the constants of this enum type, in the order they are declared.

W

waitForOneOf(LifecycleAware, LifecycleState[]) - Static method in class org.apache.flume.lifecycle.LifecycleController

waitForOneOf(LifecycleAware, LifecycleState[], long) - Static method in class org.apache.flume.lifecycle.LifecycleController

waitForState(LifecycleAware, LifecycleState) - Static method in class org.apache.flume.lifecycle.LifecycleController

waitForState(LifecycleAware, LifecycleState, long) - Static method in class org.apache.flume.lifecycle.LifecycleController

withBody(byte[]) - Static method in class org.apache.flume.event.EventBuilder

withBody(byte[], Map<String, String>) - Static method in class org.apache.flume.event.EventBuilder

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