Hacktoberfest 2026: le issue che i maintainer hanno segnato per ottobre, aperte e adatte ai principianti. Sfoglia le issue Hacktoberfest

[Feature][PPL] Apply Calcite post-processing to pushed aggregation snapshots

Aperta
  • Qualcosa non va?
#5,800 0 commenti 0 reazioni 0 assegnatari Vedi su GitHub

I maintainer di solito rispondono entro 1 giorno

Nessuno ha ancora preso questa issue.

Valutazione

Difficoltà
5/5
Tempo stimato
Più di una settimana
Idoneità per principianti
30/100
Tipo di issue
Funzionalità
Chiarezza
Abbastanza chiara
Stato di attività
Attiva
Stack tecnologico
java
Ambito
backend, databases, stream-processing

Direzione di ricerca

The issue involves modifying the query engine's physical plan processing for pushed aggregations with Calcite operators. Start by examining the optimized physical plan detection logic and the StateStoreScan integration. Look for existing tests related to pushed aggregation and StateStore to understand the codebase. The goal is to compile a residual Calcite plan for reuse without restarting the primary query.

Scritto dal modello di indicizzazione a partire dal testo della issue.

Descrizione

aggregation async calcite enhancement PPL

Parent: #5765

Goal

Return current results when an eligible pushed aggregation has Calcite operators above the aggregation leaf.

Scope

  • Detect the eligible pushed aggregation leaf from the optimized physical plan.
  • Store aggregation-boundary rows with REPLACE semantics.
  • Replace the aggregation leaf with a StateStoreScan for current-result evaluation.
  • Compile the residual Calcite plan once and reuse it for subsequent POST timeout and GET reads.
  • Do not reparse, reoptimize, or restart the primary query during polling.

Acceptance criteria

  • Queries such as pushed stats followed by partial-safe eval or fields can return meaningful current results.
  • Every read evaluates the cached residual plan against one coherent StateStore view.
  • The primary query still executes once and remains the authoritative final path.
  • Final output exactly matches synchronous Calcite PPL output.
  • Ambiguous or unsupported physical shapes fail classification safely and do not publish semantically invalid rows.
  • Concurrent StateStore replacement, preview evaluation, cancellation, and close are covered by tests.
Lingua principale
Java
Stelle
175
Fork
233
Merge medio
2g 16h
PR unite (30g)
39

Preparare l'ambiente

Come iniziare

  1. Leggi tutta la issue e poi la guida ai contributi del progetto.
  2. Commenta sulla issue per dire che te ne occupi tu — evita che due persone facciano lo stesso lavoro.
  3. Fai un fork del repository e lavora su un branch.
  4. Apri una pull request che faccia riferimento al numero della issue.

Altre issue di opensearch-project/sql

Tutte le issue di opensearch-project/sql

Issue simili

Altre issue su Java

Ricevi le nuove issue nella tua casella

Un breve riepilogo di issue GitHub adatte ai principianti.