support partial response

Signed-off-by: Yashash H L <[email protected]>
numaproj · Nov 23, 2023 · e4e32df · e4e32df
1 parent fe61737
commit e4e32df
Show file tree

Hide file tree

Showing 18 changed files with 227 additions and 248 deletions.
diff --git a/pkg/apis/proto/globalreduce/v1/globalreduce.pb.go b/pkg/apis/proto/globalreduce/v1/globalreduce.pb.go
diff --git a/pkg/apis/proto/globalreduce/v1/globalreduce.proto b/pkg/apis/proto/globalreduce/v1/globalreduce.proto
@@ -62,15 +62,18 @@ message GlobalReduceResponse {
     repeated string keys = 1;
     bytes value = 2;
     repeated string tags = 3;
+    // EventTime represents the event time of the result.
+    google.protobuf.Timestamp event_time = 4;
   }
 
-  repeated Result results = 1;
+  Result result = 1;
 
   // Partition represents a window partition to which the result belongs.
   Partition partition = 2;
 
-  // EventTime represents the event time of the result.
-  google.protobuf.Timestamp event_time = 4;
+  // EOF represents the end of the response for a partition.
+  bool EOF = 3;
+
 }
 
 /**

diff --git a/pkg/apis/proto/reduce/v1/reduce.pb.go b/pkg/apis/proto/reduce/v1/reduce.pb.go
diff --git a/pkg/apis/proto/reduce/v1/reduce.proto b/pkg/apis/proto/reduce/v1/reduce.proto
@@ -70,7 +70,7 @@ message ReduceResponse {
   Partition partition = 2;
 
   // EOF represents the end of the stream.
-  bool EOF = 4;
+  bool EOF = 3;
 }
 
 /**