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

Packages that use ProcessingTimeServiceAware

Package	Description
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.async
org.apache.flink.streaming.api.operators.collect
org.apache.flink.streaming.runtime.operators.sink
org.apache.flink.table.runtime.operators
org.apache.flink.table.runtime.operators.multipleinput
org.apache.flink.table.runtime.operators.wmassigners

Uses of ProcessingTimeServiceAware in org.apache.flink.streaming.api.functions.source

Classes in org.apache.flink.streaming.api.functions.source that implement ProcessingTimeServiceAware

Modifier and Type	Class and Description
class	ContinuousFileReaderOperatorFactory<OUT,T extends TimestampedInputSplit> ContinuousFileReaderOperator factory.

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

Classes in org.apache.flink.streaming.api.operators that implement ProcessingTimeServiceAware

Modifier and Type	Class and Description
class	AbstractStreamOperatorFactory<OUT> Base class for all stream operator factories.
class	SimpleInputFormatOperatorFactory<OUT> Input format source operator factory which just wrap existed StreamSource.
class	SimpleOperatorFactory<OUT> Simple factory which just wrap existed StreamOperator.
class	SimpleOutputFormatOperatorFactory<IN> A simple operator factory which create StreamSink containing an OutputFormat.
class	SimpleUdfStreamOperatorFactory<OUT> Udf stream operator factory which just wrap existed AbstractUdfStreamOperator.
class	SourceOperatorFactory<OUT> The Factory class for SourceOperator.

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

Classes in org.apache.flink.streaming.api.operators.async that implement ProcessingTimeServiceAware

Modifier and Type	Class and Description
class	AsyncWaitOperatorFactory<IN,OUT> The factory of AsyncWaitOperator.

Uses of ProcessingTimeServiceAware in org.apache.flink.streaming.api.operators.collect

Classes in org.apache.flink.streaming.api.operators.collect that implement ProcessingTimeServiceAware

Modifier and Type	Class and Description
class	CollectSinkOperatorFactory<IN> The Factory class for CollectSinkOperator.

Uses of ProcessingTimeServiceAware in org.apache.flink.streaming.runtime.operators.sink

Classes in org.apache.flink.streaming.runtime.operators.sink that implement ProcessingTimeServiceAware

Modifier and Type	Class and Description
class	BatchCommitterOperatorFactory<CommT> A StreamOperatorFactory for BatchCommitterOperator.
class	BatchGlobalCommitterOperatorFactory<CommT,GlobalCommT> A StreamOperatorFactory for BatchGlobalCommitterOperator.
class	StatefulSinkWriterOperatorFactory<InputT,CommT,WriterStateT> A StreamOperatorFactory for StatefulSinkWriterOperator.
class	StatelessSinkWriterOperatorFactory<InputT,CommT> A StreamOperatorFactory for StatelessSinkWriterOperator.
class	StreamingCommitterOperatorFactory<CommT> A StreamOperatorFactory for StreamingCommitterOperator.
class	StreamingGlobalCommitterOperatorFactory<CommT,GlobalCommT> A StreamOperatorFactory for StreamingGlobalCommitterOperator.

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

Classes in org.apache.flink.table.runtime.operators that implement ProcessingTimeServiceAware

Modifier and Type	Class and Description
class	CodeGenOperatorFactory<OUT> Stream operator factory for code gen operator.

Uses of ProcessingTimeServiceAware in org.apache.flink.table.runtime.operators.multipleinput

Classes in org.apache.flink.table.runtime.operators.multipleinput that implement ProcessingTimeServiceAware

Modifier and Type	Class and Description
class	BatchMultipleInputStreamOperatorFactory The factory to create BatchMultipleInputStreamOperator.

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

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

Modifier and Type	Class and Description
class	WatermarkAssignerOperatorFactory The factory of WatermarkAssignerOperator.