Uses of Package
org.apache.flink.runtime.jobgraph

Packages that use org.apache.flink.runtime.jobgraph

Package	Description
org.apache.flink.client
org.apache.flink.client.cli
org.apache.flink.client.deployment
org.apache.flink.client.deployment.application
org.apache.flink.client.deployment.executors
org.apache.flink.client.program
org.apache.flink.client.program.rest
org.apache.flink.connector.testframe.utils
org.apache.flink.kubernetes
org.apache.flink.kubernetes.highavailability
org.apache.flink.kubernetes.utils
org.apache.flink.optimizer.plantranslate
org.apache.flink.runtime
org.apache.flink.runtime.broadcast
org.apache.flink.runtime.checkpoint
org.apache.flink.runtime.checkpoint.channel
org.apache.flink.runtime.checkpoint.filemerging
org.apache.flink.runtime.client
org.apache.flink.runtime.deployment
org.apache.flink.runtime.dispatcher
org.apache.flink.runtime.dispatcher.runner
org.apache.flink.runtime.entrypoint.component
org.apache.flink.runtime.execution
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.executiongraph.failover.flip1
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.io.network.partition.hybrid.tiered.common
org.apache.flink.runtime.jobgraph
org.apache.flink.runtime.jobgraph.forwardgroup
org.apache.flink.runtime.jobgraph.jsonplan
org.apache.flink.runtime.jobgraph.tasks
org.apache.flink.runtime.jobgraph.topology
org.apache.flink.runtime.jobmanager
org.apache.flink.runtime.jobmanager.scheduler
org.apache.flink.runtime.jobmanager.slots
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.jobmaster.factories
org.apache.flink.runtime.metrics.groups
org.apache.flink.runtime.metrics.scope
org.apache.flink.runtime.minicluster
org.apache.flink.runtime.operators.coordination
org.apache.flink.runtime.query
org.apache.flink.runtime.resourcemanager
org.apache.flink.runtime.rest.messages
org.apache.flink.runtime.rest.messages.checkpoints
org.apache.flink.runtime.rest.messages.dataset
org.apache.flink.runtime.rest.messages.job
org.apache.flink.runtime.rest.messages.json
org.apache.flink.runtime.scheduler
org.apache.flink.runtime.scheduler.adapter
org.apache.flink.runtime.scheduler.adaptive
org.apache.flink.runtime.scheduler.adaptive.allocator
org.apache.flink.runtime.scheduler.adaptivebatch
org.apache.flink.runtime.scheduler.metrics
org.apache.flink.runtime.scheduler.strategy
org.apache.flink.runtime.shuffle
org.apache.flink.runtime.source.coordinator
org.apache.flink.runtime.state
org.apache.flink.runtime.taskexecutor
org.apache.flink.runtime.taskexecutor.partition
org.apache.flink.runtime.taskexecutor.rpc
org.apache.flink.runtime.taskmanager
org.apache.flink.runtime.util
org.apache.flink.runtime.webmonitor
org.apache.flink.runtime.webmonitor.handlers
org.apache.flink.runtime.webmonitor.handlers.utils
org.apache.flink.state.api
org.apache.flink.state.api.output
org.apache.flink.state.api.output.operators
org.apache.flink.state.api.runtime
org.apache.flink.streaming.api.environment
org.apache.flink.streaming.api.graph
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.collect
org.apache.flink.streaming.runtime.io
org.apache.flink.streaming.runtime.streamrecord
org.apache.flink.streaming.runtime.tasks	This package contains classes that realize streaming tasks.
org.apache.flink.streaming.util
org.apache.flink.table.runtime.operators.dynamicfiltering
org.apache.flink.table.runtime.operators.hive.script
org.apache.flink.test.util
org.apache.flink.yarn

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.client

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.client.cli

Class and Description
SavepointRestoreSettings Savepoint restore settings.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.client.deployment

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.client.deployment.application

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.client.deployment.executors

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.client.program

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
OperatorID A class for statistically unique operator IDs.
SavepointRestoreSettings Savepoint restore settings.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.client.program.rest

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
JobResourceRequirements Information about the parallelism of job vertices.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.connector.testframe.utils

Class and Description
JobVertexID A class for statistically unique job vertex IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.kubernetes

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.kubernetes.highavailability

