Uses of Class
org.apache.paimon.flink.factories.FlinkFactoryUtil.FlinkTableFactoryHelper

Packages that use FlinkFactoryUtil.FlinkTableFactoryHelper

Package	Description
org.apache.paimon.flink.factories
org.apache.paimon.flink.log

Uses of FlinkFactoryUtil.FlinkTableFactoryHelper in org.apache.paimon.flink.factories

Methods in org.apache.paimon.flink.factories that return FlinkFactoryUtil.FlinkTableFactoryHelper

Modifier and Type	Method and Description
static FlinkFactoryUtil.FlinkTableFactoryHelper	FlinkFactoryUtil.createFlinkTableFactoryHelper(LogStoreTableFactory factory, org.apache.flink.table.factories.DynamicTableFactory.Context context) Creates a utility that helps in discovering formats, merging options with DynamicTableFactory.Context#getEnrichmentOptions() and validating them all for a LogStoreTableFactory.

Uses of FlinkFactoryUtil.FlinkTableFactoryHelper in org.apache.paimon.flink.log

Methods in org.apache.paimon.flink.log with parameters of type FlinkFactoryUtil.FlinkTableFactoryHelper

Modifier and Type	Method and Description
static org.apache.flink.table.connector.format.DecodingFormat<org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData>>	LogStoreTableFactory.getKeyDecodingFormat(FlinkFactoryUtil.FlinkTableFactoryHelper helper)
static org.apache.flink.table.connector.format.EncodingFormat<org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>>	LogStoreTableFactory.getKeyEncodingFormat(FlinkFactoryUtil.FlinkTableFactoryHelper helper)
static org.apache.flink.table.connector.format.DecodingFormat<org.apache.flink.api.common.serialization.DeserializationSchema<org.apache.flink.table.data.RowData>>	LogStoreTableFactory.getValueDecodingFormat(FlinkFactoryUtil.FlinkTableFactoryHelper helper)
static org.apache.flink.table.connector.format.EncodingFormat<org.apache.flink.api.common.serialization.SerializationSchema<org.apache.flink.table.data.RowData>>	LogStoreTableFactory.getValueEncodingFormat(FlinkFactoryUtil.FlinkTableFactoryHelper helper)