JingsongLi opened a new pull request #1182: URL: https://github.com/apache/iceberg/pull/1182
Like Spark 3, Flink also has Catalog interface, we can integrate Iceberg catalog to Flink catalog, iceberg as a Flink catalog, users can use Flink DDLs to manipulate iceberg metadata. And query iceberg tables directly. The mapping between Flink database and Iceberg namespace: - Supplying a base namespace for a given catalog, so if you have a catalog that supports a 2-level namespace, you would supply the first level in the catalog configuration and the second level would be exposed as Flink databases. - The Iceberg table manages its partitions by itself. The partition of the Iceberg table is independent of the partition of Flink. This PR depends on: - https://github.com/apache/iceberg/pull/1174 - https://github.com/apache/iceberg/issues/1176 ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
