Modifier and Type | Method and Description |
---|---|
static void |
ClientUtils.waitUntilJobInitializationFinished(SupplierWithException<JobStatus,Exception> jobStatusSupplier,
SupplierWithException<JobResult,Exception> jobResultSupplier,
ClassLoader userCodeClassloader)
This method blocks until the job status is not INITIALIZING anymore.
|
Modifier and Type | Method and Description |
---|---|
static UnsuccessfulExecutionException |
UnsuccessfulExecutionException.fromJobResult(JobResult result,
ClassLoader userClassLoader) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobResult> |
MiniClusterClient.requestJobResult(JobID jobId) |
CompletableFuture<JobResult> |
ClusterClient.requestJobResult(JobID jobId)
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobResult> |
RestClusterClient.requestJobResult(JobID jobId)
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobResult> |
Dispatcher.requestJobResult(JobID jobId,
Time timeout) |
CompletableFuture<JobResult> |
MiniDispatcher.requestJobResult(JobID jobId,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
JobResult |
JobResult.Builder.build() |
static JobResult |
JobResult.createFrom(AccessExecutionGraph accessExecutionGraph)
Creates the
JobResult from the given AccessExecutionGraph which must be in a
globally terminal state. |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobResult> |
MiniCluster.requestJobResult(JobID jobId) |
Modifier and Type | Method and Description |
---|---|
JobResult |
JobExecutionResultResponseBody.getJobExecutionResult() |
JobResult |
JobExecutionResultResponseBody.resource() |
Modifier and Type | Method and Description |
---|---|
static JobExecutionResultResponseBody |
JobExecutionResultResponseBody.created(JobResult jobExecutionResult) |
Constructor and Description |
---|
JobExecutionResultResponseBody(QueueStatus status,
JobResult jobExecutionResult) |
Modifier and Type | Method and Description |
---|---|
JobResult |
JobResultDeserializer.deserialize(org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonParser p,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.DeserializationContext ctxt) |
Modifier and Type | Method and Description |
---|---|
void |
JobResultSerializer.serialize(JobResult result,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.core.JsonGenerator gen,
org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.SerializerProvider provider) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobResult> |
RestfulGateway.requestJobResult(JobID jobId,
Time timeout)
Requests the
JobResult of a job specified by the given jobId. |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.