Package org.apache.flink.autoscaler.event

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

java.lang.Object

org.apache.flink.autoscaler.event.LoggingEventHandler<KEY,Context>

All Implemented Interfaces:

AutoScalerEventHandler<KEY,Context>

public class LoggingEventHandler<KEY,Context extends JobAutoScalerContext<KEY>>
extends java.lang.Object
implements AutoScalerEventHandler<KEY,Context>

Autoscaler event handler which logs events.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.autoscaler.event.AutoScalerEventHandler

AutoScalerEventHandler.Type

Field Summary

Fields inherited from interface org.apache.flink.autoscaler.event.AutoScalerEventHandler

SCALING_EXECUTION_DISABLED_REASON, SCALING_REPORT_KEY, SCALING_REPORT_REASON, SCALING_SUMMARY_ENTRY, SCALING_SUMMARY_HEADER_SCALING_EXECUTION_DISABLED, SCALING_SUMMARY_HEADER_SCALING_EXECUTION_ENABLED

Constructor Summary

Constructors

Constructor	Description
LoggingEventHandler()

Method Summary

Modifier and Type	Method	Description
void	handleEvent(Context context, AutoScalerEventHandler.Type type, java.lang.String reason, java.lang.String message, java.lang.String messageKey, java.time.Duration interval)	Handle the event.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.autoscaler.event.AutoScalerEventHandler

handleException, handleScalingEvent

Constructor Detail

LoggingEventHandler

public LoggingEventHandler()

Method Detail

handleEvent

public void handleEvent(Context context,
                        AutoScalerEventHandler.Type type,
                        java.lang.String reason,
                        java.lang.String message,
                        @Nullable
                        java.lang.String messageKey,
                        @Nullable
                        java.time.Duration interval)

Description copied from interface: AutoScalerEventHandler

Handle the event.

Specified by:

handleEvent in interface AutoScalerEventHandler<KEY,Context extends JobAutoScalerContext<KEY>>

interval - Define the interval to suppress duplicate events. No dedupe if null.