Package org.apache.flink.cdc.debezium.internal

Class DebeziumOffsetSerializer

java.lang.Object

org.apache.flink.cdc.debezium.internal.DebeziumOffsetSerializer

@Internal
public class DebeziumOffsetSerializer
extends Object

Serializer implementation for a DebeziumOffset.

Field Summary

Fields

Modifier and Type	Field	Description
static DebeziumOffsetSerializer	INSTANCE

Constructor Summary

Constructors

Constructor	Description
DebeziumOffsetSerializer()

Method Summary

Modifier and Type	Method	Description
DebeziumOffset	deserialize(byte[] bytes)
byte[]	serialize(DebeziumOffset debeziumOffset)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final DebeziumOffsetSerializer INSTANCE

Constructor Detail

DebeziumOffsetSerializer

public DebeziumOffsetSerializer()

Method Detail

serialize

public byte[] serialize(DebeziumOffset debeziumOffset)
                 throws IOException

Throws:

IOException

deserialize

public DebeziumOffset deserialize(byte[] bytes)
                           throws IOException

Throws:

IOException