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

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	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	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,OUT>	A simple operator factory which create an operator 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	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	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	Description
class	CommitterOperatorFactory<CommT>	A StreamOperatorFactory for CommitterOperator.
class	SinkWriterOperatorFactory<InputT,CommT>	A StreamOperatorFactory for SinkWriterOperator.