Repository navigation

feat(workflow-operator): export the join and set operators as Python - #8506

Draft

kz930 wants to merge 35 commits into

apache:mainfrom

kz930:feat/standalone-relational-and-sampling

Draft

feat(workflow-operator): export the join and set operators as Python#8506
kz930 wants to merge 35 commits into
apache:mainfrom
kz930:feat/standalone-relational-and-sampling

Commits on Sep 11, 2026
- feat(workflow-operator): export the relational and sampling operators
  
  kz930
  and
  claude
  committed
  85997d8
Commits on Sep 18, 2026
- Merge remote-tracking branch 'upstream/main' into feat/standalone-relational-and-sampling
  kz930
  committed
  ab530db
- test(operator): run both routes of the exported If
  
  kz930
  and
  claude
  committed
  ef38771
- docs(operator): say where a sorted string column parts from the engine
  
  kz930
  and
  claude
  committed
  64600d7
- fix(operator): reject the draws Java rejects, and a reservoir of zero
  
  kz930
  and
  claude
  committed
  76b4690
- fix(operator): answer SUM, AVERAGE and CONCAT the way the engine answers them
  
  kz930
  and
  claude
  committed
  8522786
- fix(operator): rename a twice-colliding join column, and keep an integer integral
  
  kz930
  and
  claude
  committed
  f4ba91d
- docs(operator): cut today's comments back to what the code cannot say
  
  kz930
  and
  claude
  committed
  a240f01
- fix(operator): sort a null and a NaN where the engine sorts them
  
  kz930
  and
  claude
  committed
  42404db
- test(operator): keep a null and a NaN apart in the set, join and keyed paths
  
  kz930
  and
  claude
  committed
  0ac4039
- Merge branch 'main' into feat/standalone-relational-and-sampling
  kz930
  authored
  c381bec
- fix(operator): aggregate a timestamp in milliseconds, and cast only the column that declared an integer
  
  kz930
  and
  claude
  committed
  c18b1e5
Commits on Sep 19, 2026
- fix(operator): emit a join key once when both sides name it the same
  
  kz930
  and
  claude
  committed
  b8e5dbf
- fix(operator): widen an outer join's integer columns before the merge
  
  kz930
  and
  claude
  committed
  7ccb215
Commits on Sep 22, 2026
- fix(operator): sort on keys of its own so every input column survives
  
  kz930
  and
  claude
  committed
  de40276
- fix(operator): set the probe key aside before renaming the payload
  
  kz930
  and
  claude
  committed
  a5f3576
- fix(operator): add timestamps in the zone the script runs in
  
  kz930
  and
  claude
  committed
  516a066
Commits on Sep 26, 2026
- fix(operator): name a join's right columns by one rule in the schema and the rows
  
  kz930
  and
  claude
  committed
  88ff2a9
- fix(operator): put an unmatched right row's key where the engine puts it
  
  kz930
  and
  claude
  committed
  d80f561
Commits on Sep 27, 2026
- fix(operator): concatenate and sample as the engine does, say which route If takes, and pin where a null and a NaN land
  
  kz930
  and
  claude
  committed
  9281163
- refactor(workflow-operator): leave Aggregate, the sort family, the samplers and control flow to the two PRs that follow
  
  kz930
  and
  claude
  committed
  e831318
Commits on Oct 13, 2026
- fix(workflow-operator): match set-operator rows by the engine's equality
  
  kz930
  and
  claude
  committed
  77c64a3
- fix(workflow-operator): name a HashJoin probe's right columns from the declared build schema
  
  kz930
  and
  claude
  committed
  ce2b893
- Merge upstream/main into feat/standalone-relational-and-sampling
  
  kz930
  and
  claude
  committed
  72380df
Commits on Oct 14, 2026
- fix(workflow-operator): let a NaN key match nothing in Hash Join, as the engine does
  
  kz930
  and
  claude
  committed
  fa07950
- fix(operator): compare interval join timestamps by the millisecond as the engine does
  
  kz930
  and
  claude
  committed
  c59c02f
Commits on Oct 15, 2026
- fix(operator): add Interval Join's constant in the key's declared type, as the engine does
  
  kz930
  and
  claude
  committed
  f4004e8
- fix(operator): add Interval Join's time interval on the machine's wall clock, as the engine does
  
  kz930
  and
  claude
  committed
  2036f15
Commits on Oct 23, 2026
- fix(operator): add Interval Join's interval to the wall clock the script is handed
  
  kz930
  and
  claude
  committed
  b9620be
- feat(workflow-operator): keep the set and join helpers' notes out of the exported script
  
  kz930
  and
  claude
  committed
  16d13e1
- feat(workflow-operator): keep the sampling helper's notes out of the exported script
  
  kz930
  and
  claude
  committed
  d183c31
Commits on Oct 25, 2026
- feat(workflow-operator): read Interval Join's wall clocks with the shared helper
  
  kz930
  and
  claude
  committed
  6856d50
- feat(workflow-operator): match Hash Join's keys with the shared key codes
  
  kz930
  and
  claude
  committed
  770bbdc
- feat(workflow-operator): keep Interval Join's exported Python free of comments
  
  kz930
  and
  claude
  committed
  24d5d9b
Commits on Oct 26, 2026
- feat(workflow-operator): select the set operators' rows with the shared key codes
  
  kz930
  and
  claude
  committed
  9d7468d

Commits

Commits on Sep 11, 2026

Commits on Sep 18, 2026

Commits on Sep 19, 2026

Commits on Sep 22, 2026

Commits on Sep 26, 2026

Commits on Sep 27, 2026

Commits on Oct 13, 2026

Commits on Oct 14, 2026

Commits on Oct 15, 2026

Commits on Oct 23, 2026

Commits on Oct 25, 2026

Commits on Oct 26, 2026