package reduce.v1

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc IsReady (google.protobuf.Empty, ReadyResponse)

  reduce.proto:15

  IsReady is the heartbeat endpoint for gRPC.

  message ReadyResponse

  reduce.proto:81

  * ReadyResponse is the health check result.

  • bool ready = 1

• rpc ReduceFn (stream ReduceRequest, stream ReduceResponse)

  reduce.proto:12

  ReduceFn applies a reduce function to a stream of reduce requests and sends reduce response back in a streaming fashion.

  message ReduceRequest

  reduce.proto:21

  * ReduceRequest represents a request element.

  • optional ReduceRequest.Payload payload = 1

  • optional ReduceRequest.WindowOperation operation = 2

  message ReduceResponse

  reduce.proto:59

  * ReduceResponse represents a response element.

  • optional ReduceResponse.Result result = 1

  • optional Window window = 2

    window represents a window to which the result belongs.

  • bool EOF = 3

    EOF represents the end of the response for a window. When it's set to true, the platform considers the response as an indicator which doesn't contain real data.

Payload represents a payload element.

Used in: ReduceRequest

• repeated string keys = 1

• bytes value = 2

• optional google.protobuf.Timestamp event_time = 3

• optional google.protobuf.Timestamp watermark = 4

• map<string, string> headers = 5

WindowOperation represents a window operation. For Aligned windows, OPEN, APPEND and CLOSE events are sent.

Used in: ReduceRequest

• WindowOperation.Event event = 1

• repeated Window windows = 2

Used in: WindowOperation

• OPEN = 0

• CLOSE = 1

• APPEND = 4

FIXME: put all fields(window, EOF) inside of Result. Reference: https://protobuf.dev/programming-guides/api/#dont-include-primitive-types Result represents a result element. It contains the result of the reduce function.

Used in: ReduceResponse

• repeated string keys = 1

• bytes value = 2

• repeated string tags = 3

Window represents a window. Since the client doesn't track keys, window doesn't have a keys field.

Used in: ReduceRequest.WindowOperation, ReduceResponse

• optional google.protobuf.Timestamp start = 1

• optional google.protobuf.Timestamp end = 2

• string slot = 3