Package org.apache.flink.cdc.debezium.utils

Class ResolvedSchemaUtils

java.lang.Object

org.apache.flink.cdc.debezium.utils.ResolvedSchemaUtils

@Internal
public class ResolvedSchemaUtils
extends Object

Utilities to ResolvedSchema.

Method Summary

Modifier and Type	Method	Description
static org.apache.flink.table.catalog.ResolvedSchema	getPhysicalSchema(org.apache.flink.table.catalog.ResolvedSchema resolvedSchema)	Return ResolvedSchema which consists of all physical columns.

Methods inherited from class java.lang.Object

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

Method Detail

getPhysicalSchema

public static org.apache.flink.table.catalog.ResolvedSchema getPhysicalSchema(org.apache.flink.table.catalog.ResolvedSchema resolvedSchema)

Return ResolvedSchema which consists of all physical columns.