org.apache.nifi.controller.scheduling

Class EventDrivenSchedulingAgent

java.lang.Object

org.apache.nifi.controller.scheduling.EventDrivenSchedulingAgent

All Implemented Interfaces:

SchedulingAgent

public class EventDrivenSchedulingAgent
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected FlowEngine	flowEngine

Constructor Summary

Constructors

Constructor and Description
EventDrivenSchedulingAgent(FlowEngine flowEngine, ControllerServiceProvider serviceProvider, StateManagerProvider stateManagerProvider, EventDrivenWorkerQueue workerQueue, ProcessContextFactory contextFactory, int maxThreadCount, StringEncryptor encryptor)

Method Summary

Modifier and Type	Method and Description
void	doSchedule(Connectable connectable, ScheduleState scheduleState) Schedules the provided Connectable.
void	doSchedule(ReportingTaskNode taskNode, ScheduleState scheduleState) Schedules the provided ReportingTaskNode.
void	doUnschedule(Connectable connectable, ScheduleState scheduleState) Unschedules the provided Connectable.
void	doUnschedule(ReportingTaskNode taskNode, ScheduleState scheduleState) Unschedules the provided ReportingTaskNode.
int	getActiveThreadCount()
java.lang.String	getAdministrativeYieldDuration()
long	getAdministrativeYieldDuration(java.util.concurrent.TimeUnit timeUnit)
void	onEvent(Connectable connectable)
void	schedule(Connectable connectable, ScheduleState scheduleState)
void	schedule(ReportingTaskNode taskNode, ScheduleState scheduleState)
void	setAdministrativeYieldDuration(java.lang.String yieldDuration)
void	setMaxThreadCount(int maxThreadCount)
void	shutdown()
void	unschedule(Connectable connectable, ScheduleState scheduleState)
void	unschedule(ReportingTaskNode taskNode, ScheduleState scheduleState)

Methods inherited from class java.lang.Object

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

Field Detail

flowEngine

protected final FlowEngine flowEngine

Constructor Detail

EventDrivenSchedulingAgent

public EventDrivenSchedulingAgent(FlowEngine flowEngine,
                                  ControllerServiceProvider serviceProvider,
                                  StateManagerProvider stateManagerProvider,
                                  EventDrivenWorkerQueue workerQueue,
                                  ProcessContextFactory contextFactory,
                                  int maxThreadCount,
                                  StringEncryptor encryptor)

Method Detail

getActiveThreadCount

public int getActiveThreadCount()

shutdown

public void shutdown()

doSchedule

public void doSchedule(ReportingTaskNode taskNode,
                       ScheduleState scheduleState)

Schedules the provided ReportingTaskNode. Its ScheduleState will be set to true

Parameters:

taskNode - the instance of ReportingTaskNode

scheduleState - the instance of ScheduleState

doUnschedule

public void doUnschedule(ReportingTaskNode taskNode,
                         ScheduleState scheduleState)

Unschedules the provided ReportingTaskNode. Its ScheduleState will be set to false

Parameters:

taskNode - the instance of ReportingTaskNode

scheduleState - the instance of ScheduleState

doSchedule

public void doSchedule(Connectable connectable,
                       ScheduleState scheduleState)

Schedules the provided Connectable. Its ScheduleState will be set to true

Parameters:

connectable - the instance of Connectable

scheduleState - the instance of ScheduleState

doUnschedule

public void doUnschedule(Connectable connectable,
                         ScheduleState scheduleState)

Unschedules the provided Connectable. Its ScheduleState will be set to false

Parameters:

connectable - the instance of Connectable

scheduleState - the instance of ScheduleState

onEvent

public void onEvent(Connectable connectable)

setMaxThreadCount

public void setMaxThreadCount(int maxThreadCount)

setAdministrativeYieldDuration

public void setAdministrativeYieldDuration(java.lang.String yieldDuration)

getAdministrativeYieldDuration

public java.lang.String getAdministrativeYieldDuration()

getAdministrativeYieldDuration

public long getAdministrativeYieldDuration(java.util.concurrent.TimeUnit timeUnit)

schedule

public void schedule(Connectable connectable,
                     ScheduleState scheduleState)

Specified by:

schedule in interface SchedulingAgent

unschedule

public void unschedule(Connectable connectable,
                       ScheduleState scheduleState)

Specified by:

unschedule in interface SchedulingAgent

schedule

public void schedule(ReportingTaskNode taskNode,
                     ScheduleState scheduleState)

Specified by:

schedule in interface SchedulingAgent

unschedule

public void unschedule(ReportingTaskNode taskNode,
                       ScheduleState scheduleState)

Specified by:

unschedule in interface SchedulingAgent