Skip to content

[FLINK] feat: add StreamRecordTimestampInserterNode#52

Merged
lgbo-ustc merged 5 commits into
bigo-sg:gluten-0530from
ggjh-159:feat/stateful-stream-record-timestamp-inserter
Jul 16, 2026
Merged

[FLINK] feat: add StreamRecordTimestampInserterNode#52
lgbo-ustc merged 5 commits into
bigo-sg:gluten-0530from
ggjh-159:feat/stateful-stream-record-timestamp-inserter

Conversation

@ggjh-159

@ggjh-159 ggjh-159 commented Jul 2, 2026

Copy link
Copy Markdown

Issue: gluten#12426

Summary

Adds the Java-side PlanNode mirror for the new C++ StreamRecordTimestampInserterNode introduced in the velox PR bigo-sg/velox#64.

Test plan

  • JSON round-trip passes
  • End-to-end validation via gluten-flink nexmark q0

@KevinyhZou KevinyhZou left a comment

Copy link
Copy Markdown

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

ggjh-159 added 2 commits July 6, 2026 16:37
…stream-record-timestamp-inserter

# Conflicts:
#	src/main/cpp/CMakeLists.txt
@KevinyhZou

Copy link
Copy Markdown

@ggjh-159 please update velox ref

@ggjh-159

Copy link
Copy Markdown
Author

@lgbo-ustc cc

@lgbo-ustc
lgbo-ustc merged commit 95e9afe into bigo-sg:gluten-0530 Jul 16, 2026
1 of 3 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

3 participants