| Interface | Description |
|---|---|
| CatalogLoader |
Serializable loader to load an Iceberg
Catalog. |
| TableLoader |
Serializable loader to load an Iceberg
Table. |
| Class | Description |
|---|---|
| CatalogLoader.CustomCatalogLoader | |
| CatalogLoader.HadoopCatalogLoader | |
| CatalogLoader.HiveCatalogLoader | |
| FlinkCatalog |
A Flink Catalog implementation that wraps an Iceberg
Catalog. |
| FlinkCatalogFactory |
A Flink Catalog factory implementation that creates
FlinkCatalog. |
| FlinkConfigOptions | |
| FlinkDynamicTableFactory | |
| FlinkFilters | |
| FlinkSchemaUtil |
Converter between Flink types and Iceberg type.
|
| FlinkTypeVisitor<T> | |
| IcebergTableSink | |
| IcebergTableSource |
Flink Iceberg table source.
|
| RowDataWrapper | |
| TableLoader.CatalogTableLoader | |
| TableLoader.HadoopTableLoader |