Modifier and Type | Method and Description |
---|---|
void |
RecreateOnResetOperatorCoordinator.subtaskReady(int subtask,
OperatorCoordinator.SubtaskGateway gateway) |
void |
OperatorCoordinator.subtaskReady(int subtask,
OperatorCoordinator.SubtaskGateway gateway)
This is called when a subtask of the Operator becomes ready to receive events, both after
initial startup and after task failover.
|
Modifier and Type | Method and Description |
---|---|
void |
SourceCoordinator.subtaskReady(int subtask,
OperatorCoordinator.SubtaskGateway gateway) |
Modifier and Type | Method and Description |
---|---|
void |
CollectSinkOperatorCoordinator.subtaskReady(int subtask,
OperatorCoordinator.SubtaskGateway gateway) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.