Package | Description |
---|---|
org.apache.flink.runtime.operators.coordination | |
org.apache.flink.runtime.source.coordinator | |
org.apache.flink.streaming.api.operators.collect |
Modifier and Type | Class and Description |
---|---|
class |
OperatorCoordinatorHolder
The
OperatorCoordinatorHolder holds the OperatorCoordinator and manages all its
interactions with the remaining components. |
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 |
RecreateOnResetOperatorCoordinator.Provider.create(OperatorCoordinator.Context context) |
OperatorCoordinator |
OperatorCoordinator.Provider.create(OperatorCoordinator.Context context)
Creates the
OperatorCoordinator , using the given 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) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.