com.ververica.cdc.connectors.mysql.source.offset

Class BinlogOffsetSerializer

java.lang.Object

com.ververica.cdc.connectors.mysql.source.offset.BinlogOffsetSerializer

@Internal
public class BinlogOffsetSerializer
extends Object

Serializer implementation for a BinlogOffset.

Field Summary

Fields

Modifier and Type	Field and Description
static BinlogOffsetSerializer	INSTANCE

Constructor Summary

Constructors

Constructor and Description
BinlogOffsetSerializer()

Method Summary

Modifier and Type	Method and 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