These 36 commits are when the Protocol Buffers files have changed:
| Commit: | de51e1f | |
|---|---|---|
| Author: | Vaibhav Tiwari | |
feat: map and sink changes for per message nack wiring Signed-off-by: Vaibhav Tiwari <vaibhav.tiwari33@gmail.com>
| Commit: | 2afc401 | |
|---|---|---|
| Author: | Vaibhav Tiwari | |
feat: per message nack wiring for source and source transformer Signed-off-by: Vaibhav Tiwari <vaibhav.tiwari33@gmail.com>
| Commit: | 1abe674 | |
|---|---|---|
| Author: | Vaibhav Kant Tiwari | |
| Committer: | GitHub | |
feat: Add total partitions for source (#172) Signed-off-by: Vaibhav Tiwari <vaibhav.tiwari33@gmail.com>
The documentation is generated from this commit.
| Commit: | 000388c | |
|---|---|---|
| Author: | Adarsh Jain | |
| Committer: | GitHub | |
feat: metadata implementations for source, transformer, map and sink (#151)
| Commit: | fde3dea | |
|---|---|---|
| Author: | Vaibhav Kant Tiwari | |
| Committer: | GitHub | |
feat: Support for OnSuccess sink (#152) 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: | c1a3060 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
feat: Nack Support For Source (#136) Signed-off-by: Yashash H L <yashashhl25@gmail.com>
| Commit: | d55e91f | |
|---|---|---|
| Author: | Adarsh Jain | |
| Committer: | GitHub | |
feat: panic hook to capture stack trace (#125) Signed-off-by: adarsh0728 <gooneriitk@gmail.com>
| Commit: | 70a3798 | |
|---|---|---|
| Author: | Vigith Maurice | |
| Committer: | GitHub | |
chore: upgrade rust + latest tonic + cargo fmt (#126) Signed-off-by: Vigith Maurice <vigith@gmail.com>
| Commit: | 79a834c | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
feat: Session window and Accumulator (#118) Signed-off-by: Yashash H L <yashash_hl@intuit.com> Signed-off-by: Yashash H L <yashashhl25@gmail.com>
| Commit: | ede9bb5 | |
|---|---|---|
| Author: | Sreekanth | |
| Committer: | GitHub | |
feat: Custom Serve Store for integration with any user-defined store (#113) Signed-off-by: Sreekanth <prsreekanth920@gmail.com> Signed-off-by: Yashash H L <yashashhl25@gmail.com> Co-authored-by: Yashash H L <yashashhl25@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>
| Commit: | 0acc8d8 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | Sreekanth | |
feat: Unify Batch Map and Unary Map Operations Using a Shared gRPC Protocol (#98) Signed-off-by: Yashash H L <yashashhl25@gmail.com> Signed-off-by: Sreekanth <prsreekanth920@gmail.com>
| Commit: | 40b204b | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | Sreekanth | |
chore: Send EOT message after the responses are forwarded from Sink (#99) Signed-off-by: Yashash H L <yashashhl25@gmail.com> Signed-off-by: Sreekanth <prsreekanth920@gmail.com>
| Commit: | 0813363 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | Sreekanth | |
chore: Batch ack requests and sink responses for better performance (#100) Signed-off-by: Yashash H L <yashashhl25@gmail.com> Signed-off-by: Sreekanth <prsreekanth920@gmail.com>
| Commit: | 11598f9 | |
|---|---|---|
| Author: | Sreekanth | |
| Committer: | Sreekanth | |
chore: Use cargo workspaces (#102) Signed-off-by: Sreekanth <prsreekanth920@gmail.com>
| Commit: | d36011a | |
|---|---|---|
| Author: | Sreekanth | |
| Committer: | GitHub | |
chore: Use cargo workspaces (#102) Signed-off-by: Sreekanth <prsreekanth920@gmail.com>
| Commit: | b59dc12 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
chore: Batch ack requests and sink responses for better performance (#100) Signed-off-by: Yashash H L <yashashhl25@gmail.com>
| Commit: | 9fb3c0a | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
chore: Send EOT message after the responses are forwarded from Sink (#99) Signed-off-by: Yashash H L <yashashhl25@gmail.com>
| Commit: | 40c0550 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
feat: Unify Batch Map and Unary Map Operations Using a Shared gRPC Protocol (#98) Signed-off-by: Yashash H L <yashashhl25@gmail.com>
| Commit: | 0870af9 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
feat: Use gRPC Bidirectional Streaming for Map (#95) Signed-off-by: Yashash H L <yashashhl25@gmail.com>
| Commit: | 30d8ce1 | |
|---|---|---|
| Author: | Sreekanth | |
| Committer: | GitHub | |
feat: Bidirectional streaming for source transformer (#91) Signed-off-by: Sreekanth <prsreekanth920@gmail.com>
| Commit: | 981a0a8 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
feat: bidirectional streaming for udsink (#90) Signed-off-by: Yashash H L <yashashhl25@gmail.com> Signed-off-by: Vigith Maurice <vigith@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>
| Commit: | 7be70f4 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
fix: add handshake for readFn and ackFn (#88) Signed-off-by: Yashash H L <yashashhl25@gmail.com> Signed-off-by: Vigith Maurice <vigith@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>
| Commit: | 8e170f4 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
feat: Bidirectional Streaming for Source (#84)
| Commit: | e640ac1 | |
|---|---|---|
| Author: | Sidhant Kohli | |
| Committer: | GitHub | |
feat: impl batch map (#66) Signed-off-by: Sidhant Kohli <sidhant.kohli@gmail.com> Signed-off-by: Vigith Maurice <vigith@gmail.com> Co-authored-by: Sidhant Kohli <sidhant.kohli@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>
| Commit: | 7dff517 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
chore: Incorporate Proto Definition Changes For Reduce (#52) Signed-off-by: Yashash H L <yashashhl25@gmail.com> Signed-off-by: Vigith Maurice <vigith@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>
| Commit: | d8533ce | |
|---|---|---|
| Author: | Shubham Dixit | |
| Committer: | GitHub | |
Added header values (#51)
| Commit: | eabe854 | |
|---|---|---|
| Author: | Yashash H L | |
| Committer: | GitHub | |
chore: Fallback and Headers Support for Custom Sink (#49) Signed-off-by: Yashash H L <yashashhl25@gmail.com> Signed-off-by: Vigith Maurice <vigith@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>
| Commit: | 141c22c | |
|---|---|---|
| Author: | Sreekanth | |
| Committer: | GitHub | |
feat: add partitions RPC for source (#24) Signed-off-by: Sreekanth <prsreekanth920@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>
| Commit: | 8ba08ca | |
|---|---|---|
| Author: | Vigith Maurice | |
| Committer: | GitHub | |
feat: side-input (#18) Signed-off-by: Vigith Maurice <vigith@gmail.com>
| Commit: | a7ec6f1 | |
|---|---|---|
| Author: | Vigith Maurice | |
| Committer: | GitHub | |
feat: user-defined source (#14) Signed-off-by: Vigith Maurice <vigith@gmail.com> Signed-off-by: Yashash H L <yashash_hl@intuit.com> Co-authored-by: Yashash H L <yashash_hl@intuit.com>
| Commit: | 5c46f51 | |
|---|---|---|
| Author: | Vigith Maurice | |
| Committer: | GitHub | |
chore: remove deprecated map/reduce proto (#13) Signed-off-by: Vigith Maurice <vigith@gmail.com>
| Commit: | dba2c81 | |
|---|---|---|
| Author: | Vigith Maurice | |
| Committer: | GitHub | |
feat: add Source transform (#11) Signed-off-by: Vigith Maurice <vigith@gmail.com> Signed-off-by: Yashash H L <yashash_hl@intuit.com> Co-authored-by: Yashash H L <yashash_hl@intuit.com>
| Commit: | 4e890e3 | |
|---|---|---|
| Author: | Vigith Maurice | |
| Committer: | GitHub | |
chore: fix reduce proto (#9) Signed-off-by: Vigith Maurice <vigith@gmail.com>
| Commit: | c49c744 | |
|---|---|---|
| Author: | Vigith Maurice | |
| Committer: | GitHub | |
chore: update map to new proto (#8) Signed-off-by: Vigith Maurice <vigith@gmail.com>
| Commit: | 2b44cdc | |
|---|---|---|
| Author: | Vigith Maurice | |
| Committer: | GitHub | |
chore: migrate to new sink proto (#6) Signed-off-by: Vigith Maurice <vigith@gmail.com>
| Commit: | 29dbfd8 | |
|---|---|---|
| Author: | Vigith Maurice | |
initial outline