Modifier and Type | Class and Description |
---|---|
class |
RecreateOnResetOperatorCoordinator
A class that will recreate a new
OperatorCoordinator instance when reset to checkpoint. |
Modifier and Type | Method and Description |
---|---|
OperatorCoordinator |
OperatorCoordinatorHolder.coordinator() |
OperatorCoordinator |
OperatorCoordinator.Provider.create(OperatorCoordinator.Context context)
Creates the
OperatorCoordinator , using the given context. |
OperatorCoordinator |
RecreateOnResetOperatorCoordinator.Provider.create(OperatorCoordinator.Context context) |
protected OperatorCoordinator |
RecreateOnResetOperatorCoordinator.Provider.create(OperatorCoordinator.Context context,
long closingTimeoutMs) |
protected abstract OperatorCoordinator |
RecreateOnResetOperatorCoordinator.Provider.getCoordinator(OperatorCoordinator.Context context) |
OperatorCoordinator |
RecreateOnResetOperatorCoordinator.getInternalCoordinator() |
Modifier and Type | Class and Description |
---|---|
class |
SourceCoordinator<SplitT extends SourceSplit,EnumChkT>
The default implementation of the
OperatorCoordinator for the Source . |
Modifier and Type | Method and Description |
---|---|
OperatorCoordinator |
SourceCoordinatorProvider.getCoordinator(OperatorCoordinator.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
CollectSinkOperatorCoordinator
|
Modifier and Type | Method and Description |
---|---|
OperatorCoordinator |
CollectSinkOperatorCoordinator.Provider.create(OperatorCoordinator.Context context) |
Modifier and Type | Class and Description |
---|---|
class |
DynamicFilteringDataCollectorOperatorCoordinator
The operator coordinator for
DynamicFilteringDataCollectorOperator . |
Modifier and Type | Method and Description |
---|---|
protected OperatorCoordinator |
DynamicFilteringDataCollectorOperatorCoordinator.Provider.getCoordinator(OperatorCoordinator.Context context) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.