Uses of Class
org.apache.flink.connector.base.sink.writer.RequestEntryWrapper

Packages that use RequestEntryWrapper

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

Uses of RequestEntryWrapper in org.apache.flink.connector.base.sink.writer

Methods in org.apache.flink.connector.base.sink.writer that return RequestEntryWrapper

Modifier and Type	Method	Description
RequestEntryWrapper<RequestEntryT>	DequeRequestBuffer.peek()	Retrieves, but does not remove, the next available request entry from the buffer.
RequestEntryWrapper<RequestEntryT>	RequestBuffer.peek()	Retrieves, but does not remove, the next available request entry from the buffer.
RequestEntryWrapper<RequestEntryT>	DequeRequestBuffer.poll()	Retrieves and removes the next available request entry from the buffer.
RequestEntryWrapper<RequestEntryT>	RequestBuffer.poll()	Retrieves and removes the next available request entry from the buffer.

Methods in org.apache.flink.connector.base.sink.writer that return types with arguments of type RequestEntryWrapper

Modifier and Type	Method	Description
List<RequestEntryWrapper<RequestEntryT>>	BufferedRequestState.getBufferedRequestEntries()
Collection<RequestEntryWrapper<RequestEntryT>>	DequeRequestBuffer.getBufferedState()	Retrieves all buffered request entries as a collection.
Collection<RequestEntryWrapper<RequestEntryT>>	RequestBuffer.getBufferedState()	Retrieves all buffered request entries as a collection.

Methods in org.apache.flink.connector.base.sink.writer with parameters of type RequestEntryWrapper

Modifier and Type	Method	Description
void	DequeRequestBuffer.add(RequestEntryWrapper<RequestEntryT> entry, boolean prioritize)	Adds a request entry to the buffer.
void	RequestBuffer.add(RequestEntryWrapper<RequestEntryT> entry, boolean prioritize)	Adds an entry (RequestEntryWrapper<RequestEntryT>) to the buffer.

Constructor parameters in org.apache.flink.connector.base.sink.writer with type arguments of type RequestEntryWrapper

Constructor	Description
BufferedRequestState(Deque<RequestEntryWrapper<RequestEntryT>> bufferedRequestEntries)	Deprecated.
BufferedRequestState(List<RequestEntryWrapper<RequestEntryT>> bufferedRequestEntries)