Rajesh Mahindra
Rajesh Mahindra
### Change Logs Fix the conversion of typed properties to map in scala ### Impact Affects API to deduce schema in schema evolution ### Risk level (write none, low medium...
### Change Logs Create a common method for filtering in S3 and GCS sources and add tests for filtering out extensions ### Impact Cleaner/ maintainable code and better test coverage...
### Change Logs Pass HoodieIngestionMetrics to Error Table Writer, keep support for old interface for ErrorTableWriter. ### Impact Pass HoodieIngestionMetrics to Error Table Writer to be able to emit metrics...
### Change Logs Integrate StreamContext with StreamSync to get the ability to configure the BULK_INSERT write parallelism based on workload etc. Integrate for both row writer and non-row writer flows....
### Change Logs Currently, the source partition for s3 incr source is computed within the source. This PR adds support to be able to configure the source partition from the...