Package org.apache.iceberg.flink.sink

Class DeltaManifestsSerializer

java.lang.Object

org.apache.iceberg.flink.sink.DeltaManifestsSerializer

All Implemented Interfaces:

org.apache.flink.core.io.SimpleVersionedSerializer<DeltaManifests>, org.apache.flink.core.io.Versioned

@Internal
public class DeltaManifestsSerializer
extends Object
implements org.apache.flink.core.io.SimpleVersionedSerializer<DeltaManifests>

Field Summary

Fields

Modifier and Type	Field	Description
static final DeltaManifestsSerializer	INSTANCE

Constructor Summary

Constructors

Constructor	Description
DeltaManifestsSerializer()

Method Summary

Modifier and Type	Method	Description
DeltaManifests	deserialize(int version, byte[] serialized)
int	getVersion()
byte[]	serialize(DeltaManifests deltaManifests)

Methods inherited from class java.lang.Object

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

Field Details

INSTANCE

public static final DeltaManifestsSerializer INSTANCE

Constructor Details

DeltaManifestsSerializer

public DeltaManifestsSerializer()

Method Details

getVersion

public int getVersion()

Specified by:

getVersion in interface org.apache.flink.core.io.SimpleVersionedSerializer<DeltaManifests>

Specified by:

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

serialize

public byte[] serialize(DeltaManifests deltaManifests)
                 throws IOException

Specified by:

serialize in interface org.apache.flink.core.io.SimpleVersionedSerializer<DeltaManifests>

Throws:

IOException

deserialize

public DeltaManifests deserialize(int version,
 byte[] serialized)
                           throws IOException

Specified by:

deserialize in interface org.apache.flink.core.io.SimpleVersionedSerializer<DeltaManifests>

Throws:

IOException