Modifier and Type | Method and Description |
---|---|
CompletableFuture<MultipleJobsDetails> |
AkkaJobManagerGateway.requestJobDetails(boolean includeRunning,
boolean includeFinished,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<MultipleJobsDetails> |
Dispatcher.requestJobDetails(boolean includeRunning,
boolean includeFinished,
Time timeout) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<MultipleJobsDetails> |
CurrentJobsOverviewHandler.handleRequest(HandlerRequest<EmptyRequestBody,EmptyMessageParameters> request,
DispatcherGateway gateway) |
Modifier and Type | Method and Description |
---|---|
Class<MultipleJobsDetails> |
CurrentJobsOverviewHandlerHeaders.getResponseClass() |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<MultipleJobsDetails> |
RestfulGateway.requestJobDetails(boolean includeRunning,
boolean includeFinished,
Time timeout)
Requests job details currently being executed on the Flink cluster.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.