These 28 commits are when the Protocol Buffers files have changed:
| Commit: | 5c7d07f | |
|---|---|---|
| Author: | Vaibhav Kant Tiwari | |
| Committer: | GitHub | |
feat: Update Sourcer interface for propagating totalPartitions (#343) Signed-off-by: Vaibhav Tiwari <vaibhav.tiwari33@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>
The documentation is generated from this commit.
| Commit: | 2ebe47f | |
|---|---|---|
| Author: | Vaibhav Kant Tiwari | |
| Committer: | GitHub | |
feat: Support for on_success sink in pynumaflow (#302) Signed-off-by: vtiwari5 <vaibhav_tiwari1@intuit.com> Signed-off-by: Vaibhav Tiwari <vaibhav.tiwari33@gmail.com> Co-authored-by: vtiwari5 <vaibhav_tiwari1@intuit.com>
| Commit: | c3c3f19 | |
|---|---|---|
| Author: | Sreekanth | |
| Committer: | GitHub | |
feat: metadata implementation for source, map and sink (#274) Signed-off-by: Sreekanth <prsreekanth920@gmail.com>
| Commit: | 40cbff8 | |
|---|---|---|
| Author: | Sreekanth | |
| Committer: | GitHub | |
chore: Rearrange code to support both existing and new Rust FFI based pynumaflow (#258) Signed-off-by: Sreekanth <prsreekanth920@gmail.com>
| Commit: | 5f2c89a | |
|---|---|---|
| Author: | Sreekanth | |
| Committer: | GitHub | |
feat: Nack support for Sources (#252) Signed-off-by: Sreekanth <prsreekanth920@gmail.com>
| Commit: | 4982414 | |
|---|---|---|
| Author: | shrivardhan | |
| Committer: | GitHub | |
feat: add Accumulator (#237) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com> Signed-off-by: srao12 <Shrivardhan_Rao@intuit.com> Co-authored-by: Sidhant Kohli <sidhant.kohli@gmail.com>
| Commit: | f2f7bf6 | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
feat: update batchmap and mapstream to use Map proto (#200) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>
| Commit: | 688132a | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
chore: batch ack req and sink resp (#199) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>
| Commit: | 4788627 | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
feat: bi-directional streaming map (#197) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>
| Commit: | a1d3eb5 | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
feat: streaming transformer (#196) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>
| Commit: | ec00728 | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
feat: streaming sink (#193) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>
| Commit: | ea799ef | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
chore: streaming source (#191) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>
| Commit: | 921b7c0 | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
feat: batch-map implementation (#177) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>
| Commit: | 0c2501b | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
feat: add fallback sink support (#157) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>
| Commit: | 5d99fb8 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
feat: support headers for message (#138) Signed-off-by: Yashash H L <yashash_hl@intuit.com>
| Commit: | b366e2f | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
feat: implement reduce streaming (#134) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>
| Commit: | df6afe6 | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
feat: add support for new reduce proto (#133) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>
| Commit: | 39ec103 | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
feat: class based refactor for SDK (#129) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>
| Commit: | e6e1261 | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
feat: adding partitions for user defined source (#124) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>
| Commit: | 71c2b52 | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
feat: Add User Defined Source support (#114) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com>
| Commit: | c5a4695 | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
feat: add side input grpc service (#107) Signed-off-by: Sidhant Kohli <sidhant_kohli@intuit.com> Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com> Signed-off-by: Vigith Maurice <vigith@gmail.com> Co-authored-by: Sidhant Kohli <sidhant_kohli@intuit.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>
| Commit: | 3720c95 | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
chore: Refactor SDK to split into separate servers (#105) Signed-off-by: Sidhant Kohli <sidhant_kohli@intuit.com>
| Commit: | c441ebe | |
|---|---|---|
| Author: | xdevxy | |
| Committer: | GitHub | |
feat: introduce `MapStreamFn` for streaming map udf in async sever (#93) Signed-off-by: Hao Hao <xdevxhao@gmail.com>
| Commit: | d252283 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
feat: introducing tags for conditional forwarding (#76) Signed-off-by: Yashash H L <yashash_hl@intuit.com>
| Commit: | 786b48e | |
|---|---|---|
| Author: | xdevxy | |
| Committer: | GitHub | |
feat: Add ID and numDelivered fields to Datum in udf (#77) Signed-off-by: Hao Hao <xdevxhao@gmail.com>
| Commit: | acba109 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
feat: support for multi keys (#72) Signed-off-by: Yashash H L <yashash_hl@intuit.com>
| Commit: | cd8eac2 | |
|---|---|---|
| Author: | Keran Yang | |
| Committer: | GitHub | |
feat: add mapt sdk support (#64) This change adds the mapt sdk support such that numaflow source vertex can use it to perform initial transformations on input data. Transformations include 1. filtering on source messages and 2. assigning a new event time to each of the messages, etc. Signed-off-by: Keran Yang <yangkr920208@gmail.com>
| Commit: | ea78057 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
feat: bidirectional streaming for reduce (#55) Signed-off-by: Yashash H L <yashash_hl@intuit.com>