Class JobGraphBuilder
- java.lang.Object
-
- org.apache.flink.runtime.jobgraph.JobGraphBuilder
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description JobGraphBuilder
addClasspaths(Collection<URL> additionalClasspaths)
JobGraphBuilder
addJobVertex(JobVertex jobVertex)
JobGraphBuilder
addJobVertices(Collection<? extends JobVertex> jobVerticesToAdd)
JobGraphBuilder
addUserArtifacts(Map<String,DistributedCache.DistributedCacheEntry> newUserArtifacts)
JobGraph
build()
static JobGraphBuilder
newBatchJobGraphBuilder()
static JobGraphBuilder
newStreamingJobGraphBuilder()
JobGraphBuilder
setExecutionConfig(ExecutionConfig newExecutionConfig)
JobGraphBuilder
setJobCheckpointingSettings(JobCheckpointingSettings newJobCheckpointingSettings)
JobGraphBuilder
setJobConfiguration(Configuration jobConfiguration)
JobGraphBuilder
setJobId(JobID jobId)
JobGraphBuilder
setJobName(String jobName)
JobGraphBuilder
setSavepointRestoreSettings(SavepointRestoreSettings newSavepointRestoreSettings)
-
-
-
Method Detail
-
setJobName
public JobGraphBuilder setJobName(String jobName)
-
addJobVertices
public JobGraphBuilder addJobVertices(Collection<? extends JobVertex> jobVerticesToAdd)
-
addJobVertex
public JobGraphBuilder addJobVertex(JobVertex jobVertex)
-
setJobId
public JobGraphBuilder setJobId(JobID jobId)
-
setExecutionConfig
public JobGraphBuilder setExecutionConfig(ExecutionConfig newExecutionConfig) throws IOException
- Throws:
IOException
-
addUserArtifacts
public JobGraphBuilder addUserArtifacts(Map<String,DistributedCache.DistributedCacheEntry> newUserArtifacts)
-
setJobCheckpointingSettings
public JobGraphBuilder setJobCheckpointingSettings(JobCheckpointingSettings newJobCheckpointingSettings)
-
setSavepointRestoreSettings
public JobGraphBuilder setSavepointRestoreSettings(SavepointRestoreSettings newSavepointRestoreSettings)
-
addClasspaths
public JobGraphBuilder addClasspaths(Collection<URL> additionalClasspaths)
-
setJobConfiguration
public JobGraphBuilder setJobConfiguration(Configuration jobConfiguration)
-
build
public JobGraph build()
-
newStreamingJobGraphBuilder
public static JobGraphBuilder newStreamingJobGraphBuilder()
-
newBatchJobGraphBuilder
public static JobGraphBuilder newBatchJobGraphBuilder()
-
-