Package org.apache.flink.connector.base.sink.writer

Class BufferedRequestState<RequestEntryT extends Serializable>

  • Type Parameters:
    RequestEntryT - request type.
    All Implemented Interfaces:
    Serializable
    @PublicEvolving
public class BufferedRequestState<RequestEntryT extends Serializable>
extends Object
implements Serializable
    Class holding state of AsyncSinkWriter needed at taking a snapshot. The state captures the bufferedRequestEntries buffer for the writer at snapshot to resume the requests. This guarantees at least once semantic in sending requests where restoring from a snapshot where buffered requests were flushed to the sink will cause duplicate requests.
    See Also:
    Serialized Form