Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

feat: Session Window and Reduce Streaming #87

Merged
merged 30 commits into from
Dec 19, 2023
Merged

feat: Session Window and Reduce Streaming #87

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
30 commits
Select commit Hold shift + click to select a range
1049027
session window
yhl25 Nov 7, 2023
7325fc2
refactor existing reducer
yhl25 Nov 7, 2023
05e425d
support for global reduce
yhl25 Nov 7, 2023
e46031d
fix lock
yhl25 Nov 13, 2023
56ee7ba
fix global reduce
yhl25 Nov 13, 2023
52c946f
minor changes
yhl25 Nov 17, 2023
35c5ff7
update partition
yhl25 Nov 17, 2023
bf364c5
working version
yhl25 Nov 21, 2023
52ae842
minor cleanup
yhl25 Nov 21, 2023
fe61737
reduce streaming
yhl25 Nov 23, 2023
e4e32df
support partial response
yhl25 Nov 23, 2023
b5e4c92
fix naming
yhl25 Nov 27, 2023
d928823
tests for session reduce
yhl25 Nov 27, 2023
dd80049
avoid sending eof for merged windows
yhl25 Nov 30, 2023
f833d63
updating images
yhl25 Dec 6, 2023
2dafecd
avoid breaking change, by introducing reduceStreamer
yhl25 Dec 6, 2023
f9530b2
updating examples
yhl25 Dec 6, 2023
006e9bc
Merge branch 'main' of github.com:numaproj/numaflow-go into unaligned…
yhl25 Dec 7, 2023
191cf47
chore: rename
vigith Dec 8, 2023
e5b9f4d
remove global reduce
yhl25 Dec 8, 2023
2c9517d
clean up
yhl25 Dec 8, 2023
a8f7865
fix tests
yhl25 Dec 8, 2023
d7512d8
chore: code review
vigith Dec 8, 2023
1231c4c
remove lock
yhl25 Dec 11, 2023
b5b6953
add go mod
yhl25 Dec 12, 2023
dbd9016
Merge branch 'main' of github.com:numaproj/numaflow-go into unaligned…
yhl25 Dec 13, 2023
6e5d083
Merge branch 'main' of github.com:numaproj/numaflow-go into unaligned…
yhl25 Dec 19, 2023
e76b04f
resolving conflicts
yhl25 Dec 19, 2023
d096c41
fix interface
yhl25 Dec 19, 2023
7ba4dd4
update examples
yhl25 Dec 19, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -5,6 +5,7 @@ go 1.20
require (
github.com/golang/mock v1.6.0
github.com/stretchr/testify v1.8.1
go.uber.org/atomic v1.11.0
golang.org/x/net v0.9.0
golang.org/x/sync v0.1.0
google.golang.org/grpc v1.57.0
Expand Down
2 changes: 2 additions & 0 deletions go.sum
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,8 @@ github.com/stretchr/testify v1.8.0/go.mod h1:yNjHg4UonilssWZ8iaSj1OCr/vHnekPRkoO
github.com/stretchr/testify v1.8.1 h1:w7B6lhMri9wdJUVmEZPGGhZzrYTPvgJArz7wNPgYKsk=
github.com/stretchr/testify v1.8.1/go.mod h1:w2LPCIKwWwSfY2zedu0+kehJoqGctiVI29o6fzry7u4=
github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k=
go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE=
go.uber.org/atomic v1.11.0/go.mod h1:LUxbIzbOniOlMKjJjyPfpl4v+PKK2cNJn91OQbhoJI0=
golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=
golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=
golang.org/x/mod v0.4.2/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=
Expand Down
Loading
Loading