Code

feat: implement reduce stream sdk#91

Code

Merged

KeranYang merged 11 commits intonumaproj:mainnumaproj/numaflow-java:mainfrom KeranYang:reduce-streamKeranYang/numaflow-java:reduce-streamCopy head branch name to clipboardJan 23, 2024

+1,937-12

Commits

Commits on Jan 15, 2024

• copy reducer

  Show description for 593418a
  KeranYang

  committed
  593418a

  Copy full SHA for 593418a

• an initial try

  Show description for 3164f91
  KeranYang

  committed
  3164f91

  Copy full SHA for 3164f91

• add server unit tests

  Show description for 13a33b6
  KeranYang

  committed
  13a33b6

  Copy full SHA for 13a33b6

• add an example

  Show description for 2174c73
  KeranYang

  committed
  2174c73

  Copy full SHA for 2174c73

Commits on Jan 17, 2024

• add handleEndOfStream method

  Show description for c2937a9
  KeranYang

  committed
  c2937a9

  Copy full SHA for c2937a9

Commits on Jan 18, 2024

• make it thread-safe

  Show description for 461610a
  KeranYang

  committed
  461610a

  Copy full SHA for 461610a

Commits on Jan 19, 2024

• a bit of clean up

  Show description for 49d2527
  KeranYang

  committed
  49d2527

  Copy full SHA for 49d2527

Commits on Jan 22, 2024

• remove unnecessary synchronized keyword

  Show description for 4a6bc98
  KeranYang

  committed
  4a6bc98

  Copy full SHA for 4a6bc98

• not expose output observer to the supervisor

  Show description for c67de10
  KeranYang

  committed
  c67de10

  Copy full SHA for c67de10

• rename

  Show description for cd07811
  KeranYang

  committed
  cd07811

  Copy full SHA for cd07811

Commits on Jan 23, 2024

• address comments

  Show description for 60c45fc
  KeranYang

  committed
  60c45fc

  Copy full SHA for 60c45fc