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 CatalogLoader.RESTCatalogLoader 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 FlinkReadConf FlinkReadOptions Flink source read optionsFlinkSchemaUtil Converter between Flink types and Iceberg type.FlinkSourceFilter FlinkTypeVisitor<T> FlinkWriteConf A class for common Iceberg configs for Flink writes.FlinkWriteOptions Flink sink write optionsIcebergTableSink RowDataWrapper TableLoader.CatalogTableLoader TableLoader.HadoopTableLoader