Package org.apache.flink.cdc.connectors.mysql.source.offset

Class BinlogOffsetSerializer

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.offset.BinlogOffsetSerializer

@Internal
public class BinlogOffsetSerializer
extends Object

Serializer implementation for a BinlogOffset.

Field Summary

Fields

Modifier and Type	Field	Description
static BinlogOffsetSerializer	INSTANCE

Constructor Summary

Constructors

Constructor	Description
BinlogOffsetSerializer()

Method Summary

Modifier and Type	Method	Description
BinlogOffset	deserialize(byte[] bytes)
byte[]	serialize(BinlogOffset binlogOffset)

Methods inherited from class java.lang.Object

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

Field Detail

INSTANCE

public static final BinlogOffsetSerializer INSTANCE

Constructor Detail

BinlogOffsetSerializer

public BinlogOffsetSerializer()

Method Detail

serialize

public byte[] serialize(BinlogOffset binlogOffset)
                 throws IOException

Throws:

IOException

deserialize

public BinlogOffset deserialize(byte[] bytes)
                         throws IOException

Throws:

IOException