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

Class MySqlSplitSerializer

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.split.MySqlSplitSerializer

All Implemented Interfaces:

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

public final class MySqlSplitSerializer
extends Object
implements org.apache.flink.core.io.SimpleVersionedSerializer<MySqlSplit>

A serializer for the MySqlSplit.

Field Summary

Fields

Modifier and Type	Field	Description
static MySqlSplitSerializer	INSTANCE

Constructor Summary

Constructors

Constructor	Description
MySqlSplitSerializer()

Method Summary

Modifier and Type	Method	Description
MySqlSplit	deserialize(int version, byte[] serialized)
MySqlSplit	deserializeSplit(int version, byte[] serialized)
int	getVersion()
static Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	readTableSchemas(int version, org.apache.flink.core.memory.DataInputDeserializer in)
byte[]	serialize(MySqlSplit split)
static void	writeTableSchemas(Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas, 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

Field Detail

INSTANCE

public static final MySqlSplitSerializer INSTANCE

Constructor Detail

MySqlSplitSerializer

public MySqlSplitSerializer()

Method Detail

getVersion

public int getVersion()

Specified by:

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

Specified by:

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

serialize

public byte[] serialize(MySqlSplit split)
                 throws IOException

Specified by:

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

Throws:

IOException

deserialize

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

Specified by:

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

Throws:

IOException

deserializeSplit

public MySqlSplit deserializeSplit(int version,
                                   byte[] serialized)
                            throws IOException

Throws:

IOException

writeTableSchemas

public static void writeTableSchemas(Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas,
                                     org.apache.flink.core.memory.DataOutputSerializer out)
                              throws IOException

Throws:

IOException

readTableSchemas

public static Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> readTableSchemas(int version,
                                                                                                                                 org.apache.flink.core.memory.DataInputDeserializer in)
                                                                                                                          throws IOException

Throws:

IOException