Interface JobListFetcher<KEY,​Context extends JobAutoScalerContext<KEY>>

    • Method Detail

      • fetch

        java.util.Collection<Context> fetch​(org.apache.flink.configuration.Configuration baseConf)
                                     throws java.lang.Exception
        Fetch the job context.
        Parameters:
        baseConf - The basic configuration for standalone autoscaler. The basic configuration can be overridden by the configuration at job-level.
        Throws:
        java.lang.Exception