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

Class SerializerUtils

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.utils.SerializerUtils

public class SerializerUtils
extends Object

Utils for serialization and deserialization.

Method Summary

Modifier and Type	Method	Description
static BinlogOffset	readBinlogPosition(int offsetVersion, org.apache.flink.core.memory.DataInputDeserializer in)
static BinlogOffset	readBinlogPosition(org.apache.flink.core.memory.DataInputDeserializer in)
static String	rowToSerializedString(Object[] splitBoundary)
static Object[]	serializedStringToRow(String serialized)
static void	writeBinlogPosition(BinlogOffset offset, org.apache.flink.core.memory.DataOutputSerializer out)

Methods inherited from class java.lang.Object

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

Method Detail

writeBinlogPosition

public static void writeBinlogPosition(BinlogOffset offset,
                                       org.apache.flink.core.memory.DataOutputSerializer out)
                                throws IOException

Throws:

IOException

readBinlogPosition

public static BinlogOffset readBinlogPosition(int offsetVersion,
                                              org.apache.flink.core.memory.DataInputDeserializer in)
                                       throws IOException

Throws:

IOException

readBinlogPosition

public static BinlogOffset readBinlogPosition(org.apache.flink.core.memory.DataInputDeserializer in)
                                       throws IOException

Throws:

IOException

rowToSerializedString

public static String rowToSerializedString(Object[] splitBoundary)

serializedStringToRow

public static Object[] serializedStringToRow(String serialized)