package reduce.v1

Get desktop application:
View/edit binary Protocol Buffers messages

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

  reduce.proto:17

  IsReady is the heartbeat endpoint for gRPC.

  message ReadyResponse

  reduce.proto:85

  * ReadyResponse is the health check result.

  • bool ready = 1

• rpc ReduceFn (stream ReduceRequest, stream ReduceResponse)

  reduce.proto:14

  ReduceFn applies a reduce function to a request stream.

  message ReduceRequest

  reduce.proto:23

  * ReduceRequest represents a request element.

  • optional ReduceRequest.Payload payload = 1

  • optional ReduceRequest.WindowOperation operation = 2

  message ReduceResponse

  reduce.proto:63

  * 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.

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

• optional common.Metadata metadata = 6

  Metadata is the metadata of the message

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

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

• optional common.Metadata metadata = 4

  Metadata is the metadata of the message

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