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

类 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.

构造器概要

构造器

构造器和说明
BufferDebloater(org.apache.flink.configuration.Configuration taskConfig, org.apache.flink.runtime.io.network.partition.consumer.IndexedInputGate[] inputGates)

方法概要

限定符和类型	方法和说明
int	getLastBufferSize()
java.time.Duration	getLastEstimatedTimeToConsumeBuffers()
void	recalculateBufferSize(long currentThroughput)

从类继承的方法 java.lang.Object

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

构造器详细资料

BufferDebloater

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

方法详细资料

recalculateBufferSize

public void recalculateBufferSize(long currentThroughput)

getLastBufferSize

public int getLastBufferSize()

getLastEstimatedTimeToConsumeBuffers

public java.time.Duration getLastEstimatedTimeToConsumeBuffers()