v0.7.0

What's Changed

• chore: apply latest reducer proto to the reducer SDK by @KeranYang in #90
• feat: implement reduce stream sdk by @KeranYang in #91
• chore: write server info for sideinput sdk by @ayildirim21 in #93
• chore: add separate server info file paths for services by @ayildirim21 in #95
• feat: implement sdk for session reduce by @KeranYang in #94
• feat: support headers for message by @yhl25 in #98
• feat: implement update script and build/push workflow by @ayildirim21 in #99
• fix: compile pom.xml before building by @ayildirim21 in #100
• chore: refactor developer guide by @ayildirim21 in #101
• chore: send one EOF response only for reduce stream by @KeranYang in #102
• chore: release version 0.7.0 by @yhl25 in #103

New Contributors

• @ayildirim21 made their first contribution in #93

Full Changelog: v0.6.0...v0.7.0

v0.6.0

What's Changed

• chore: add e2e image build to example pom file by @KeranYang in #84
• fix: counter example by @yhl25 in #85
• fix: require event time when dropping messages by @KeranYang in #86
• chore: adding partitions for user defined source by @yhl25 in #88
• chore: release version 0.6.0 by @KeranYang in #89

⚠️ Breaking Changes

The sourcer and source transformer interfaces have been updated. Please refer to the examples and update your sourcers and source transformers accordingly.

Full Changelog: v0.5.6...v0.6.0

v0.5.6

What's Changed

• chore: upgrade netty version by @KeranYang in #82

Full Changelog: v0.5.5...v0.5.6

v0.5.5

What's Changed

• fix: upgrade netty to mitigate Vulnerability issue by @KeranYang in #79
• chore: update version by @KeranYang in #80

Full Changelog: v0.5.4...v0.5.5

v0.5.4

What's Changed

• chore: unify the event time of messages to drop by @KeranYang in #76
• chore: update sdk version by @KeranYang in #78

Full Changelog: v0.5.3...v0.5.4

v0.5.3

🎉 Release Notes - Version 0.5.3

Changed

• User-defined source SDK now supports returning a negative number from pending() to indicate the source doesn't support retrieving the pending information.

Full Changelog: v0.5.2...v0.5.3

v0.5.2

🎉 Release Notes - Version 0.5.2

Changed

• simplified Sinker and MapStreamer interface

⚠️ Breaking Changes

The Sinker interface has been updated. Please refer to the examples.

Full Changelog: v0.5.1...v0.5.2

v0.5.1

🎉 Release Notes - Version 0.5.1

Changed

• updated sink interface
• Fixed a bug that was preventing the reduce pod from starting.

⚠️ Breaking Changes

The Sinker interface has been updated. Please refer to the examples and update your sinks accordingly.

Full Changelog: v0.5.0...v0.5.1

v0.5.0

What's Changed

• chore: separate servers for each service by @yhl25 in #63
• feat: support for side input by @yhl25 in #65

🚨 Breaking Change 🚨

The servers for each operation have been separated, and all types have been moved to specific packages. For example, for map operations, we will no longer use FunctionServer to start the server. Instead, we will be using the Server class inside the mapper package. The same changes have been made for other operations like reduce, source transformer, sink, and mapstream. Please update your SDKs accordingly to ensure compatibility with the latest version of Numaflow. For reference, please take a look at the examples.
Full Changelog: v0.4.8...v0.5.0

v0.4.8

What's Changed

• chore: update default gPRC msg size to 64 MB by @whynowy in #60
• fix: npe inside message list builder by @yhl25 in #61
• chore: use kqueue when epoll is not available for netty worker group by @yhl25 in #59

New Contributors

• @whynowy made their first contribution in #60

Full Changelog: v0.4.7...v0.4.8