Package org.apache.iceberg.flink.sink

Class IcebergCommittableSerializer

java.lang.Object

org.apache.iceberg.flink.sink.IcebergCommittableSerializer

All Implemented Interfaces:

org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.iceberg.flink.sink.IcebergCommittable>, org.apache.flink.core.io.Versioned

public class IcebergCommittableSerializer
extends Object
implements org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.iceberg.flink.sink.IcebergCommittable>

This serializer is used for serializing the IcebergCommittable objects between the Writer and the Aggregator operator and between the Aggregator and the Committer as well.

In both cases only the respective part is serialized.

Constructor Summary

Constructors

Constructor	Description
IcebergCommittableSerializer()

Method Summary

Modifier and Type	Method	Description
org.apache.iceberg.flink.sink.IcebergCommittable	deserialize(int version, byte[] serialized)
int	getVersion()
byte[]	serialize(org.apache.iceberg.flink.sink.IcebergCommittable committable)

Methods inherited from class java.lang.Object

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

Constructor Details

IcebergCommittableSerializer

public IcebergCommittableSerializer()

Method Details

getVersion

public int getVersion()

Specified by:

getVersion in interface org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.iceberg.flink.sink.IcebergCommittable>

Specified by:

getVersion in interface org.apache.flink.core.io.Versioned

serialize

public byte[] serialize(org.apache.iceberg.flink.sink.IcebergCommittable committable)
                 throws IOException

Specified by:

serialize in interface org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.iceberg.flink.sink.IcebergCommittable>

Throws:

IOException

deserialize

public org.apache.iceberg.flink.sink.IcebergCommittable deserialize(int version,
 byte[] serialized)
                                                             throws IOException

Specified by:

deserialize in interface org.apache.flink.core.io.SimpleVersionedSerializer<org.apache.iceberg.flink.sink.IcebergCommittable>

Throws:

IOException