Package 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:

org.apache.flink.core.io.SimpleVersionedSerializer<BufferedRequestState<RequestEntryT>>, org.apache.flink.core.io.Versioned

@PublicEvolving
public abstract class AsyncSinkWriterStateSerializer<RequestEntryT extends Serializable>
extends Object
implements org.apache.flink.core.io.SimpleVersionedSerializer<BufferedRequestState<RequestEntryT>>

Serializer class for AsyncSinkWriter state.

Constructor Summary

Constructors

Constructor	Description
AsyncSinkWriterStateSerializer()

Method Summary

Modifier and Type	Method	Description
BufferedRequestState<RequestEntryT>	deserialize(int version, byte[] serialized)
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 org.apache.flink.core.io.SimpleVersionedSerializer<RequestEntryT extends Serializable>

Throws:

IOException

deserialize

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

Specified by:

deserialize in interface org.apache.flink.core.io.SimpleVersionedSerializer<RequestEntryT extends Serializable>

Throws:

IOException

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