Uses of Interface
org.apache.flume.lifecycle.LifecycleAware

Packages that use LifecycleAware

org.apache.flume
org.apache.flume.channel
org.apache.flume.channel.file
org.apache.flume.channel.jdbc
org.apache.flume.channel.recoverable.memory
org.apache.flume.conf.file
org.apache.flume.conf.properties
org.apache.flume.lifecycle
org.apache.flume.node
org.apache.flume.node.nodemanager
org.apache.flume.sink
org.apache.flume.sink.elasticsearch
org.apache.flume.sink.hbase
org.apache.flume.sink.hdfs
org.apache.flume.sink.irc
org.apache.flume.source
org.apache.flume.source.avroLegacy
org.apache.flume.source.http
org.apache.flume.source.scribe
org.apache.flume.source.thriftLegacy

Uses of LifecycleAware in org.apache.flume

Subinterfaces of LifecycleAware in org.apache.flume

interface	Channel A channel connects a Source to a Sink.
interface	EventDrivenSource 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.
interface	PollableSource A Source that requires an external driver to poll to determine whether there are events that are available to ingest from the source.
interface	Sink A sink is connected to a Channel and consumes its contents, sending them to a configured destination that may vary according to the sink type.
interface	SinkProcessor Interface for a device that allows abstraction of the behavior of multiple sinks, always assigned to a SinkRunner
interface	Source A source generates and calls methods on the configured ChannelProcessor to persist those events into the configured channels.

Classes in org.apache.flume that implement LifecycleAware

class	SinkRunner A driver for sinks that polls them, attempting to process events if any are available in the Channel.
class	SourceRunner A source runner controls how a source is driven.

Uses of LifecycleAware in org.apache.flume.channel

Classes in org.apache.flume.channel that implement LifecycleAware

class	AbstractChannel
class	BasicChannelSemantics An implementation of basic Channel semantics, including the implied thread-local semantics of the Transaction class, which is required to extend BasicTransactionSemantics.
class	MemoryChannel MemoryChannel is the recommended channel to use when speeds which writing to disk is impractical is required or durability of data is not required.
class	PseudoTxnMemoryChannel A capacity-capped Channel implementation that supports in-memory buffering and delivery of events.

Uses of LifecycleAware in org.apache.flume.channel.file

Classes in org.apache.flume.channel.file that implement LifecycleAware

class

FileChannel A durable Channel implementation that uses the local file system for its storage.

Uses of LifecycleAware in org.apache.flume.channel.jdbc

Classes in org.apache.flume.channel.jdbc that implement LifecycleAware

class

JdbcChannel A JDBC based channel implementation.

Uses of LifecycleAware in org.apache.flume.channel.recoverable.memory

Classes in org.apache.flume.channel.recoverable.memory that implement LifecycleAware

class

RecoverableMemoryChannel Deprecated. The RecoverableMemoryChannel has been deprecated in favor of FileChannel, which gives better performance and is also durable.

Uses of LifecycleAware in org.apache.flume.conf.file

Classes in org.apache.flume.conf.file that implement LifecycleAware

class

AbstractFileConfigurationProvider

Uses of LifecycleAware in org.apache.flume.conf.properties

Classes in org.apache.flume.conf.properties that implement LifecycleAware

class

PropertiesFileConfigurationProvider A configuration provider that uses properties file for specifying configuration.

Uses of LifecycleAware in org.apache.flume.lifecycle

Classes in org.apache.flume.lifecycle that implement LifecycleAware

class

LifecycleSupervisor

Fields in org.apache.flume.lifecycle declared as LifecycleAware

LifecycleAware

LifecycleSupervisor.MonitorRunnable.lifecycleAware

Methods in org.apache.flume.lifecycle with parameters of type LifecycleAware

boolean	LifecycleSupervisor.isComponentInErrorState(LifecycleAware component)
void	LifecycleSupervisor.setDesiredState(LifecycleAware lifecycleAware, LifecycleState desiredState)
void	LifecycleSupervisor.supervise(LifecycleAware lifecycleAware, LifecycleSupervisor.SupervisorPolicy policy, LifecycleState desiredState)
void	LifecycleSupervisor.unsupervise(LifecycleAware lifecycleAware)
static boolean	LifecycleController.waitForOneOf(LifecycleAware delegate, LifecycleState[] states)
static boolean	LifecycleController.waitForOneOf(LifecycleAware delegate, LifecycleState[] states, long timeout)
static boolean	LifecycleController.waitForState(LifecycleAware delegate, LifecycleState state)
static boolean	LifecycleController.waitForState(LifecycleAware delegate, LifecycleState state, long timeout)

Method parameters in org.apache.flume.lifecycle with type arguments of type LifecycleAware

static void

LifecycleController.stopAll(List<LifecycleAware> services)

Uses of LifecycleAware in org.apache.flume.node

Subinterfaces of LifecycleAware in org.apache.flume.node

interface	ConfigurationProvider
interface	NodeManager

Classes in org.apache.flume.node that implement LifecycleAware

class

FlumeNode

