Package org.apache.flink.cdc.connectors.base.utils

Class SerializerUtils

java.lang.Object

org.apache.flink.cdc.connectors.base.utils.SerializerUtils

public class SerializerUtils
extends Object

Utils for serialization and deserialization.

Method Summary

Modifier and Type	Method	Description
static String	rowToSerializedString(Object splitBoundary)
static String	rowToSerializedString(Object[] splitBoundary)
static Object	serializedStringToObject(String serialized)
static Object[]	serializedStringToRow(String serialized)
static boolean	shouldUseCatalogBeforeSchema(io.debezium.relational.TableId tableId)	Check whether the catalog should be used before the schema.

Methods inherited from class java.lang.Object

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

Method Detail

rowToSerializedString

public static String rowToSerializedString(Object[] splitBoundary)

rowToSerializedString

public static String rowToSerializedString(Object splitBoundary)

serializedStringToRow

public static Object[] serializedStringToRow(String serialized)

serializedStringToObject

public static Object serializedStringToObject(String serialized)

shouldUseCatalogBeforeSchema

public static boolean shouldUseCatalogBeforeSchema(io.debezium.relational.TableId tableId)

Check whether the catalog should be used before the schema.

Parameters:

tableId - the table id

Returns:

false if catalog is not defined but the schema is defined; otherwise return true