David Cromberge

Request: Flink connector enhancements

3

**What needs to be done?** - Upgrade Flink version The version of Flink in the pinot project pom should be updated from 1.14.6 to the latest version of Flink, 1.18.1....

I currently have a map of datapoints that I am trying to write. The schema for this field is as follows: `MapType(LongType,DoubleType,false)` Since the map is keyed on longs and...

Proposal: Extending merge rollup capabilities

1

### What needs to be done? Extend the merge-rollup framework to create additional transformations: - dimensionality reduction/erasure - varying aggregate behaviour over time #### Dimensionality reduction/erasure Eliminate a particular dimension...

Adaptive merge rollup segment sizing

1

Summary ---------- Enable size-based segment generation for tables with variable-sized data (e.g., Theta sketches) where static row counts produce inconsistent segment sizes. Finally, adds size-based segment grouping for MergeRollupTask. Implemented...