|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of LifecycleAware in org.apache.flume |
---|
Subinterfaces of LifecycleAware in org.apache.flume | |
---|---|
interface |
EventDrivenSource
|
interface |
PollableSink
|
interface |
PollableSource
|
interface |
Sink
|
interface |
Source
|
Classes in org.apache.flume that implement LifecycleAware | |
---|---|
class |
SinkRunner
|
class |
SourceRunner
|
Uses of LifecycleAware in org.apache.flume.conf.file |
---|
Classes in org.apache.flume.conf.file that implement LifecycleAware | |
---|---|
class |
AbstractFileConfigurationProvider
|
class |
JsonFileConfigurationProvider
|
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 Avro server (such as
Flume's AvroSource). |
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 |
PollableSinkRunner
|
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.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
|
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
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |