Uses of Class
org.apache.flink.runtime.messages.webmonitor.JobDetails
-
Packages that use JobDetails Package Description org.apache.flink.runtime.dispatcher org.apache.flink.runtime.dispatcher.cleanup org.apache.flink.runtime.jobmaster org.apache.flink.runtime.messages.webmonitor This package contains the actor messages that are sent between the JobManager and components that are interested in the status of the JobManager.org.apache.flink.runtime.rest.handler.legacy.metrics org.apache.flink.runtime.scheduler org.apache.flink.runtime.scheduler.adaptive -
-
Uses of JobDetails in org.apache.flink.runtime.dispatcher
Methods in org.apache.flink.runtime.dispatcher that return JobDetails Modifier and Type Method Description JobDetailsExecutionGraphInfoStore. getAvailableJobDetails(org.apache.flink.api.common.JobID jobId)Return theJobDetails} for the given job.JobDetailsFileExecutionGraphInfoStore. getAvailableJobDetails(org.apache.flink.api.common.JobID jobId)JobDetailsMemoryExecutionGraphInfoStore. getAvailableJobDetails(org.apache.flink.api.common.JobID jobId)Methods in org.apache.flink.runtime.dispatcher that return types with arguments of type JobDetails Modifier and Type Method Description Collection<JobDetails>ExecutionGraphInfoStore. getAvailableJobDetails()Return the collection ofJobDetailsof all currently stored jobs.Collection<JobDetails>FileExecutionGraphInfoStore. getAvailableJobDetails()Collection<JobDetails>MemoryExecutionGraphInfoStore. getAvailableJobDetails() -
Uses of JobDetails in org.apache.flink.runtime.dispatcher.cleanup
Methods in org.apache.flink.runtime.dispatcher.cleanup that return types with arguments of type JobDetails Modifier and Type Method Description CompletableFuture<JobDetails>CheckpointResourcesCleanupRunner. requestJobDetails(org.apache.flink.api.common.time.Time timeout) -
Uses of JobDetails in org.apache.flink.runtime.jobmaster
Methods in org.apache.flink.runtime.jobmaster that return types with arguments of type JobDetails Modifier and Type Method Description CompletableFuture<JobDetails>JobManagerRunner. requestJobDetails(org.apache.flink.api.common.time.Time timeout)Request the details of the executed job.CompletableFuture<JobDetails>JobMaster. requestJobDetails(org.apache.flink.api.common.time.Time timeout)CompletableFuture<JobDetails>JobMasterGateway. requestJobDetails(org.apache.flink.api.common.time.Time timeout)Request the details of the executed job.CompletableFuture<JobDetails>JobMasterServiceLeadershipRunner. requestJobDetails(org.apache.flink.api.common.time.Time timeout) -
Uses of JobDetails in org.apache.flink.runtime.messages.webmonitor
Methods in org.apache.flink.runtime.messages.webmonitor that return JobDetails Modifier and Type Method Description static JobDetailsJobDetails. createDetailsForJob(AccessExecutionGraph job)Methods in org.apache.flink.runtime.messages.webmonitor that return types with arguments of type JobDetails Modifier and Type Method Description Collection<JobDetails>MultipleJobsDetails. getJobs()Constructor parameters in org.apache.flink.runtime.messages.webmonitor with type arguments of type JobDetails Constructor Description MultipleJobsDetails(Collection<JobDetails> jobs) -
Uses of JobDetails in org.apache.flink.runtime.rest.handler.legacy.metrics
Method parameters in org.apache.flink.runtime.rest.handler.legacy.metrics with type arguments of type JobDetails Modifier and Type Method Description voidMetricStore. updateCurrentExecutionAttempts(Collection<JobDetails> jobs) -
Uses of JobDetails in org.apache.flink.runtime.scheduler
Methods in org.apache.flink.runtime.scheduler that return JobDetails Modifier and Type Method Description JobDetailsSchedulerBase. requestJobDetails()JobDetailsSchedulerNG. requestJobDetails() -
Uses of JobDetails in org.apache.flink.runtime.scheduler.adaptive
Methods in org.apache.flink.runtime.scheduler.adaptive that return JobDetails Modifier and Type Method Description JobDetailsAdaptiveScheduler. requestJobDetails()
-