RequestEntryWrapper (Flink : Connectors : Base 2.1.1-cp1 API)

java.lang.Object
- org.apache.flink.connector.base.sink.writer.RequestEntryWrapper<RequestEntryT>

Type Parameters:

RequestEntryT - Corresponds to the type parameter of the same name in AsyncSinkWriter
```
@PublicEvolving
public class RequestEntryWrapper<RequestEntryT>
extends Object
```
A wrapper that contains a RequestEntryT ready to be written by the Sink Writer class, along with the size of that entry as defined by the method getSizeInBytes(RequestEntryT) of the AsyncSinkWriter.

- Constructor Summary
  
  Constructors
  Constructor Description
  
  RequestEntryWrapper(RequestEntryT requestEntry, long size)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  RequestEntryT getRequestEntry()
  
  long getSize()
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RequestEntryWrapper

public RequestEntryWrapper(RequestEntryT requestEntry,
                           long size)

Method Detail

getRequestEntry

public RequestEntryT getRequestEntry()

getSize
```
public long getSize()
```