package common

Get desktop application:
View/edit binary Protocol Buffers messages

KeyValueGroup is a group of key-value pairs for a given group.

Used in: Metadata

• map<string, bytes> key_value = 1

Metadata is the metadata of the message

Used in: accumulator.v1.Payload, map.v1.MapRequest.Request, map.v1.MapResponse.Result, reduce.v1.ReduceRequest.Payload, reduce.v1.ReduceResponse.Result, sessionreduce.v1.SessionReduceRequest.Payload, sessionreduce.v1.SessionReduceResponse.Result, sideinput.v1.SideInputResponse, sink.v1.SinkRequest.Request, sink.v1.SinkResponse.Result.Message, source.v1.ReadResponse.Result, sourcetransformer.v1.SourceTransformRequest.Request, sourcetransformer.v1.SourceTransformResponse.Result

• string previous_vertex = 1

  PreviousVertex is the name of the previous vertex

• map<string, KeyValueGroup> sys_metadata = 2

  SystemMetadata is the system metadata of the message Key of the map is the group name

• map<string, KeyValueGroup> user_metadata = 3

  UserMetadata is the user metadata of the message Key of the map is the group name

NackOptions carries per-message redelivery options for a negative acknowledgement (nack).

Used in: map.v1.MapResponse.Result, sink.v1.SinkResponse.Result, source.v1.NackRequest.Request, sourcetransformer.v1.SourceTransformResponse.Result

• optional string reason = 1

  reason is a human-readable reason for nacking the message.

• optional uint32 max_deliveries = 2

  max_deliveries is the maximum number of redelivery attempts.

• optional uint64 delay = 3

  delay is the redelivery delay in milliseconds.

• map<string, string> nack_map = 4

  a generic map of values