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.
|
FlinkSourceFilter | |
FlinkTypeVisitor<T> | |
FlinkWriteConf |
A class for common Iceberg configs for Flink writes.
|
FlinkWriteOptions |
Flink sink write options
|
IcebergTableSink | |
RowDataWrapper | |
TableLoader.CatalogTableLoader | |
TableLoader.HadoopTableLoader |