Methods in org.apache.flume.node that return types with arguments of type LifecycleAware

Set<LifecycleAware>

NodeManager.getNodes()

Methods in org.apache.flume.node with parameters of type LifecycleAware

boolean	NodeManager.add(LifecycleAware node)
boolean	NodeManager.remove(LifecycleAware node)

Method parameters in org.apache.flume.node with type arguments of type LifecycleAware

void	NodeManager.setNodes(Set<LifecycleAware> nodes)

Uses of LifecycleAware in org.apache.flume.node.nodemanager

Classes in org.apache.flume.node.nodemanager that implement LifecycleAware

class	AbstractLogicalNodeManager
class	DefaultLogicalNodeManager

Methods in org.apache.flume.node.nodemanager that return types with arguments of type LifecycleAware

Set<LifecycleAware>

AbstractLogicalNodeManager.getNodes()

Methods in org.apache.flume.node.nodemanager with parameters of type LifecycleAware

boolean	DefaultLogicalNodeManager.add(LifecycleAware node)
boolean	AbstractLogicalNodeManager.add(LifecycleAware node)
boolean	DefaultLogicalNodeManager.remove(LifecycleAware node)
boolean	AbstractLogicalNodeManager.remove(LifecycleAware node)

Method parameters in org.apache.flume.node.nodemanager with type arguments of type LifecycleAware

void	AbstractLogicalNodeManager.setNodes(Set<LifecycleAware> nodes)

Uses of LifecycleAware in org.apache.flume.sink

Subinterfaces of LifecycleAware in org.apache.flume.sink

static interface

LoadBalancingSinkProcessor.SinkSelector An interface that allows the LoadBalancingSinkProcessor to use a load-balancing strategy such as round-robin, random distribution etc.

Classes in org.apache.flume.sink that implement LifecycleAware

class	AbstractSink
class	AbstractSinkProcessor A convenience base class for sink processors.
class	AbstractSinkSelector
class	AvroSink A Sink implementation that can send events to an RPC server (such as Flume's AvroSource).
class	DefaultSinkProcessor Default sink processor that only accepts a single sink, passing on process results without any additional handling.
class	FailoverSinkProcessor FailoverSinkProcessor maintains a prioritized list of sinks, guarranteeing that so long as one is available events will be processed.
class	LoadBalancingSinkProcessor Provides the ability to load-balance flow over multiple sinks.
class	LoggerSink A Sink implementation that logs all events received at the INFO level to the org.apache.flume.sink.LoggerSink logger.
class	NullSink A Sink implementation that simply discards all events it receives.
class	RollingFileSink

Uses of LifecycleAware in org.apache.flume.sink.elasticsearch

Classes in org.apache.flume.sink.elasticsearch that implement LifecycleAware

class

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

Uses of LifecycleAware in org.apache.flume.sink.hbase

Classes in org.apache.flume.sink.hbase that implement LifecycleAware

class	AsyncHBaseSink A simple sink which reads events from a channel and writes them to HBase.
class	HBaseSink A simple sink which reads events from a channel and writes them to HBase.

Uses of LifecycleAware in org.apache.flume.sink.hdfs

Classes in org.apache.flume.sink.hdfs that implement LifecycleAware

class

HDFSEventSink

Uses of LifecycleAware in org.apache.flume.sink.irc

Classes in org.apache.flume.sink.irc that implement LifecycleAware

class

IRCSink

Uses of LifecycleAware in org.apache.flume.source

Classes in org.apache.flume.source that implement LifecycleAware

class	AbstractSource
class	AvroSource A Source implementation that receives Avro events from clients that implement AvroSourceProtocol.
class	EventDrivenSourceRunner Starts, stops, and manages event-driven sources.
class	ExecSource A Source implementation that executes a Unix process and turns each line of text into an event.
class	MultiportSyslogTCPSource
class	NetcatSource A netcat-like source that listens on a given port and turns each line of text into an event.
class	PollableSourceRunner An implementation of SourceRunner that can drive a PollableSource.
class	SequenceGeneratorSource
class	SpoolDirectorySource
class	StressSource Internal load-generating source implementation.
class	SyslogTcpSource
class	SyslogUDPSource

Uses of LifecycleAware in org.apache.flume.source.avroLegacy

Classes in org.apache.flume.source.avroLegacy that implement LifecycleAware

class

AvroLegacySource A Source implementation that receives Avro events from Avro sink of Flume OG

Uses of LifecycleAware in org.apache.flume.source.http

Classes in org.apache.flume.source.http that implement LifecycleAware

class

HTTPSource A source which accepts Flume Events by HTTP POST and GET.

Uses of LifecycleAware in org.apache.flume.source.scribe

Classes in org.apache.flume.source.scribe that implement LifecycleAware

class

ScribeSource Flume should adopt the Scribe entry LogEntry from existing Scribe system.

Uses of LifecycleAware in org.apache.flume.source.thriftLegacy

Classes in org.apache.flume.source.thriftLegacy that implement LifecycleAware

class

ThriftLegacySource