Package org.apache.flink.cdc.debezium.history

Class FlinkJsonTableChangeSerializer

java.lang.Object

org.apache.flink.cdc.debezium.history.FlinkJsonTableChangeSerializer

All Implemented Interfaces:

io.debezium.relational.history.TableChanges.TableChangesSerializer<io.debezium.document.Array>

public class FlinkJsonTableChangeSerializer
extends Object
implements io.debezium.relational.history.TableChanges.TableChangesSerializer<io.debezium.document.Array>

The serializer responsible for converting of TableChanges into a JSON format. Copied from io.debezium.relational.history.JsonTableChangeSerializer, but add serialization/deserialization for column's enumValues

Constructor Summary

Constructors

Constructor	Description
FlinkJsonTableChangeSerializer()

Method Summary

Modifier and Type	Method	Description
io.debezium.relational.history.TableChanges	deserialize(io.debezium.document.Array array, boolean useCatalogBeforeSchema)
static io.debezium.relational.history.TableChanges.TableChange	fromDocument(io.debezium.document.Document document, boolean useCatalogBeforeSchema)
io.debezium.document.Array	serialize(io.debezium.relational.history.TableChanges tableChanges)
io.debezium.document.Document	toDocument(io.debezium.relational.history.TableChanges.TableChange tableChange)

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkJsonTableChangeSerializer

public FlinkJsonTableChangeSerializer()

Method Detail

serialize

public io.debezium.document.Array serialize(io.debezium.relational.history.TableChanges tableChanges)

Specified by:

serialize in interface io.debezium.relational.history.TableChanges.TableChangesSerializer<io.debezium.document.Array>

toDocument

public io.debezium.document.Document toDocument(io.debezium.relational.history.TableChanges.TableChange tableChange)

deserialize

public io.debezium.relational.history.TableChanges deserialize(io.debezium.document.Array array,
                                                               boolean useCatalogBeforeSchema)

Specified by:

deserialize in interface io.debezium.relational.history.TableChanges.TableChangesSerializer<io.debezium.document.Array>

fromDocument

public static io.debezium.relational.history.TableChanges.TableChange fromDocument(io.debezium.document.Document document,
                                                                                   boolean useCatalogBeforeSchema)