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 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 void scaling()

scalingSingleJob

@VisibleForTesting
protected void scalingSingleJob(Context jobContext)