Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobgraph | |
org.apache.flink.streaming.api.graph |
Constructor and Description |
---|
DefaultExecutionGraph(JobInformation jobInformation,
ScheduledExecutorService futureExecutor,
Executor ioExecutor,
Time rpcTimeout,
int executionHistorySizeLimit,
ClassLoader userClassLoader,
BlobWriter blobWriter,
PartitionGroupReleaseStrategy.Factory partitionGroupReleaseStrategyFactory,
ShuffleMaster<?> shuffleMaster,
JobMasterPartitionTracker partitionTracker,
TaskDeploymentDescriptorFactory.PartitionLocationConstraint partitionLocationConstraint,
ExecutionDeploymentListener executionDeploymentListener,
ExecutionStateUpdateListener executionStateUpdateListener,
long initializationTimestamp,
VertexAttemptNumberStore initialAttemptCounts,
VertexParallelismStore vertexParallelismStore,
boolean isDynamic,
ExecutionJobVertex.Factory executionJobVertexFactory,
List<JobStatusHook> jobStatusHooks) |
Modifier and Type | Method and Description |
---|---|
List<JobStatusHook> |
JobGraph.getJobStatusHooks() |
Modifier and Type | Method and Description |
---|---|
void |
JobGraph.setJobStatusHooks(List<JobStatusHook> hooks) |
Modifier and Type | Method and Description |
---|---|
List<JobStatusHook> |
StreamGraph.getJobStatusHooks() |
Modifier and Type | Method and Description |
---|---|
void |
StreamGraph.registerJobStatusHook(JobStatusHook hook)
Registers the JobStatusHook.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.