Package org.apache.paimon.flink.utils

Class Summary

Class	Description
FlinkCalciteClasses	Class for load calcite dependency via reflection.
FlinkCalciteClasses.ConfigDelegate	Accessing org.apache.calcite.sql.parser.SqlParser$Config by Reflection.
FlinkCalciteClasses.LexDelegate	Accessing org.apache.calcite.config.Lex by Reflection.
FlinkCalciteClasses.SqlBasicCallDelegate	Accessing org.apache.calcite.sql.SqlBasicCall by Reflection.
FlinkCalciteClasses.SqlIdentifierDelegate	Accessing org.apache.calcite.sql.SqlIdentifier by Reflection.
FlinkCalciteClasses.SqlKindDelegate	Accessing org.apache.calcite.sql.SqlKind by Reflection.
FlinkCalciteClasses.SqlLiteralDelegate	Accessing org.apache.calcite.sql.SqlLiteral by Reflection.
FlinkCalciteClasses.SqlNodeListDelegate	Accessing org.apache.calcite.sql.SqlNodeList by Reflection.
FlinkCalciteClasses.SqlOperatorDelegate	Accessing org.apache.calcite.sql.SqlOperator by Reflection.
FlinkCalciteClasses.SqlParserDelegate	Accessing org.apache.calcite.sql.parser.SqlParser by Reflection.
FlinkCatalogPropertiesUtil	Utilities for ser/deserializing non-physical columns and watermark into/from a map of string properties.
InternalRowTypeSerializer	A TypeSerializer for InternalRow.
InternalTypeInfo<T>	A TypeInformation for internal serializer.
InternalTypeSerializer<T>	A simple version TypeSerializer.
JavaSerializer<T extends Serializable>	A type serializer that serializes its type using the Java serialization.
JavaSerializer.JavaSerializerSnapshot<T extends Serializable>	JavaSerializer snapshot class.
JavaTypeInfo<T extends Serializable>	A TypeInformation which uses java serialization.
ManagedMemoryUtils	Utils for using Flink managed memory.
MultiTablesCompactorUtil	Utility methods for dedicated compaction job for multi-tables.
SingleOutputStreamOperatorUtils	Utility methods for SingleOutputStreamOperator.
TableMigrationUtils	Migration util to choose importer according to connector.
TableScanUtils	Utility methods for TableScan, such as validating.