JasonThon / lightflus

A Lightweight, Cloud-Native Stateful Distributed Dataflow Engine
Apache License 2.0
99 stars 9 forks source link

[LIG-10] window support #20

Closed JasonThon closed 1 year ago

JasonThon commented 1 year ago

Description

  1. support three event-time-based windows: fixed, sliding and session
  2. support event-time-based watermark trigger

Impact Scope

  1. executor initialization
  2. add window impl to group data

Test Suggestions

It will be tested in CI

Tag

N/A

codecov-commenter commented 1 year ago

Codecov Report

Merging #20 (aa0deed) into master (50dfc7b) will increase coverage by 2.75%. The diff coverage is 72.78%.

@@            Coverage Diff             @@
##           master      #20      +/-   ##
==========================================
+ Coverage   69.44%   72.19%   +2.75%     
==========================================
  Files          21       21              
  Lines        1666     1892     +226     
==========================================
+ Hits         1157     1366     +209     
- Misses        509      526      +17     
Impacted Files Coverage Δ
src/stream/src/dataflow.rs 60.33% <0.00%> (+1.90%) :arrow_up:
src/stream/src/err.rs 13.33% <ø> (ø)
src/common/src/utils.rs 73.56% <57.14%> (-1.44%) :arrow_down:
src/stream/src/actor.rs 67.72% <63.07%> (+6.46%) :arrow_up:
src/stream/src/window.rs 80.44% <80.44%> (ø)
src/common/src/collections/lang.rs 79.31% <100.00%> (ø)
src/common/src/event.rs 69.23% <100.00%> (+2.56%) :arrow_up:
src/common/src/kafka.rs 90.38% <100.00%> (+0.18%) :arrow_up:
src/stream/src/lib.rs 40.00% <100.00%> (+40.00%) :arrow_up:
src/stream/src/v8_runtime.rs 76.55% <0.00%> (+0.68%) :arrow_up:
... and 3 more

:mega: We’re building smart automated test selection to slash your CI/CD build times. Learn more