Package org.apache.iceberg.flink
package org.apache.iceberg.flink
-
ClassDescriptionSerializable loader to load an Iceberg
Catalog.A Flink Catalog implementation that wraps an IcebergCatalog.A Flink Catalog factory implementation that createsFlinkCatalog.When constructing Flink Iceberg source via Java API, configs can be set inConfigurationpassed to source builder.Flink source read optionsConverter between Flink types and Iceberg type.A class for common Iceberg configs for Flink writes.Flink sink write optionsSerializable loader to load an IcebergTable.