Package | Description |
---|---|
org.apache.flink.client.program | |
org.apache.flink.optimizer.plan | |
org.apache.flink.optimizer.plantranslate | |
org.apache.flink.runtime.client | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobgraph.jsonplan | |
org.apache.flink.runtime.jobmanager | |
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
org.apache.flink.runtime.metrics.groups | |
org.apache.flink.runtime.minicluster | |
org.apache.flink.runtime.webmonitor.handlers | |
org.apache.flink.streaming.api.graph | |
org.apache.flink.yarn |
Modifier and Type | Method and Description |
---|---|
JobGraph |
ClusterClient.getJobGraph(PackagedProgram prog,
FlinkPlan optPlan,
SavepointRestoreSettings savepointSettings) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
ClusterClient.run(JobGraph jobGraph,
ClassLoader classLoader)
Submits a JobGraph blocking.
|
JobSubmissionResult |
ClusterClient.runDetached(JobGraph jobGraph,
ClassLoader classLoader)
Submits a JobGraph detached.
|
protected JobSubmissionResult |
StandaloneClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader) |
protected abstract JobSubmissionResult |
ClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader)
Calls the subclasses' submitJob method.
|
Modifier and Type | Method and Description |
---|---|
abstract JobGraph |
StreamingPlan.getJobGraph() |
Modifier and Type | Method and Description |
---|---|
JobGraph |
JobGraphGenerator.compileJobGraph(OptimizedPlan program)
Translates a
OptimizedPlan into a
JobGraph . |
JobGraph |
JobGraphGenerator.compileJobGraph(OptimizedPlan program,
JobID jobId) |
Modifier and Type | Method and Description |
---|---|
static JobListeningContext |
JobClient.submitJob(akka.actor.ActorSystem actorSystem,
Configuration config,
LeaderRetrievalService leaderRetrievalService,
JobGraph jobGraph,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutLogUpdates,
ClassLoader classLoader)
Submits a job to a Flink cluster (non-blocking) and returns a JobListeningContext which can be
passed to
awaitJobResult to get the result of the submission. |
static JobExecutionResult |
JobClient.submitJobAndWait(akka.actor.ActorSystem actorSystem,
Configuration config,
LeaderRetrievalService leaderRetrievalService,
JobGraph jobGraph,
scala.concurrent.duration.FiniteDuration timeout,
boolean sysoutLogUpdates,
ClassLoader classLoader)
Sends a [[JobGraph]] to the JobClient actor specified by jobClient which submits it then to
the JobManager.
|
static void |
JobClient.submitJobDetached(ActorGateway jobManagerGateway,
Configuration config,
JobGraph jobGraph,
scala.concurrent.duration.FiniteDuration timeout,
ClassLoader classLoader)
Submits a job in detached mode.
|
Modifier and Type | Method and Description |
---|---|
static ExecutionGraph |
ExecutionGraphBuilder.buildGraph(ExecutionGraph prior,
JobGraph jobGraph,
Configuration jobManagerConfig,
Executor futureExecutor,
Executor ioExecutor,
SlotProvider slotProvider,
ClassLoader classLoader,
CheckpointRecoveryFactory recoveryFactory,
Time timeout,
RestartStrategy restartStrategy,
MetricGroup metrics,
int parallelismForAutoMax,
org.slf4j.Logger log)
Builds the ExecutionGraph from the JobGraph.
|
Modifier and Type | Method and Description |
---|---|
static String |
JsonPlanGenerator.generatePlan(JobGraph jg) |
Modifier and Type | Method and Description |
---|---|
JobGraph |
SubmittedJobGraph.getJobGraph()
Returns the submitted
JobGraph . |
Constructor and Description |
---|
SubmittedJobGraph(JobGraph jobGraph,
JobInfo jobInfo)
Creates a
SubmittedJobGraph . |
Modifier and Type | Method and Description |
---|---|
JobGraph |
JobManagerMessages.SubmitJob.jobGraph() |
JobGraph |
JobClientMessages.SubmitJobAndWait.jobGraph() |
Constructor and Description |
---|
SubmitJob(JobGraph jobGraph,
ListeningBehaviour listeningBehaviour) |
SubmitJobAndWait(JobGraph jobGraph) |
Modifier and Type | Method and Description |
---|---|
JobManagerJobMetricGroup |
JobManagerMetricGroup.addJob(JobGraph job) |
Modifier and Type | Method and Description |
---|---|
JobExecutionResult |
FlinkMiniCluster.submitJobAndWait(JobGraph jobGraph,
boolean printUpdates) |
JobExecutionResult |
FlinkMiniCluster.submitJobAndWait(JobGraph jobGraph,
boolean printUpdates,
scala.concurrent.duration.FiniteDuration timeout) |
JobExecutionResult |
FlinkMiniCluster.submitJobAndWait(JobGraph jobGraph,
boolean printUpdates,
scala.concurrent.duration.FiniteDuration timeout,
LeaderRetrievalService leaderRetrievalService) |
JobSubmissionResult |
FlinkMiniCluster.submitJobDetached(JobGraph jobGraph) |
Modifier and Type | Method and Description |
---|---|
protected Tuple2<JobGraph,ClassLoader> |
JarActionHandler.getJobGraphAndClassLoader(org.apache.flink.runtime.webmonitor.handlers.JarActionHandler.JarActionHandlerConfig config) |
Modifier and Type | Method and Description |
---|---|
JobGraph |
StreamingJobGraphGenerator.createJobGraph() |
JobGraph |
StreamGraph.getJobGraph()
Gets the assembled
JobGraph . |
Modifier and Type | Method and Description |
---|---|
protected JobSubmissionResult |
YarnClusterClient.submitJob(JobGraph jobGraph,
ClassLoader classLoader) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.