SreeramGarlapati opened a new pull request #2611: URL: https://github.com/apache/iceberg/pull/2611
Am creating this PR as a starting point on my way to collaborate and build on Spark3 structured streaming read support for Iceberg table with @aokolnychyi & @RussellSpitzer. Truly apologize - if I am violating any policies of this repository. Please let me know & I will remove this PR. This work is an extension of Spark2 work done in PR #2272 - only that - this is for Spark3. StreamingOffset was defined in PR #2092 using `Offset` class defined in Spark2. But, Spark3 introduces another base class for Offsets. As a result I had to copy this. Hit a roadblock - while trying to model MicroBatchStream scan & seeking guidance. -- 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]
