Class and Description |
---|
ElementConverter
This interface specifies the mapping between elements of a stream to request entries that can be
sent to the destination.
|
Class and Description |
---|
BufferedRequestState
Class holding state of
AsyncSinkWriter needed at taking a snapshot. |
ElementConverter
This interface specifies the mapping between elements of a stream to request entries that can be
sent to the destination.
|
RequestEntryWrapper
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 . |
Class and Description |
---|
AsyncSinkWriterStateSerializer
Serializer class for
AsyncSinkWriter state. |
BufferedRequestState
Class holding state of
AsyncSinkWriter needed at taking a snapshot. |
ElementConverter
This interface specifies the mapping between elements of a stream to request entries that can be
sent to the destination.
|
Class and Description |
---|
AsyncSinkWriterStateSerializer
Serializer class for
AsyncSinkWriter state. |
BufferedRequestState
Class holding state of
AsyncSinkWriter needed at taking a snapshot. |
ElementConverter
This interface specifies the mapping between elements of a stream to request entries that can be
sent to the destination.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.