Uses of Class
org.apache.flink.runtime.source.coordinator.SourceCoordinatorContext

Packages that use SourceCoordinatorContext

Package	Description
org.apache.flink.runtime.source.coordinator

Uses of SourceCoordinatorContext in org.apache.flink.runtime.source.coordinator

Constructors in org.apache.flink.runtime.source.coordinator with parameters of type SourceCoordinatorContext

Constructor and Description
SourceCoordinator(String operatorName, Source<?,SplitT,EnumChkT> source, SourceCoordinatorContext<SplitT> context, CoordinatorStore coordinatorStore)
SourceCoordinator(String operatorName, Source<?,SplitT,EnumChkT> source, SourceCoordinatorContext<SplitT> context, CoordinatorStore coordinatorStore, WatermarkAlignmentParams watermarkAlignmentParams)