Package org.apache.flink.runtime.asyncprocessing

Class StateRequestBuffer<K>

java.lang.Object

org.apache.flink.runtime.asyncprocessing.StateRequestBuffer<K>

Type Parameters:

K - the type of the key

@NotThreadSafe
public class StateRequestBuffer<K>
extends Object

A buffer to hold state requests to execute state requests in batch, which can only be manipulated within task thread.

Constructor Summary

Constructors

Constructor	Description
StateRequestBuffer(long bufferTimeout, java.util.function.Consumer<Long> timeoutHandler)

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

StateRequestBuffer

public StateRequestBuffer(long bufferTimeout,
                          java.util.function.Consumer<Long> timeoutHandler)