Class and Description
RestoreMode Defines how Flink should restore from a given savepoint or retained checkpoint.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.kubernetes.utils

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
RestoreMode Defines how Flink should restore from a given savepoint or retained checkpoint.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.optimizer.plantranslate

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.broadcast

Class and Description
JobVertexID A class for statistically unique job vertex IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.checkpoint

Class and Description
JobVertexID A class for statistically unique job vertex IDs.
OperatorID A class for statistically unique operator IDs.
OperatorInstanceID An ID for physical instance of the operator.
RestoreMode Defines how Flink should restore from a given savepoint or retained checkpoint.
SavepointRestoreSettings Savepoint restore settings.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.checkpoint.channel

Class and Description
JobVertexID A class for statistically unique job vertex IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.checkpoint.filemerging

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.client

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.deployment

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.
IntermediateResultPartitionID Id identifying IntermediateResultPartition.
JobType Enum to distinguish JobGraphs between batch and streaming, currently used by the scheduler.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.dispatcher

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
JobResourceRequirements Information about the parallelism of job vertices.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.dispatcher.runner

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.entrypoint.component

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.execution

Class and Description
JobVertexID A class for statistically unique job vertex IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.executiongraph

Class and Description
DistributionPattern A distribution pattern determines, which sub tasks of a producing task are connected to which consuming sub tasks.
IntermediateDataSet An intermediate data set is the data set produced by an operator - either a source or any intermediate operation.
IntermediateDataSetID Id identifying IntermediateDataSet.
IntermediateResultPartitionID Id identifying IntermediateResultPartition.
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
JobVertex The base class for job vertexes.
JobVertex.InitializeOnMasterContext
JobVertexID A class for statistically unique job vertex IDs.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.executiongraph.failover.flip1

Class and Description
IntermediateResultPartitionID Id identifying IntermediateResultPartition.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.io.network.partition

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.
IntermediateResultPartitionID Id identifying IntermediateResultPartition.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.io.network.partition.consumer

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.
IntermediateResultPartitionID Id identifying IntermediateResultPartition.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.io.network.partition.hybrid.tiered.common

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.jobgraph

Class and Description
DistributionPattern A distribution pattern determines, which sub tasks of a producing task are connected to which consuming sub tasks.
InputOutputFormatContainer A container for InputFormats and OutputFormats, along with their Configuration.
IntermediateDataSet An intermediate data set is the data set produced by an operator - either a source or any intermediate operation.
IntermediateDataSetID Id identifying IntermediateDataSet.
IntermediateResultPartitionID Id identifying IntermediateResultPartition.
JobEdge This class represent edges (communication channels) in a job graph.
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
JobGraphBuilder Builder for the JobGraph.
JobGraphUtils Utilities for generating JobGraph.
JobResourceRequirements Information about the parallelism of job vertices.
JobResourceRequirements.Builder
JobType Enum to distinguish JobGraphs between batch and streaming, currently used by the scheduler.
JobVertex The base class for job vertexes.
JobVertex.FinalizeOnMasterContext The context exposes some runtime infos for finalization.
JobVertex.InitializeOnMasterContext
JobVertexID A class for statistically unique job vertex IDs.
JobVertexResourceRequirements Information about the parallelism of job vertices.
JobVertexResourceRequirements.Parallelism
OperatorID A class for statistically unique operator IDs.
OperatorInstanceID An ID for physical instance of the operator.
RestoreMode Defines how Flink should restore from a given savepoint or retained checkpoint.
SavepointRestoreSettings Savepoint restore settings.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.jobgraph.forwardgroup

Class and Description
JobVertex The base class for job vertexes.
JobVertexID A class for statistically unique job vertex IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.jobgraph.jsonplan

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
JobType Enum to distinguish JobGraphs between batch and streaming, currently used by the scheduler.
JobVertex The base class for job vertexes.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.jobgraph.tasks

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.jobgraph.topology

Class and Description
DistributionPattern A distribution pattern determines, which sub tasks of a producing task are connected to which consuming sub tasks.
IntermediateDataSetID Id identifying IntermediateDataSet.
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
JobVertex The base class for job vertexes.
JobVertexID A class for statistically unique job vertex IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.jobmanager

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
JobResourceRequirements Information about the parallelism of job vertices.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.jobmanager.scheduler

