org.apache.flink.streaming.runtime.tasks.bufferdebloat

Class BufferDebloater

java.lang.Object

org.apache.flink.streaming.runtime.tasks.bufferdebloat.BufferDebloater

public class BufferDebloater
extends Object

Class for automatic calculation of the buffer size based on the current throughput and configuration.

Constructor Summary

Constructors

Constructor and Description
BufferDebloater(org.apache.flink.configuration.Configuration taskConfig, org.apache.flink.runtime.io.network.partition.consumer.IndexedInputGate[] inputGates)

Method Summary

Modifier and Type	Method and Description
int	getLastBufferSize()
java.time.Duration	getLastEstimatedTimeToConsumeBuffers()
void	recalculateBufferSize(long currentThroughput)

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferDebloater

public BufferDebloater(org.apache.flink.configuration.Configuration taskConfig,
                       org.apache.flink.runtime.io.network.partition.consumer.IndexedInputGate[] inputGates)

Method Detail

recalculateBufferSize

public void recalculateBufferSize(long currentThroughput)

getLastBufferSize

public int getLastBufferSize()

getLastEstimatedTimeToConsumeBuffers

public java.time.Duration getLastEstimatedTimeToConsumeBuffers()