Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobResult> |
NewClusterClient.requestJobResult(JobID jobId)
|
CompletableFuture<JobResult> |
MiniClusterClient.requestJobResult(JobID jobId) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobResult> |
RestClusterClient.requestJobResult(JobID jobId)
|
Modifier and Type | Method and Description |
---|---|
CompletableFuture<JobResult> |
AkkaJobManagerGateway.requestJobResult(JobID jobId,
Time timeout) |
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–2019 The Apache Software Foundation. All rights reserved.