Package org.apache.iceberg.flink
-
Interface Summary Interface Description CatalogLoader Serializable loader to load an IcebergCatalog
.TableLoader Serializable loader to load an IcebergTable
. -
Class Summary Class Description CatalogLoader.CustomCatalogLoader CatalogLoader.HadoopCatalogLoader CatalogLoader.HiveCatalogLoader FlinkCatalog A Flink Catalog implementation that wraps an IcebergCatalog
.FlinkCatalogFactory A Flink Catalog factory implementation that createsFlinkCatalog
.FlinkConfigOptions FlinkDynamicTableFactory FlinkFilters FlinkSchemaUtil Converter between Flink types and Iceberg type.FlinkTypeVisitor<T> IcebergTableSink IcebergTableSource Flink Iceberg table source.RowDataWrapper TableLoader.CatalogTableLoader TableLoader.HadoopTableLoader