org.apache.iceberg.flink

Class FlinkSchemaUtil

java.lang.Object

org.apache.iceberg.flink.FlinkSchemaUtil

public class FlinkSchemaUtil
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
static Schema	convert(org.apache.flink.table.api.TableSchema schema) Convert the flink table schema to apache iceberg schema.

Methods inherited from class java.lang.Object

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

Method Detail

convert

public static Schema convert(org.apache.flink.table.api.TableSchema schema)

Convert the flink table schema to apache iceberg schema.