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

Packages that use ProcessingTimeCallback

Package	Description
org.apache.flink.state.api.runtime
org.apache.flink.streaming.api.functions.sink.filesystem
org.apache.flink.streaming.connectors.fs.bucketing
org.apache.flink.streaming.runtime.operators	This package contains the operators that perform the stream transformations.
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.table.runtime.operators.wmassigners

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

Methods in org.apache.flink.state.api.runtime with parameters of type ProcessingTimeCallback

Modifier and Type	Method and Description
ScheduledFuture<?>	NeverFireProcessingTimeService.registerTimer(long timestamp, ProcessingTimeCallback target)
ScheduledFuture<?>	NeverFireProcessingTimeService.scheduleAtFixedRate(ProcessingTimeCallback callback, long initialDelay, long period)
ScheduledFuture<?>	NeverFireProcessingTimeService.scheduleWithFixedDelay(ProcessingTimeCallback callback, long initialDelay, long period)

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

Classes in org.apache.flink.streaming.api.functions.sink.filesystem that implement ProcessingTimeCallback

Modifier and Type	Class and Description
class	StreamingFileSinkHelper<IN> Helper for StreamingFileSink.

Uses of ProcessingTimeCallback in org.apache.flink.streaming.connectors.fs.bucketing

Classes in org.apache.flink.streaming.connectors.fs.bucketing that implement ProcessingTimeCallback

Modifier and Type	Class and Description
class	BucketingSink<T> Deprecated. Please use the StreamingFileSink instead.

Uses of ProcessingTimeCallback in org.apache.flink.streaming.runtime.operators

Classes in org.apache.flink.streaming.runtime.operators that implement ProcessingTimeCallback

Modifier and Type	Class and Description
class	TimestampsAndWatermarksOperator<T> A stream operator that may do one or both of the following: extract timestamps from events and generate watermarks.

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

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

Modifier and Type	Method and Description
ScheduledFuture<?>	ProcessingTimeService.registerTimer(long timestamp, ProcessingTimeCallback target) Registers a task to be executed when (processing) time is timestamp.
ScheduledFuture<?>	TestProcessingTimeService.registerTimer(long timestamp, ProcessingTimeCallback target)
ScheduledFuture<?>	SystemProcessingTimeService.registerTimer(long timestamp, ProcessingTimeCallback callback) Registers a task to be executed no sooner than time timestamp, but without strong guarantees of order.
ScheduledFuture<?>	ProcessingTimeService.scheduleAtFixedRate(ProcessingTimeCallback callback, long initialDelay, long period) Registers a task to be executed repeatedly at a fixed rate.
ScheduledFuture<?>	TestProcessingTimeService.scheduleAtFixedRate(ProcessingTimeCallback callback, long initialDelay, long period)
ScheduledFuture<?>	SystemProcessingTimeService.scheduleAtFixedRate(ProcessingTimeCallback callback, long initialDelay, long period)
ScheduledFuture<?>	ProcessingTimeService.scheduleWithFixedDelay(ProcessingTimeCallback callback, long initialDelay, long period) Registers a task to be executed repeatedly with a fixed delay.
ScheduledFuture<?>	TestProcessingTimeService.scheduleWithFixedDelay(ProcessingTimeCallback callback, long initialDelay, long period)
ScheduledFuture<?>	SystemProcessingTimeService.scheduleWithFixedDelay(ProcessingTimeCallback callback, long initialDelay, long period)

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

Classes in org.apache.flink.table.runtime.operators.wmassigners that implement ProcessingTimeCallback

Modifier and Type	Class and Description
class	ProcTimeMiniBatchAssignerOperator A stream operator that emits mini-batch marker in a given period.
class	WatermarkAssignerOperator A stream operator that extracts timestamps from stream elements and generates periodic watermarks.