com.ververica.cdc.connectors.mysql.source.split

Class MySqlSplitSerializer

java.lang.Object

com.ververica.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 and Description
static MySqlSplitSerializer	INSTANCE

Constructor Summary

Constructors

Constructor and Description
MySqlSplitSerializer()

Method Summary

Modifier and Type	Method and Description
MySqlSplit	deserialize(int version, byte[] serialized)
MySqlSplit	deserializeSplit(int version, byte[] serialized)
int	getVersion()
byte[]	serialize(MySqlSplit split)

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