org.apache.flink.streaming.runtime.operators.sink.committables

Class CommittableCollectorSerializer<CommT>

java.lang.Object

org.apache.flink.streaming.runtime.operators.sink.committables.CommittableCollectorSerializer<CommT>

All Implemented Interfaces:

SimpleVersionedSerializer<CommittableCollector<CommT>>, Versioned

@Internal
public final class CommittableCollectorSerializer<CommT>
extends Object
implements SimpleVersionedSerializer<CommittableCollector<CommT>>

The serializer for the CommittableCollector. Compatible to 1.14- StreamingCommitterState.

Constructor Summary

Constructors

Constructor and Description
CommittableCollectorSerializer(SimpleVersionedSerializer<CommT> committableSerializer, int subtaskId, int numberOfSubtasks)

Method Summary

Modifier and Type	Method and Description
CommittableCollector<CommT>	deserialize(int version, byte[] serialized) De-serializes the given data (bytes) which was serialized with the scheme of the indicated version.
int	getVersion() Gets the version with which this serializer serializes.
byte[]	serialize(CommittableCollector<CommT> committableCollector) Serializes the given object.

Methods inherited from class java.lang.Object

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

Constructor Detail

CommittableCollectorSerializer

public CommittableCollectorSerializer(SimpleVersionedSerializer<CommT> committableSerializer,
                                      int subtaskId,
                                      int numberOfSubtasks)

Method Detail

getVersion

public int getVersion()

Description copied from interface: SimpleVersionedSerializer

Gets the version with which this serializer serializes.

Specified by:

getVersion in interface SimpleVersionedSerializer<CommittableCollector<CommT>>

Specified by:

getVersion in interface Versioned

Returns:

The version of the serialization schema.

serialize

public byte[] serialize(CommittableCollector<CommT> committableCollector)
                 throws IOException

Description copied from interface: SimpleVersionedSerializer

Serializes the given object. The serialization is assumed to correspond to the current serialization version (as returned by SimpleVersionedSerializer.getVersion().

Specified by:

serialize in interface SimpleVersionedSerializer<CommittableCollector<CommT>>

Parameters:

committableCollector - The object to serialize.

Returns:

The serialized data (bytes).

Throws:

IOException - Thrown, if the serialization fails.

deserialize

public CommittableCollector<CommT> 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<CommittableCollector<CommT>>

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.