public class BufferDebloater extends Object
Constructor and Description |
---|
BufferDebloater(Configuration taskConfig,
IndexedInputGate[] inputGates) |
Modifier and Type | Method and Description |
---|---|
int |
getLastBufferSize() |
java.time.Duration |
getLastEstimatedTimeToConsumeBuffers() |
void |
recalculateBufferSize(long currentThroughput) |
public BufferDebloater(Configuration taskConfig, IndexedInputGate[] inputGates)
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.