v0.2.0

What's Changed

• feat: UDFs and UDSink by @vigith in #1
• chore: reduce example by @vigith in #2
• chore: add example sink by @vigith in #3
• chore: one more map example by @vigith in #4
• chore: contributing guide by @vigith in #5
• chore: migrate to new sink proto by @vigith in #6
• chore: update map to new proto by @vigith in #8
• chore: fix reduce proto by @vigith in #9
• chore: remove function.proto by @vigith in #10
• feat: add Source transform by @vigith in #11
• chore: remove deprecated map/reduce proto by @vigith in #13
• feat: user-defined source by @vigith in #14
• chore: example for user-defined source by @yhl25 in #15
• chore: update examples by @yhl25 in #16
• doc: add user defined source. by @vigith in #17
• feat: side-input by @vigith in #18
• chore: CI with unit tests by @shubhamdixit863 in #21
• chore: sideInput example by @shubhamdixit863 in #22
• feat: add partitions RPC for source by @BulkBeing in #24
• chore: update .gitignore by @vigith in #25
• Remove Datum trait in mapper by @BulkBeing in #28
• feat: improve sink SDK experience by @vigith in #29
• feat: simplified sourcer server API changes by @BulkBeing in #32
• chore: rename pb module name by @vigith in #33
• feat: make sourcetransfomer API simpler by @vigith in #34
• Use UDF specific names for server info file by @BulkBeing in #35
• chore: export proto definitions by @vigith in #37
• chore: simplified reducer and side input api by @yhl25 in #39
• chore: Introducing Factory to Create Reducer by @yhl25 in #40
• chore: Fallback and Headers Support for Custom Sink by @yhl25 in #49
• fix: setting incorrect enum for sink responses by @yhl25 in #50
• feat: Message To Drop Semantics by @shubhamdixit863 in #47
• Added header values by @shubhamdixit863 in #51
• Fixed the utc_from_timestamp method ,added test cases by @shubhamdixit863 in #60
• Event filter test by @shubhamdixit863 in #58
• chore: Incorporate Proto Definition Changes For Reduce by @yhl25 in #52
• chore: add formatting to CI by @vigith in #63
• feat: automate docker build and push + fix broken examples by @ayildirim21 in #62
• feat: upgrade to tonic 0.12 and internally to hyper 1.x by @vigith in #65
• chore: handle panics inside user handlers by @yhl25 in #67
• feat: impl batch map by @kohlisid in #66
• chore: add flatmap example by @kohlisid in #68
• chore: fix simple source by @yhl25 in #69
• chore: add min-numa version to server info by @kohlisid in #70
• chore: update Serverinfo to use struct by @kohlisid in #71
• chore: buffer channels for better performance by @yhl25 in #72
• chore: update to rust 1.80 by @vigith in #74
• chore: update example version by @kohlisid in #75
• chore: publish to crates.io by @vigith in #81
• chore: update dependencies by @vigith in #82
• chore: retrieve sdk version from env by @KeranYang in #83
• feat: Bidirectional Streaming for Source by @yhl25 in #84
• chore: update ubuntu by @vigith in #86
• docs: minor updates on docs and examples by @KeranYang in #87
• fix: add handshake for readFn and ackFn by @yhl25 in #88
• docs: add instructions on minimum numaflow version update by @KeranYang in #89
• feat: bidirectional streaming for udsink by @yhl25 in #90
• fix: invariant on global stream ending is upheld by @vigith in #92
• feat: Bidirectional streaming for source transformer by @BulkBeing in #91
• feat: container-type level version compatibility check by @KeranYang in #94
• feat: Use gRPC Bidirectional Streaming for Map by @yhl25 in #95
• chore: Release pipeline by @BulkBeing in #97
• feat: Unify Batch Map and Unary Map Operations Using a Shared gRPC Protocol by @yhl25 in #98
• chore: Send EOT message after the responses are forwarded from Sink by @yhl25 in #99
• chore: Batch ack requests and sink responses for better performance by @yhl25 in #100
• chore: update release version by @kohlisid in #101

New Contributors

• @vigith made their first contribution in #1
• @yhl25 made their first contribution in #15
• @shubhamdixit863 made their first contribution in #21
• @ayildirim21 made their first contribution in #62
• @kohlisid made their first contribution in #66
• @KeranYang made their first contribution in #83

Full Changelog: https://github.com/numaproj/numaflow-rs/commits/v0.2.0