Package org.apache.flink.autoscaler.standalone.flinkcluster

Class FlinkClusterJobListFetcher

  • All Implemented Interfaces:
    JobListFetcher<org.apache.flink.api.common.JobID,​JobAutoScalerContext<org.apache.flink.api.common.JobID>>
    public class FlinkClusterJobListFetcher
extends java.lang.Object
implements JobListFetcher<org.apache.flink.api.common.JobID,​JobAutoScalerContext<org.apache.flink.api.common.JobID>>
    Fetch JobAutoScalerContext based on flink cluster.

    • Constructor Summary

      Constructors 
      Constructor Description
      FlinkClusterJobListFetcher​(org.apache.flink.util.function.FunctionWithException<org.apache.flink.configuration.Configuration,​org.apache.flink.client.program.rest.RestClusterClient<java.lang.String>,​java.lang.Exception> restClientGetter, java.time.Duration restClientTimeout)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.util.Collection<JobAutoScalerContext<org.apache.flink.api.common.JobID>> fetch​(org.apache.flink.configuration.Configuration baseConf)
      Fetch the job context.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • FlinkClusterJobListFetcher

        public FlinkClusterJobListFetcher​(org.apache.flink.util.function.FunctionWithException<org.apache.flink.configuration.Configuration,​org.apache.flink.client.program.rest.RestClusterClient<java.lang.String>,​java.lang.Exception> restClientGetter,
                                  java.time.Duration restClientTimeout)

    • Method Detail

      • fetch

        public java.util.Collection<JobAutoScalerContext<org.apache.flink.api.common.JobID>> fetch​(org.apache.flink.configuration.Configuration baseConf)
                                                                                    throws java.lang.Exception
        Description copied from interface: JobListFetcher
        Fetch the job context.
        Specified by:
        fetch in interface JobListFetcher<org.apache.flink.api.common.JobID,​JobAutoScalerContext<org.apache.flink.api.common.JobID>>
        Parameters:
        baseConf - The basic configuration for standalone autoscaler. The basic configuration can be overridden by the configuration at job-level.
        Throws:
        java.lang.Exception