Package | Description |
---|---|
org.apache.flink.api.common.eventtime | |
org.apache.flink.runtime.source.coordinator |
Modifier and Type | Field and Description |
---|---|
static WatermarkAlignmentParams |
WatermarkAlignmentParams.WATERMARK_ALIGNMENT_DISABLED |
Modifier and Type | Method and Description |
---|---|
default WatermarkAlignmentParams |
WatermarkStrategy.getAlignmentParameters()
Provides configuration for watermark alignment of a maximum watermark of multiple
sources/tasks/partitions in the same watermark group.
|
Constructor and Description |
---|
SourceCoordinator(String operatorName,
Source<?,SplitT,EnumChkT> source,
SourceCoordinatorContext<SplitT> context,
CoordinatorStore coordinatorStore,
WatermarkAlignmentParams watermarkAlignmentParams,
String coordinatorListeningID) |
SourceCoordinatorProvider(String operatorName,
OperatorID operatorID,
Source<?,SplitT,?> source,
int numWorkerThreads,
WatermarkAlignmentParams alignmentParams,
String coordinatorListeningID)
Construct the
SourceCoordinatorProvider . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.