package accumulator.v1

Get desktop application:
View/edit binary Protocol Buffers messages

AccumulatorWindow describes a special kind of SessionWindow (similar to Global Window) where output should always have monotonically increasing WM but it can be manipulated through event-time by reordering the messages. NOTE: Quite powerful, should not be abused; it can cause stalling of pipelines and leaks

• rpc AccumulateFn (stream AccumulatorRequest, stream AccumulatorResponse)

  accumulator.proto:17

  AccumulateFn applies a accumulate function to a request stream.

  message AccumulatorRequest

  accumulator.proto:36

  AccumulatorRequest represents a request element.

  • optional Payload payload = 1

  • optional AccumulatorRequest.WindowOperation operation = 2

  message AccumulatorResponse

  accumulator.proto:63

  AccumulatorResponse represents a response element.

  • optional Payload payload = 1

  • optional KeyedWindow window = 2

    window represents a window to which the result belongs.

  • repeated string tags = 3

  • bool EOF = 4

    EOF represents the end of the response for a window.

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

  accumulator.proto:20

  IsReady is the heartbeat endpoint for gRPC.

  message ReadyResponse

  accumulator.proto:74

  ReadyResponse is the health check result.

  • bool ready = 1

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

Used in: AccumulatorRequest

• WindowOperation.Event event = 1

• optional KeyedWindow keyedWindow = 2

Used in: WindowOperation

• OPEN = 0

• CLOSE = 1

• APPEND = 2

Window represents a window.

Used in: AccumulatorRequest.WindowOperation, AccumulatorResponse

• optional google.protobuf.Timestamp start = 1

• optional google.protobuf.Timestamp end = 2

• string slot = 3

• repeated string keys = 4

Payload represents a payload element.

Used in: AccumulatorRequest, AccumulatorResponse

• repeated string keys = 1

• bytes value = 2

• optional google.protobuf.Timestamp event_time = 3

• optional google.protobuf.Timestamp watermark = 4

• string id = 5

• map<string, string> headers = 6

• optional common.Metadata metadata = 7

  Metadata is the metadata of the message