Modifier and Type | Method and Description |
---|---|
void |
RecreateOnResetOperatorCoordinator.executionAttemptReady(int subtask,
int attemptNumber,
OperatorCoordinator.SubtaskGateway gateway) |
void |
OperatorCoordinator.executionAttemptReady(int subtask,
int attemptNumber,
OperatorCoordinator.SubtaskGateway gateway)
This is called when a subtask execution attempt of the Operator becomes ready to receive
events.
|
Modifier and Type | Method and Description |
---|---|
void |
SourceCoordinator.executionAttemptReady(int subtask,
int attemptNumber,
OperatorCoordinator.SubtaskGateway gateway) |
Modifier and Type | Method and Description |
---|---|
void |
CollectSinkOperatorCoordinator.executionAttemptReady(int subtask,
int attemptNumber,
OperatorCoordinator.SubtaskGateway gateway) |
Modifier and Type | Method and Description |
---|---|
void |
DynamicFilteringDataCollectorOperatorCoordinator.executionAttemptReady(int subtask,
int attemptNumber,
OperatorCoordinator.SubtaskGateway gateway) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.