Package org.apache.flink.autoscaler.standalone

Class StandaloneAutoscalerExecutor<KEY,Context extends JobAutoScalerContext<KEY>>

java.lang.Object

org.apache.flink.autoscaler.standalone.StandaloneAutoscalerExecutor<KEY,Context>

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class StandaloneAutoscalerExecutor<KEY,Context extends JobAutoScalerContext<KEY>>
extends java.lang.Object
implements java.io.Closeable

The executor of the standalone autoscaler.

Field Summary

Fields

Modifier and Type	Field	Description
protected static java.lang.String	AUTOSCALER_ERROR

Constructor Summary

Constructors

Constructor	Description
StandaloneAutoscalerExecutor(org.apache.flink.configuration.Configuration conf, JobListFetcher<KEY,Context> jobListFetcher, AutoScalerEventHandler<KEY,Context> eventHandler, JobAutoScaler<KEY,Context> autoScaler)

Method Summary

Modifier and Type	Method	Description
void	close()
protected java.util.List<java.util.concurrent.CompletableFuture<java.lang.Void>>	scaling()
protected void	scalingSingleJob(Context jobContext)
void	start()

Methods inherited from class java.lang.Object

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

Field Detail

AUTOSCALER_ERROR

@VisibleForTesting
protected static final java.lang.String AUTOSCALER_ERROR

See Also:

Constant Field Values

Constructor Detail

StandaloneAutoscalerExecutor

public StandaloneAutoscalerExecutor(@Nonnull
                                    org.apache.flink.configuration.Configuration conf,
                                    @Nonnull
                                    JobListFetcher<KEY,Context> jobListFetcher,
                                    @Nonnull
                                    AutoScalerEventHandler<KEY,Context> eventHandler,
                                    @Nonnull
                                    JobAutoScaler<KEY,Context> autoScaler)

Method Detail

start

public void start()

close

public void close()

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

scaling

@VisibleForTesting
protected java.util.List<java.util.concurrent.CompletableFuture<java.lang.Void>> scaling()

Returns:

All CompletableFuture for all scaling jobs, note: it's only used for test for now.

scalingSingleJob

@VisibleForTesting
protected void scalingSingleJob(Context jobContext)