package sourcetransformer.v1

Get desktop application:
View/edit binary Protocol Buffers messages

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

  sourcetransform.proto:16

  IsReady is the heartbeat endpoint for gRPC.

  message ReadyResponse

  sourcetransform.proto:69

  * ReadyResponse is the health check result.

  • bool ready = 1

• rpc SourceTransformFn (stream SourceTransformRequest, stream SourceTransformResponse)

  sourcetransform.proto:13

  SourceTransformFn applies a function to each request element. In addition to map function, SourceTransformFn also supports assigning a new event time to response. SourceTransformFn can be used only at source vertex by source data transformer.

  message SourceTransformRequest

  sourcetransform.proto:30

  * SourceTransformerRequest represents a request element.

  • optional SourceTransformRequest.Request request = 1

  • optional Handshake handshake = 2

  message SourceTransformResponse

  sourcetransform.proto:50

  * SourceTransformerResponse represents a response element.

  • repeated SourceTransformResponse.Result results = 1

  • string id = 2

    This ID is used to refer the responses to the request it corresponds to.

  • optional Handshake handshake = 3

    Handshake message between client and server to indicate the start of transmission.

Handshake message between client and server to indicate the start of transmission.

Used in: SourceTransformRequest, SourceTransformResponse

• bool sot = 1

  Required field indicating the start of transmission.

Used in: SourceTransformRequest

• 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

• string id = 6

  This ID is used to uniquely identify a transform request

• optional metadata.Metadata metadata = 7

  Metadata is the metadata of the message

Used in: SourceTransformResponse

• repeated string keys = 1

• bytes value = 2

• optional google.protobuf.Timestamp event_time = 3

• repeated string tags = 4

• optional metadata.Metadata metadata = 5

  Metadata is the metadata of the message