| 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.