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 When constructing Flink Iceberg source via Java API, configs can be set inConfiguration
passed to source builder.FlinkDynamicTableFactory FlinkFilters FlinkSchemaUtil Converter between Flink types and Iceberg type.FlinkTypeVisitor<T> FlinkWriteConf A class for common Iceberg configs for Flink writes.FlinkWriteOptions Flink sink write optionsIcebergTableSink IcebergTableSource Flink Iceberg table source.RowDataWrapper TableLoader.CatalogTableLoader TableLoader.HadoopTableLoader