package sourcetransformer.v1
Get desktop application:
View/edit binary Protocol Buffers messages
rpc IsReady (, )
sourcetransformer.proto:18IsReady is the heartbeat endpoint for gRPC.
message
sourcetransformer.proto:68* ReadyResponse is the health check result.
bool ready = 1
rpc SourceTransformFn (stream , stream )
sourcetransformer.proto:15SourceTransformFn 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
sourcetransformer.proto:32* SourceTransformerRequest represents a request element.
optional request = 1
optional handshake = 2
message
sourcetransformer.proto:50* SourceTransformerResponse represents a response element.
repeated results = 1
string id = 2
This ID is used to refer the responses to the request it corresponds to.
optional handshake = 3
Handshake message between client and server to indicate the start of transmission.
message
sourcetransformer.proto:24Handshake message between client and server to indicate the start of transmission.
Used in: ,
bool sot = 1
Required field indicating the start of transmission.
message
sourcetransformer.proto:33Used in:
repeated string keys = 1
bytes value = 2
optional event_time = 3
optional watermark = 4
map<string, string> headers = 5
string id = 6
This ID is used to uniquely identify a transform request
optional metadata = 7
message
sourcetransformer.proto:51Used in:
repeated string keys = 1
bytes value = 2
optional event_time = 3
repeated string tags = 4
optional metadata = 5