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

Packages that use ProcessingTimeService

Package	Description
org.apache.flink.connector.file.table.stream
org.apache.flink.state.api.runtime
org.apache.flink.streaming.api.functions.sink.filesystem
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.async
org.apache.flink.streaming.api.operators.sorted.state
org.apache.flink.streaming.api.operators.source
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.table.runtime.operators
org.apache.flink.table.runtime.operators.wmassigners

Uses of ProcessingTimeService in org.apache.flink.connector.file.table.stream

Methods in org.apache.flink.connector.file.table.stream with parameters of type ProcessingTimeService

Modifier and Type	Method	Description
static PartitionCommitTrigger	PartitionCommitTrigger.create(boolean isRestored, OperatorStateStore stateStore, Configuration conf, ClassLoader cl, List<String> partitionKeys, ProcessingTimeService procTimeService)

Constructors in org.apache.flink.connector.file.table.stream with parameters of type ProcessingTimeService

Constructor	Description
ProcTimeCommitTrigger(boolean isRestored, OperatorStateStore stateStore, ProcessingTimeService procTimeService, PartitionCommitPredicate partitionCommitPredicate)

Uses of ProcessingTimeService in org.apache.flink.state.api.runtime

Classes in org.apache.flink.state.api.runtime that implement ProcessingTimeService

Modifier and Type	Class	Description
class	NeverFireProcessingTimeService	A processing time service whose timers never fire so all timers are included in savepoints.

Uses of ProcessingTimeService in org.apache.flink.streaming.api.functions.sink.filesystem

Constructors in org.apache.flink.streaming.api.functions.sink.filesystem with parameters of type ProcessingTimeService

Constructor	Description
StreamingFileSinkHelper(Buckets<IN,?> buckets, boolean isRestored, OperatorStateStore stateStore, ProcessingTimeService procTimeService, long bucketCheckInterval)

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

Fields in org.apache.flink.streaming.api.operators declared as ProcessingTimeService

Modifier and Type	Field	Description
protected ProcessingTimeService	AbstractStreamOperator.processingTimeService
protected ProcessingTimeService	AbstractStreamOperatorFactory.processingTimeService
protected ProcessingTimeService	AbstractStreamOperatorV2.processingTimeService
protected ProcessingTimeService	InternalTimerServiceImpl.processingTimeService

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

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

Methods in org.apache.flink.streaming.api.operators that return types with arguments of type ProcessingTimeService

Modifier and Type	Method	Description
static <OUT,OP extends StreamOperator<OUT>> Tuple2<OP,Optional<ProcessingTimeService>>	StreamOperatorFactoryUtil.createOperator(StreamOperatorFactory<OUT> operatorFactory, StreamTask<OUT,?> containingTask, StreamConfig configuration, Output<StreamRecord<OUT>> output, OperatorEventDispatcher operatorEventDispatcher)	Creates a new operator using a factory and makes sure that all special factory traits are properly handled.

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

Modifier and Type	Method	Description
<K> InternalTimeServiceManager<K>	InternalTimeServiceManager.Provider.create(TaskIOMetricGroup taskIOMetricGroup, PriorityQueueSetFactory factory, KeyGroupRange keyGroupRange, ClassLoader userClassloader, KeyContext keyContext, ProcessingTimeService processingTimeService, Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStates, StreamTaskCancellationContext cancellationContext)
static <K> InternalTimeServiceManagerImpl<K>	InternalTimeServiceManagerImpl.create(TaskIOMetricGroup taskIOMetricGroup, PriorityQueueSetFactory factory, KeyGroupRange keyGroupRange, ClassLoader userClassloader, KeyContext keyContext, ProcessingTimeService processingTimeService, Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStates, StreamTaskCancellationContext cancellationContext)	A factory method for creating the InternalTimeServiceManagerImpl.
static <OUT> SourceFunction.SourceContext<OUT>	StreamSourceContexts.getSourceContext(ProcessingTimeService processingTimeService, Object checkpointLock, Output<StreamRecord<OUT>> output, long watermarkInterval, long idleTimeout, boolean emitProgressiveWatermarks)	Deprecated.
protected void	AbstractStreamOperator.setProcessingTimeService(ProcessingTimeService processingTimeService)
void	AbstractStreamOperatorFactory.setProcessingTimeService(ProcessingTimeService processingTimeService)
static void	StreamOperatorUtils.setProcessingTimeService(AbstractStreamOperator<?> operator, ProcessingTimeService processingTimeService)
StreamOperatorStateContext	StreamTaskStateInitializer.streamOperatorStateContext(OperatorID operatorID, String operatorClassName, ProcessingTimeService processingTimeService, KeyContext keyContext, TypeSerializer<?> keySerializer, CloseableRegistry streamTaskCloseableRegistry, MetricGroup metricGroup, double managedMemoryFraction, boolean isUsingCustomRawKeyedState, boolean isAsyncState)	Returns the StreamOperatorStateContext for an AbstractStreamOperator that runs in the stream task that owns this manager.
StreamOperatorStateContext	StreamTaskStateInitializerImpl.streamOperatorStateContext(OperatorID operatorID, String operatorClassName, ProcessingTimeService processingTimeService, KeyContext keyContext, TypeSerializer<?> keySerializer, CloseableRegistry streamTaskCloseableRegistry, MetricGroup metricGroup, double managedMemoryFraction, boolean isUsingCustomRawKeyedState, boolean isAsyncState)

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

