|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
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
|
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.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 | |
---|---|
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 |
---|
Classes in org.apache.flume.sink that implement LifecycleAware | |
---|---|
class |
AbstractSink
|
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 is in no way thread safe and expects to be run via SinkRunner Additionally, setSinks must be called before configure, and additional sinks cannot be added while running To configure, set a sink groups processor to "failover" and set priorities for individual sinks: Ex) host1.sinkgroups = group1 host1.sinkgroups.group1.sinks = sink1 sink2 host1.sinkgroups.group1.processor.type = failover host1.sinkgroups.group1.processor.priority.sink1 = 5 host1.sinkgroups.group1.processor.priority.sink2 = 10 |
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.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 |
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 |
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.thriftLegacy |
---|
Classes in org.apache.flume.source.thriftLegacy that implement LifecycleAware | |
---|---|
class |
ThriftLegacySource
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |