Modifier and Type | Method and 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 |
setJobId(JobID jobId) |
JobGraphBuilder |
setJobName(String jobName) |
JobGraphBuilder |
setSavepointRestoreSettings(SavepointRestoreSettings newSavepointRestoreSettings) |
public JobGraphBuilder setJobName(String jobName)
public JobGraphBuilder addJobVertices(Collection<? extends JobVertex> jobVerticesToAdd)
public JobGraphBuilder addJobVertex(JobVertex jobVertex)
public JobGraphBuilder setJobId(JobID jobId)
public JobGraphBuilder setExecutionConfig(ExecutionConfig newExecutionConfig) throws IOException
IOException
public JobGraphBuilder addUserArtifacts(Map<String,DistributedCache.DistributedCacheEntry> newUserArtifacts)
public JobGraphBuilder setJobCheckpointingSettings(JobCheckpointingSettings newJobCheckpointingSettings)
public JobGraphBuilder setSavepointRestoreSettings(SavepointRestoreSettings newSavepointRestoreSettings)
public JobGraphBuilder addClasspaths(Collection<URL> additionalClasspaths)
public JobGraph build()
public static JobGraphBuilder newStreamingJobGraphBuilder()
public static JobGraphBuilder newBatchJobGraphBuilder()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.