Uses of Class
org.apache.flink.streaming.runtime.tasks.ProcessingTimeService

Packages that use ProcessingTimeService

Package	Description
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

Uses of ProcessingTimeService in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators that return ProcessingTimeService

Modifier and Type	Method and Description
ProcessingTimeService	StreamingRuntimeContext.getProcessingTimeService()
protected ProcessingTimeService	AbstractStreamOperator.getProcessingTimeService() Returns the ProcessingTimeService responsible for getting the current processing time and registering timers.

Methods in org.apache.flink.streaming.api.operators with parameters of type ProcessingTimeService

Modifier and Type	Method and Description
static <OUT> SourceFunction.SourceContext<OUT>	StreamSourceContexts.getSourceContext(TimeCharacteristic timeCharacteristic, ProcessingTimeService processingTimeService, Object checkpointLock, StreamStatusMaintainer streamStatusMaintainer, Output<StreamRecord<OUT>> output, long watermarkInterval, long idleTimeout) Depending on the TimeCharacteristic, this method will return the adequate SourceFunction.SourceContext.

Constructors in org.apache.flink.streaming.api.operators with parameters of type ProcessingTimeService

Constructor and Description
StreamTaskStateInitializerImpl(org.apache.flink.runtime.execution.Environment environment, org.apache.flink.runtime.state.StateBackend stateBackend, ProcessingTimeService processingTimeService)

Uses of ProcessingTimeService in org.apache.flink.streaming.runtime.tasks

Subclasses of ProcessingTimeService in org.apache.flink.streaming.runtime.tasks

Modifier and Type	Class and Description
class	SystemProcessingTimeService A ProcessingTimeService which assigns as current processing time the result of calling System.currentTimeMillis() and registers timers using a ScheduledThreadPoolExecutor.
class	TestProcessingTimeService This is a ProcessingTimeService used strictly for testing the processing time functionality.

Fields in org.apache.flink.streaming.runtime.tasks declared as ProcessingTimeService

Modifier and Type	Field and Description
protected ProcessingTimeService	StreamTask.timerService The internal ProcessingTimeService used to define the current processing time (default = System.currentTimeMillis()) and register timers for tasks to be executed in the future.

Methods in org.apache.flink.streaming.runtime.tasks that return ProcessingTimeService

Modifier and Type	Method and Description
ProcessingTimeService	StreamTask.getProcessingTimeService() Returns the ProcessingTimeService responsible for telling the current processing time and registering timers.

Constructors in org.apache.flink.streaming.runtime.tasks with parameters of type ProcessingTimeService

Constructor and Description
OneInputStreamTask(org.apache.flink.runtime.execution.Environment env, ProcessingTimeService timeProvider) Constructor for initialization, possibly with initial state (recovery / savepoint / etc).
StreamTask(org.apache.flink.runtime.execution.Environment environment, ProcessingTimeService timeProvider) Constructor for initialization, possibly with initial state (recovery / savepoint / etc).