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.connectors.kafka.internal
org.apache.flink.streaming.connectors.kafka.internals
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
HeapInternalTimerService(int totalKeyGroups, KeyGroupsList localKeyGroupRange, KeyContext keyContext, ProcessingTimeService processingTimeService)
InternalTimerServiceSerializationProxy(Map<String,HeapInternalTimerService<K,N>> timerServicesMapToPopulate, ClassLoader userCodeClassLoader, int totalKeyGroups, KeyGroupsList localKeyGroupRange, KeyContext keyContext, ProcessingTimeService processingTimeService, int keyGroupIdx) Constructor to use when restoring timer services.
StreamTaskStateInitializerImpl(Environment environment, StateBackend stateBackend, ProcessingTimeService processingTimeService)

Uses of ProcessingTimeService in org.apache.flink.streaming.connectors.kafka.internal

Constructors in org.apache.flink.streaming.connectors.kafka.internal with parameters of type ProcessingTimeService

Constructor and Description
Kafka010Fetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, String taskNameWithSubtasks, KeyedDeserializationSchema<T> deserializer, Properties kafkaProperties, long pollTimeout, MetricGroup subtaskMetricGroup, MetricGroup consumerMetricGroup, boolean useMetrics)
Kafka09Fetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> assignedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, String taskNameWithSubtasks, KeyedDeserializationSchema<T> deserializer, Properties kafkaProperties, long pollTimeout, MetricGroup subtaskMetricGroup, MetricGroup consumerMetricGroup, boolean useMetrics)

Uses of ProcessingTimeService in org.apache.flink.streaming.connectors.kafka.internals

Constructors in org.apache.flink.streaming.connectors.kafka.internals with parameters of type ProcessingTimeService

Constructor and Description

AbstractFetcher(SourceFunction.SourceContext<T> sourceContext, Map<KafkaTopicPartition,Long> seedPartitionsWithInitialOffsets, SerializedValue<AssignerWithPeriodicWatermarks<T>> watermarksPeriodic, SerializedValue<AssignerWithPunctuatedWatermarks<T>> watermarksPunctuated, ProcessingTimeService processingTimeProvider, long autoWatermarkInterval, ClassLoader userCodeClassLoader, MetricGroup consumerMetricGroup, boolean useMetrics)

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(Environment env, ProcessingTimeService timeProvider) Constructor for initialization, possibly with initial state (recovery / savepoint / etc).
StreamTask(Environment environment, ProcessingTimeService timeProvider) Constructor for initialization, possibly with initial state (recovery / savepoint / etc).