Anand Shah

Clone of https://github.com/akka/akka/issues/20643 Can we have timed sorting operation in akka streams? Similar to `takeWithin`, This could be `sortWithin` Possible method signatures ``` scala def sortWithin(d: FiniteDuration): Source[Out, Mat] def...

Wrangler to support Hudi/Iceberg datasets read/write

8

**Is your idea related to a problem? Please describe.** No **Describe the solution you'd like** It would be good to have support for CDC data lake formats like Apache Hudi,...

Implement GraphJet adapter for [Gramlin](https://tinkerpop.apache.org/gremlin.html) to make GraphJet work with any Graph database exploration

*Issue #, if available:* #3 *Description of changes:* By submitting this pull request, I confirm that you can use, modify, copy, and redistribute this contribution, under the terms of your...

Running barometer for the first time shows file not found exception ``` Loading configuration file : /build/cli-wizard/storage/benchmarking-config.json Configuration file not found: /build/cli-wizard/storage/benchmarking-config.json. Creating a default configuration file... Error: ENOENT: no...

Barometer cli sometime shows memory leak warning. ``` MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 keypress listeners added to [ReadStream]. Use emitter.setMaxListeners() to increase limit (Use `node --trace-warnings ...` to...