public static interface OperatorCoordinator.Context
Modifier and Type | Method and Description |
---|---|
int |
currentParallelism()
Gets the current parallelism with which this operator is executed.
|
void |
failJob(Throwable cause)
Fails the job and trigger a global failover operation.
|
CoordinatorStore |
getCoordinatorStore()
Get the
CoordinatorStore instance for sharring information between OperatorCoordinator s. |
OperatorID |
getOperatorId()
Gets the ID of the operator to which the coordinator belongs.
|
ClassLoader |
getUserCodeClassloader()
Gets the classloader that contains the additional dependencies, which are not part of the
JVM's classpath.
|
OperatorID getOperatorId()
void failJob(Throwable cause)
This operation restores the entire job to the latest complete checkpoint. This is useful to recover from inconsistent situations (the view from the coordinator and its subtasks as diverged), but is expensive and should be used with care.
int currentParallelism()
ClassLoader getUserCodeClassloader()
CoordinatorStore getCoordinatorStore()
CoordinatorStore
instance for sharring information between OperatorCoordinator
s.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.