| 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 | |
| CatalogLoader.RESTCatalogLoader | |
| FlinkCatalog |
A Flink Catalog implementation that wraps an Iceberg
Catalog. |
| FlinkCatalogFactory |
A Flink Catalog factory implementation that creates
FlinkCatalog. |
| FlinkConfigOptions |
When constructing Flink Iceberg source via Java API, configs can be set in
Configuration
passed to source builder. |
| FlinkDynamicTableFactory | |
| FlinkFilters | |
| FlinkReadConf | |
| FlinkReadOptions |
Flink source read options
|
| FlinkSchemaUtil |
Converter between Flink types and Iceberg type.
|
| FlinkTypeVisitor<T> | |
| FlinkWriteConf |
A class for common Iceberg configs for Flink writes.
|
| FlinkWriteOptions |
Flink sink write options
|
| IcebergTableSink | |
| RowDataWrapper | |
| TableLoader.CatalogTableLoader | |
| TableLoader.HadoopTableLoader |