Package org.apache.flink.cdc.connectors.base.relational.handler

Interface SchemaChangeEventHandler

All Known Implementing Classes:

Db2SchemaChangeEventHandler, OracleSchemaChangeEventHandler, PostgresSchemaChangeEventHandler, SqlServerSchemaChangeEventHandler

@Experimental
public interface SchemaChangeEventHandler

This handler helps to parse the source struct in SchemaChangeEvent and generate source info.

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	parseSource(io.debezium.schema.SchemaChangeEvent event)

Method Detail

parseSource

Map<String,Object> parseSource(io.debezium.schema.SchemaChangeEvent event)