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

Class AsyncSinkWriterStateSerializer<RequestEntryT extends Serializable>

java.lang.Object

org.apache.flink.connector.base.sink.writer.AsyncSinkWriterStateSerializer<RequestEntryT>

Type Parameters:

RequestEntryT - Writer Request Entry type

All Implemented Interfaces:

SimpleVersionedSerializer<BufferedRequestState<RequestEntryT>>, Versioned

@PublicEvolving
public abstract class AsyncSinkWriterStateSerializer<RequestEntryT extends Serializable>
extends Object
implements SimpleVersionedSerializer<BufferedRequestState<RequestEntryT>>

Serializer class for AsyncSinkWriter state.

Constructor Summary

Constructors

Constructor and Description
AsyncSinkWriterStateSerializer()

Method Summary

Modifier and Type	Method and Description
BufferedRequestState<RequestEntryT>	deserialize(int version, byte[] serialized) De-serializes the given data (bytes) which was serialized with the scheme of the indicated version.
protected abstract RequestEntryT	deserializeRequestFromStream(long requestSize, DataInputStream in)
byte[]	serialize(BufferedRequestState<RequestEntryT> obj) Serializes state in form of [DATA_IDENTIFIER,NUM_OF_ELEMENTS,SIZE1,REQUEST1,SIZE2,REQUEST2....].
protected abstract void	serializeRequestToStream(RequestEntryT request, DataOutputStream out)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.core.io.SimpleVersionedSerializer

getVersion

Constructor Detail

AsyncSinkWriterStateSerializer

public AsyncSinkWriterStateSerializer()

Method Detail

serialize

public byte[] serialize(BufferedRequestState<RequestEntryT> obj)
                 throws IOException

Serializes state in form of [DATA_IDENTIFIER,NUM_OF_ELEMENTS,SIZE1,REQUEST1,SIZE2,REQUEST2....].

Specified by:

serialize in interface SimpleVersionedSerializer<BufferedRequestState<RequestEntryT extends Serializable>>

Parameters:

obj - The object to serialize.

Returns:

The serialized data (bytes).

Throws:

IOException - Thrown, if the serialization fails.

deserialize

public BufferedRequestState<RequestEntryT> deserialize(int version,
                                                       byte[] serialized)
                                                throws IOException

Description copied from interface: SimpleVersionedSerializer

De-serializes the given data (bytes) which was serialized with the scheme of the indicated version.

Specified by:

deserialize in interface SimpleVersionedSerializer<BufferedRequestState<RequestEntryT extends Serializable>>

Parameters:

version - The version in which the data was serialized

serialized - The serialized data

Returns:

The deserialized object

Throws:

IOException - Thrown, if the deserialization fails.

serializeRequestToStream

protected abstract void serializeRequestToStream(RequestEntryT request,
                                                 DataOutputStream out)
                                          throws IOException

Throws:

IOException

deserializeRequestFromStream

protected abstract RequestEntryT deserializeRequestFromStream(long requestSize,
                                                              DataInputStream in)
                                                       throws IOException

Throws:

IOException