stevenzwu opened a new pull request #2105: URL: https://github.com/apache/iceberg/pull/2105
Scope in the first version - simple split assigner (no ordering or locality aware) - support both batch and streaming read This is the uber PR for the reference of complete context. Will submit smaller PRs for the code review 1. [refactor Flink tests so that new source implementation can reuse](https://github.com/apache/iceberg/pull/2047) 2. [Upgrade Flink version to 1.12.1](https://github.com/apache/iceberg/pull/1956) 3. IcebergSourceSplit (TBD) 4. SplitAssigner (TBD) 5. SplitEnumerator (TBD) 6. IcebergSource where everything put together (TBD) The new `IcebergSource` will be marked as `@Experimental` as FLIP-27 source is maturing and we are making it production ready. ---------------------------------------------------------------- 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]
