sqlflow.proto

syntax = "proto3";

import "google/protobuf/any.proto";

package server;

service SQLFlow {
  rpc File (Request) returns (Job);
  rpc ReadRow(Job) returns (stream Row);
  rpc ReadLog(Job) returns (stream Log);
}

message Request {
  string sql = 1;
}

message Job {
  int32 id = 1;
}

message Log {
  string log = 1;
}

// A row of data. Data can be any type
message Row {
  repeated google.protobuf.Any data = 1;
}