Package org.apache.paimon.flink

Class Summary

Class	Description
AbstractFlinkTableFactory	Abstract paimon factory to create table source and table sink.
DataCatalogTable	A CatalogTableImpl to wrap FileStoreTable.
DataTypeToLogicalType	Convert DataType to LogicalType.
FlinkCatalog	Catalog for paimon.
FlinkCatalogFactory	Factory for FlinkCatalog.
FlinkCatalogOptions	Options for flink catalog.
FlinkConnectorOptions	Options for flink connector.
FlinkFileIO	Flink FileIO to use FileSystem.
FlinkFileIOLoader	Flink FileIOLoader for FlinkFileIO.
FlinkGenericCatalog	A Flink catalog that can also load non-Paimon tables.
FlinkGenericCatalogFactory	Factory for FlinkGenericCatalog.
FlinkGenericTableFactory	A table factory to wrap paimon and flink factories.
FlinkRowData	Convert to Flink row data.
FlinkRowWrapper	Convert from Flink row data.
FlinkTableFactory	A paimon DynamicTableFactory to create source and sink.
FormatCatalogTable	A CatalogTable to represent format table.
LogicalTypeConversion	Conversion between LogicalType and DataType.
LogicalTypeToDataType	Convert LogicalType to DataType.
PaimonDataStreamScanProvider	Paimon DataStreamScanProvider.
PaimonDataStreamSinkProvider	Paimon DataStreamSinkProvider.
PredicateConverter	Convert Expression to Predicate.
ProcessRecordAttributesUtil	Utils for RecordAttributes.
ProjectedRowData	An implementation of RowData which provides a projected view of the underlying RowData.
Projection	Projection represents a list of (possibly nested) indexes that can be used to project data types.
SystemCatalogTable	A CatalogTable to represent system table.
VersionedSerializerWrapper<T>	Wrap a VersionedSerializer to SimpleVersionedSerializer.

Enum Summary

Enum	Description
FlinkConnectorOptions.LookupCacheMode	The mode of lookup cache.
FlinkConnectorOptions.SplitAssignMode	Split assign mode for StaticFileStoreSplitEnumerator.
FlinkConnectorOptions.WatermarkEmitStrategy	Watermark emit strategy for scan.

Exception Summary

Exception	Description
PredicateConverter.UnsupportedExpression	Encounter an unsupported expression, the caller can choose to ignore this filter branch.