Proto commits in numaproj/numaflow-java

These 35 commits are when the Protocol Buffers files have changed:

Commit:a517350
Author:Vaibhav Tiwari
Committer:Vaibhav Tiwari

feat: add nack_options proto + sink NACK status for per-message nack Signed-off-by: Vaibhav Tiwari <vaibhav.tiwari33@gmail.com>

Commit:35d5203
Author:Yashash Lokesh
Committer:GitHub

chore: add total partitions for source (#212) Signed-off-by: Yashash <yashashhl25@gmail.com>

The documentation is generated from this commit.

Commit:d08cc31
Author:Vaibhav Kant Tiwari
Committer:GitHub

feat: Metadata propagation in source, source transformer, mapper, sink (#210) 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:e616ba6
Author:Vaibhav Kant Tiwari
Committer:GitHub

feat: Support for on success sink (#207) Signed-off-by: vtiwari5 <vaibhav_tiwari1@intuit.com> Co-authored-by: vtiwari5 <vaibhav_tiwari1@intuit.com>

Commit:38734c0
Author:Yashash H L
Committer:GitHub

feat: nack support for udsource (#204)

Commit:641639c
Author:Yashash H L
Committer:GitHub

chore: update accumulator proto (#198) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:5030d44
Author:Yashash H L
Committer:GitHub

feat: Accumulator (#172) Signed-off-by: Yashash H L <yashashhl25@gmail.com> Signed-off-by: Keran Yang <yangkr920208@gmail.com> Co-authored-by: Keran Yang <yangkr920208@gmail.com>

Commit:c3737df
Author:Yashash H L
Committer:GitHub

feat: user defined serving store (#169) Signed-off-by: Yashash H L <yashashhl25@gmail.com> Signed-off-by: Keran Yang <yangkr920208@gmail.com> Co-authored-by: Keran Yang <yangkr920208@gmail.com> Co-authored-by: Vigith Maurice <vigith@gmail.com>

Commit:134414a
Author:Yashash H L
Committer:GitHub

chore: Batch ack requests and sink responses for better performance (#149) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:707c5bf
Author:Yashash H L
Committer:GitHub

feat: Unify MapStream and Unary Map Operations Using a Shared gRPC Protocol (#146) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:a5cdc00
Author:Yashash H L
Committer:GitHub

chore: send eot response for batchmap operations (#145) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:f5c324e
Author:Yashash H L

feat: Unify MapStream and Unary Map Operations Using a Shared gRPC Protocol Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:800a0e7
Author:Yashash H L

send eot response for batchmap operations Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:fa2f746
Author:Yashash H L
Committer:GitHub

feat: Unify Batch Map and Unary Map Operations Using a Shared gRPC Protocol (#144)

Commit:2895ffd
Author:Yashash H L
Committer:GitHub

feat: use gRPC Bidirectional Streaming for Mapper and Transformer (#143) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:f68f9f2
Author:Yashash H L
Committer:GitHub

feat: udsink bidirectional streaming (#141) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:11e70d4
Author:Yashash H L
Committer:GitHub

feat: bidirectional streaming source (#138)

Commit:7997724
Author:RohanAshar
Committer:GitHub

feat: Add Map batch (#132) Signed-off-by: rashar <rohan_ashar@intuit.com> Signed-off-by: RohanAshar <rohanashar1@gmail.com> Co-authored-by: rashar <rohan_ashar@intuit.com> Co-authored-by: Keran Yang <yangkr920208@gmail.com>

Commit:8ec468f
Author:Yashash H L
Committer:GitHub

feat: Fallback Sink (#116) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:684e113
Author:Yashash H L
Committer:GitHub

feat: support headers for message (#98) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:68ffc5a
Author:Keran Yang
Committer:GitHub

feat: implement sdk for session reduce (#94) Signed-off-by: Keran Yang <yangkr920208@gmail.com>

Commit:d4e6d35
Author:Keran Yang
Committer:GitHub

chore: apply latest reducer proto to the reducer SDK (#90) Signed-off-by: Keran Yang <yangkr920208@gmail.com>

Commit:2daf34c
Author:Yashash H L
Committer:GitHub

chore: adding partitions for user defined source (#88) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:cfbfe25
Author:Keran Yang
Committer:GitHub

fix: allow returning negative value from source pending api (#73) Signed-off-by: Keran Yang <yangkr920208@gmail.com>

Commit:c6ddb8b
Author:Yashash H L
Committer:GitHub

feat: support for user-defined source (#71) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:2d8a55c
Author:Yashash H L
Committer:GitHub

feat: support for side input (#65) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:c5eeff8
Author:Yashash H L
Committer:GitHub

chore: separate servers for each service (#63) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:b38897d
Author:xdevxy
Committer:GitHub

feat: introduce MapStreamFn for streaming map udf (#51) Signed-off-by: Hao Hao <xdevxhao@gmail.com>

Commit:53ea86c
Author:xdevxy
Committer:GitHub

feat: Add ID and numDelivered fields to Datum in udf (#33) Signed-off-by: Hao Hao <xdevxhao@gmail.com>

Commit:b1466e6
Author:Yashash H L
Committer:GitHub

feat: introducing tags for conditional forwarding (#32) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:fd9b5ce
Author:Yashash H L
Committer:GitHub

feat: support for multi keys (#30) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:bf88956
Author:Yashash H L
Committer:GitHub

feat: bidirectional streaming (#23) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:e4e9ef2
Author:Keran Yang
Committer:GitHub

feat: add source transformer SDK support (#17) Signed-off-by: Keran Yang <yangkr920208@gmail.com>

Commit:6a9e566
Author:Yashash H L
Committer:GitHub

udsink with streaming (#8) Signed-off-by: Yashash H L <yashashhl25@gmail.com>

Commit:67170fc
Author:David Seapy
Committer:David Seapy

chore: initial code Signed-off-by: David Seapy <dseapy@gmail.com>