Class and Description
JobVertex The base class for job vertexes.
JobVertexID A class for statistically unique job vertex IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.jobmanager.slots

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.jobmaster

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
JobResourceRequirements Information about the parallelism of job vertices.
JobType Enum to distinguish JobGraphs between batch and streaming, currently used by the scheduler.
JobVertexID A class for statistically unique job vertex IDs.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.jobmaster.factories

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.metrics.groups

Class and Description
IntermediateResultPartitionID Id identifying IntermediateResultPartition.
JobVertexID A class for statistically unique job vertex IDs.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.metrics.scope

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.minicluster

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.operators.coordination

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.query

Class and Description
JobVertexID A class for statistically unique job vertex IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.resourcemanager

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.rest.messages

Class and Description
JobVertexID A class for statistically unique job vertex IDs.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.rest.messages.checkpoints

Class and Description
JobVertexID A class for statistically unique job vertex IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.rest.messages.dataset

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.rest.messages.job

Class and Description
JobResourceRequirements Information about the parallelism of job vertices.
JobVertexID A class for statistically unique job vertex IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.rest.messages.json

Class and Description
JobVertexID A class for statistically unique job vertex IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.scheduler

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
JobResourceRequirements Information about the parallelism of job vertices.
JobVertex The base class for job vertexes.
JobVertexID A class for statistically unique job vertex IDs.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.scheduler.adapter

Class and Description
IntermediateResultPartitionID Id identifying IntermediateResultPartition.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.scheduler.adaptive

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
JobResourceRequirements Information about the parallelism of job vertices.
JobVertexID A class for statistically unique job vertex IDs.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.scheduler.adaptive.allocator

Class and Description
JobVertexID A class for statistically unique job vertex IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.scheduler.adaptivebatch

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
JobVertex The base class for job vertexes.
JobVertexID A class for statistically unique job vertex IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.scheduler.metrics

Class and Description
JobType Enum to distinguish JobGraphs between batch and streaming, currently used by the scheduler.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.scheduler.strategy

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.
IntermediateResultPartitionID Id identifying IntermediateResultPartition.
JobVertexID A class for statistically unique job vertex IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.shuffle

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.
IntermediateResultPartitionID Id identifying IntermediateResultPartition.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.source.coordinator

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.state

Class and Description
JobVertexID A class for statistically unique job vertex IDs.
OperatorID A class for statistically unique operator IDs.
RestoreMode Defines how Flink should restore from a given savepoint or retained checkpoint.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.taskexecutor

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.
JobVertexID A class for statistically unique job vertex IDs.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.taskexecutor.partition

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.taskexecutor.rpc

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.
JobVertexID A class for statistically unique job vertex IDs.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.taskmanager

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.
JobVertexID A class for statistically unique job vertex IDs.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.util

Class and Description
JobType Enum to distinguish JobGraphs between batch and streaming, currently used by the scheduler.
OperatorID A class for statistically unique operator IDs.
RestoreMode Defines how Flink should restore from a given savepoint or retained checkpoint.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.webmonitor

Class and Description
JobResourceRequirements Information about the parallelism of job vertices.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.webmonitor.handlers

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
RestoreMode Defines how Flink should restore from a given savepoint or retained checkpoint.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.runtime.webmonitor.handlers.utils

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.state.api

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.state.api.output

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.state.api.output.operators

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.state.api.runtime

Class and Description
JobVertexID A class for statistically unique job vertex IDs.
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.streaming.api.environment

Class and Description
SavepointRestoreSettings Savepoint restore settings.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.streaming.api.graph

Class and Description
IntermediateDataSetID Id identifying IntermediateDataSet.
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.
JobType Enum to distinguish JobGraphs between batch and streaming, currently used by the scheduler.
OperatorID A class for statistically unique operator IDs.
SavepointRestoreSettings Savepoint restore settings.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.streaming.api.operators

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.streaming.api.operators.collect

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.streaming.runtime.io

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.streaming.runtime.streamrecord

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.streaming.runtime.tasks

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.streaming.util

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.table.runtime.operators.dynamicfiltering

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.table.runtime.operators.hive.script

Class and Description
OperatorID A class for statistically unique operator IDs.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.test.util

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.

Classes in org.apache.flink.runtime.jobgraph used by org.apache.flink.yarn

Class and Description
JobGraph The JobGraph represents a Flink dataflow program, at the low level that the JobManager accepts.