Issues

• Implement Rust COLLECT and ARRAY_AGG state instead of the generated JVM aggregate handler

  enhancementpriority: P1
  datafusion-contrib/StreamFusion#514 · Filter by author liuyongvs opened on Oct 26, 2026

• Implement exact native floating math paths currently delegated to the JVM

  enhancementpriority: P3
  datafusion-contrib/StreamFusion#513 · Filter by author liuyongvs opened on Oct 26, 2026

• Support native LAG in time-ordered streaming OVER windows

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#512 · Filter by author liuyongvs opened on Oct 26, 2026

• Support native PERCENTILE aggregation on released Flink 2.2

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#511 · Filter by author liuyongvs opened on Oct 26, 2026

• Track native execution support for the Flink PRINT debug scalar function

  enhancementpriority: P4
  datafusion-contrib/StreamFusion#510 · Filter by author liuyongvs opened on Oct 26, 2026

• Support native PARSE_JSON and TRY_PARSE_JSON with VARIANT transport

  enhancementpriority: P3
  datafusion-contrib/StreamFusion#509 · Filter by author liuyongvs opened on Oct 26, 2026

• Extend native STRING ordering and dynamic trim beyond unproven source representations

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#508 · Filter by author liuyongvs opened on Oct 26, 2026

• Support SQL TRIM with a runtime trim operand in native Calc

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#507 · Filter by author liuyongvs opened on Oct 26, 2026

• Replace remaining Calc SQL/JSON JVM evaluator signatures with compatible native kernels

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#506 · Filter by author liuyongvs opened on Oct 26, 2026

• Replace remaining generated collection and constructor signatures with native kernels

  enhancementpriority: P1
  datafusion-contrib/StreamFusion#505 · Filter by author liuyongvs opened on Oct 26, 2026

• Extend pure-native temporal extraction and calendar arithmetic signatures

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#504 · Filter by author liuyongvs opened on Oct 26, 2026

• Extend pure-native temporal parsing, formatting, timezone conversion and casts

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#503 · Filter by author liuyongvs opened on Oct 26, 2026

• Implement native binary STARTSWITH and ENDSWITH overloads

  enhancementpriority: P3
  datafusion-contrib/StreamFusion#502 · Filter by author liuyongvs opened on Oct 26, 2026

• Implement native SPLIT_INDEX integer-delimiter overload

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#501 · Filter by author liuyongvs opened on Oct 26, 2026

• Support native SHA2 with runtime or NULL bit-length arguments

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#500 · Filter by author liuyongvs opened on Oct 26, 2026

• Extend native ENCODE/DECODE beyond runtime charset and current charset whitelist limits

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#499 · Filter by author liuyongvs opened on Oct 26, 2026

• Implement native FROM_BASE64 and remaining fixed-BINARY TO_BASE64 signatures

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#498 · Filter by author liuyongvs opened on Oct 26, 2026

• Implement a compatible native PRINTF formatting path on Flink 2.2

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#497 · Filter by author liuyongvs opened on Oct 26, 2026

• Implement a compatible pure-native PARSE_URL kernel

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#496 · Filter by author liuyongvs opened on Oct 26, 2026

• Implement compatible native SQL matching and regular-expression function paths

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#495 · Filter by author liuyongvs opened on Oct 26, 2026

• Implement Flink-compatible native Unicode casing and string classification

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#494 · Filter by author liuyongvs opened on Oct 26, 2026

• Support native BINARY/VARBINARY to STRING CAST for verified released-Flink semantics

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#493 · Filter by author liuyongvs opened on Oct 26, 2026

• Replace remaining scalar CAST/TRY_CAST JVM evaluators with compatible native kernels

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#492 · Filter by author liuyongvs opened on Oct 26, 2026

• Implement JVM-free exact numeric unary, rounding and mixed-type scalar paths

  enhancementpriority: P2
  datafusion-contrib/StreamFusion#491 · Filter by author liuyongvs opened on Oct 26, 2026

• Native Top-1 replaces Flink update pairs with DELETE/INSERT changelog events

  bugpriority: P2
  datafusion-contrib/StreamFusion#462 · Filter by author liuyongvs opened on Oct 23, 2026