RequestEntryT
- request type.@PublicEvolving public class BufferedRequestState<RequestEntryT extends Serializable> extends Object implements Serializable
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.Constructor and Description |
---|
BufferedRequestState(Deque<RequestEntryWrapper<RequestEntryT>> bufferedRequestEntries) |
BufferedRequestState(List<RequestEntryWrapper<RequestEntryT>> bufferedRequestEntries) |
Modifier and Type | Method and Description |
---|---|
static <T extends Serializable> |
emptyState() |
List<RequestEntryWrapper<RequestEntryT>> |
getBufferedRequestEntries() |
long |
getStateSize() |
public BufferedRequestState(Deque<RequestEntryWrapper<RequestEntryT>> bufferedRequestEntries)
public BufferedRequestState(List<RequestEntryWrapper<RequestEntryT>> bufferedRequestEntries)
public List<RequestEntryWrapper<RequestEntryT>> getBufferedRequestEntries()
public long getStateSize()
public static <T extends Serializable> BufferedRequestState<T> emptyState()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.