Package | Description |
---|---|
org.apache.flume | |
org.apache.flume.channel | |
org.apache.flume.lifecycle | |
org.apache.flume.node | |
org.apache.flume.sink | |
org.apache.flume.source |
Modifier and Type | Method and Description |
---|---|
LifecycleState |
SinkRunner.getLifecycleState() |
Modifier and Type | Method and Description |
---|---|
LifecycleState |
AbstractChannel.getLifecycleState() |
Modifier and Type | Field and Description |
---|---|
LifecycleState |
LifecycleSupervisor.Status.desiredState |
LifecycleState |
LifecycleSupervisor.Status.lastSeenState |
static LifecycleState[] |
LifecycleState.START_OR_ERROR |
static LifecycleState[] |
LifecycleState.STOP_OR_ERROR |
Modifier and Type | Method and Description |
---|---|
LifecycleState |
LifecycleSupervisor.getLifecycleState() |
LifecycleState |
LifecycleAware.getLifecycleState()
Return the current state of the service or component.
|
static LifecycleState |
LifecycleState.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static LifecycleState[] |
LifecycleState.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
LifecycleSupervisor.setDesiredState(LifecycleAware lifecycleAware,
LifecycleState desiredState) |
void |
LifecycleSupervisor.supervise(LifecycleAware lifecycleAware,
LifecycleSupervisor.SupervisorPolicy policy,
LifecycleState desiredState) |
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) |
Modifier and Type | Method and Description |
---|---|
LifecycleState |
PollingZooKeeperConfigurationProvider.getLifecycleState() |
LifecycleState |
PollingPropertiesFileConfigurationProvider.getLifecycleState() |
Modifier and Type | Method and Description |
---|---|
LifecycleState |
DefaultSinkProcessor.getLifecycleState() |
LifecycleState |
AbstractSinkSelector.getLifecycleState() |
LifecycleState |
AbstractSinkProcessor.getLifecycleState() |
LifecycleState |
AbstractSink.getLifecycleState() |
Modifier and Type | Method and Description |
---|---|
LifecycleState |
EventDrivenSourceRunner.getLifecycleState() |
LifecycleState |
PollableSourceRunner.getLifecycleState() |
LifecycleState |
AbstractSource.getLifecycleState() |
LifecycleState |
BasicSourceSemantics.getLifecycleState() |
Modifier and Type | Method and Description |
---|---|
protected void |
BasicSourceSemantics.setLifecycleState(LifecycleState lifecycleState) |
Copyright © 2009–2019 Apache Software Foundation. All rights reserved.