Constructor	Description
SourceOperator(StreamOperatorParameters<OUT> parameters, FunctionWithException<SourceReaderContext,SourceReader<OUT,SplitT>,Exception> readerFactory, OperatorEventGateway operatorEventGateway, SimpleVersionedSerializer<SplitT> splitSerializer, WatermarkStrategy<OUT> watermarkStrategy, ProcessingTimeService timeService, Configuration configuration, String localHostname, boolean emitProgressiveWatermarks, StreamTask.CanEmitBatchOfRecordsChecker canEmitBatchOfRecords)
StreamingRuntimeContext(Environment env, Map<String,Accumulator<?,?>> accumulators, OperatorMetricGroup operatorMetricGroup, OperatorID operatorID, ProcessingTimeService processingTimeService, KeyedStateStore keyedStateStore, ExternalResourceInfoProvider externalResourceInfoProvider)

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

Constructor	Description
StreamOperatorParameters(StreamTask<?,?> containingTask, StreamConfig config, Output<StreamRecord<OUT>> output, Supplier<ProcessingTimeService> processingTimeServiceFactory, OperatorEventDispatcher operatorEventDispatcher, MailboxExecutor mailboxExecutor)

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

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

Constructor	Description
AsyncWaitOperator(StreamOperatorParameters<OUT> parameters, AsyncFunction<IN,OUT> asyncFunction, long timeout, int capacity, AsyncDataStream.OutputMode outputMode, AsyncRetryStrategy<OUT> asyncRetryStrategy, ProcessingTimeService processingTimeService, MailboxExecutor mailboxExecutor)

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

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

Modifier and Type	Method	Description
static <K> InternalTimeServiceManager<K>	BatchExecutionInternalTimeServiceManager.create(TaskIOMetricGroup taskIOMetricGroup, PriorityQueueSetFactory factory, KeyGroupRange keyGroupRange, ClassLoader userClassloader, KeyContext keyContext, ProcessingTimeService processingTimeService, Iterable<KeyGroupStatePartitionStreamProvider> rawKeyedStates, StreamTaskCancellationContext cancellationContext)

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

Constructor	Description
BatchExecutionInternalTimeServiceManager(ProcessingTimeService processingTimeService)

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

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

Modifier and Type	Method	Description
static <E> TimestampsAndWatermarks<E>	TimestampsAndWatermarks.createProgressiveEventTimeLogic(WatermarkStrategy<E> watermarkStrategy, MetricGroup metrics, ProcessingTimeService timeService, long periodicWatermarkIntervalMillis, RelativeClock mainInputActivityClock, Clock clock, TaskIOMetricGroup taskIOMetricGroup)

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

Constructor	Description
ProgressiveTimestampsAndWatermarks(TimestampAssigner<T> timestampAssigner, WatermarkGeneratorSupplier<T> watermarksFactory, TimestampsAndWatermarks.TimestampsAndWatermarksContextProvider watermarksContextProvider, ProcessingTimeService timeService, Duration periodicWatermarkInterval, RelativeClock mainInputActivityClock, Clock clock, TaskIOMetricGroup taskIOMetricGroup)

Uses of ProcessingTimeService in org.apache.flink.streaming.runtime.operators.windowing

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

Modifier and Type	Method	Description
void	WindowOperator.setProcessingTimeService(ProcessingTimeService processingTimeService)

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

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

Modifier and Type	Interface	Description
interface	TimerService	A common timer service interface with life cycle methods.

Classes in org.apache.flink.streaming.runtime.tasks that implement ProcessingTimeService

Modifier and Type	Class	Description
class	SystemProcessingTimeService	A TimerService which assigns as current processing time the result of calling System.currentTimeMillis() and registers timers using a ScheduledThreadPoolExecutor.

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

Modifier and Type	Method	Description
ProcessingTimeService	ProcessingTimeServiceFactory.createProcessingTimeService(MailboxExecutor mailboxExecutor)	Creates a new processing time service with the mailbox executor.

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

Modifier and Type	Method	Description
void	ProcessingTimeServiceAware.setProcessingTimeService(ProcessingTimeService processingTimeService)

Uses of ProcessingTimeService in org.apache.flink.table.runtime.operators

Fields in org.apache.flink.table.runtime.operators declared as ProcessingTimeService

Modifier and Type	Field	Description
protected ProcessingTimeService	TableStreamOperator.ContextImpl.timerService

Uses of ProcessingTimeService in org.apache.flink.table.runtime.operators.wmassigners

Constructors in org.apache.flink.table.runtime.operators.wmassigners with parameters of type ProcessingTimeService

Constructor	Description
WatermarkAssignerOperator(StreamOperatorParameters<RowData> parameters, int rowtimeFieldIndex, WatermarkGenerator watermarkGenerator, long idleTimeout, ProcessingTimeService processingTimeService)	Create a watermark assigner operator.