Package | Description |
---|---|
org.apache.paimon.flink | |
org.apache.paimon.flink.action | |
org.apache.paimon.flink.source |
Class and Description |
---|
AbstractFlinkTableFactory
Abstract paimon factory to create table source and table sink.
|
DataTypeToLogicalType
Convert
DataType to LogicalType . |
FlinkCatalog
Catalog for paimon.
|
FlinkConnectorOptions.LookupCacheMode
The mode of lookup cache.
|
FlinkConnectorOptions.SplitAssignMode
Split assign mode for
StaticFileStoreSplitEnumerator . |
FlinkConnectorOptions.WatermarkEmitStrategy
Watermark emit strategy for scan.
|
FlinkGenericCatalog
A Flink catalog that can also load non-Paimon tables.
|
FlinkRowData
Convert to Flink row data.
|
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. |
Class and Description |
---|
FlinkCatalog
Catalog for paimon.
|
Class and Description |
---|
FlinkConnectorOptions.SplitAssignMode
Split assign mode for
StaticFileStoreSplitEnumerator . |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.