org.apache.nifi.controller.scheduling

Class ScheduleState

java.lang.Object

org.apache.nifi.controller.scheduling.ScheduleState

Direct Known Subclasses:

DummyScheduleState

public class ScheduleState
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ScheduleState()

Method Summary

Modifier and Type	Method and Description
int	decrementActiveThreadCount()
int	getActiveThreadCount()
java.util.Set<java.util.concurrent.ScheduledFuture<?>>	getFutures()
long	getLastStopTime()
int	incrementActiveThreadCount()
boolean	isScheduled()
boolean	mustCallOnStoppedMethods() Maintains an AtomicBoolean so that the first thread to call this method after a Processor is no longer scheduled to run will receive a true and MUST call the methods annotated with @OnStopped
void	replaceFuture(java.util.concurrent.ScheduledFuture<?> oldFuture, java.util.concurrent.ScheduledFuture<?> newFuture)
void	setFutures(java.util.Collection<java.util.concurrent.ScheduledFuture<?>> newFutures) Establishes the list of relevant futures for this processor.
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ScheduleState

public ScheduleState()

Method Detail

incrementActiveThreadCount

public int incrementActiveThreadCount()

decrementActiveThreadCount

public int decrementActiveThreadCount()

getActiveThreadCount

public int getActiveThreadCount()

isScheduled

public boolean isScheduled()

getLastStopTime

public long getLastStopTime()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

mustCallOnStoppedMethods

public boolean mustCallOnStoppedMethods()

Maintains an AtomicBoolean so that the first thread to call this method after a Processor is no longer scheduled to run will receive a true and MUST call the methods annotated with @OnStopped

Returns:

true if the caller is required to call Processor methods annotated with

setFutures

public void setFutures(java.util.Collection<java.util.concurrent.ScheduledFuture<?>> newFutures)

Establishes the list of relevant futures for this processor. Replaces any previously held futures.

Parameters:

newFutures - futures

replaceFuture

public void replaceFuture(java.util.concurrent.ScheduledFuture<?> oldFuture,
                          java.util.concurrent.ScheduledFuture<?> newFuture)

getFutures

public java.util.Set<java.util.concurrent.ScheduledFuture<?>> getFutures()