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

Packages that use StreamTaskCancellationContext

Package	Description
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.sorted.state
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.

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

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

Modifier and Type	Method	Description
<K> InternalTimeServiceManager<K>	InternalTimeServiceManager.Provider.create(org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> keyedStatedBackend, ClassLoader userClassloader, KeyContext keyContext, ProcessingTimeService processingTimeService, Iterable<org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider> rawKeyedStates, StreamTaskCancellationContext cancellationContext)
static <K> InternalTimeServiceManagerImpl<K>	InternalTimeServiceManagerImpl.create(org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> keyedStateBackend, ClassLoader userClassloader, KeyContext keyContext, ProcessingTimeService processingTimeService, Iterable<org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider> rawKeyedStates, StreamTaskCancellationContext cancellationContext)	A factory method for creating the InternalTimeServiceManagerImpl.

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

Constructor	Description
StreamTaskStateInitializerImpl(org.apache.flink.runtime.execution.Environment environment, org.apache.flink.runtime.state.StateBackend stateBackend, org.apache.flink.runtime.state.ttl.TtlTimeProvider ttlTimeProvider, InternalTimeServiceManager.Provider timeServiceManagerProvider, StreamTaskCancellationContext cancellationContext)

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

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

Modifier and Type	Method	Description
static <K> InternalTimeServiceManager<K>	BatchExecutionInternalTimeServiceManager.create(org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> keyedStatedBackend, ClassLoader userClassloader, KeyContext keyContext, ProcessingTimeService processingTimeService, Iterable<org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider> rawKeyedStates, StreamTaskCancellationContext cancellationContext)

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

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

Modifier and Type	Method	Description
static StreamTaskCancellationContext	StreamTaskCancellationContext.alwaysRunning()	Factory for a context that always returns false when isCancelled() is called.