package turbo.proto
Get desktop application:
View/edit binary Protocol Buffers messages
The service definitions for query scheduling in pixels-turbo.
rpc ScheduleQuery (, )
turbo.proto:33message
turbo.proto:41uint64 transId = 1
bool forceMpp = 2
message
turbo.proto:46int32 errorCode = 1
string executorType = 2
rpc FinishQuery (, )
turbo.proto:34message
turbo.proto:51uint64 transId = 1
string executorType = 2
message
turbo.proto:56int32 errorCode = 1
rpc GetQuerySlots (, )
turbo.proto:35message
turbo.proto:60(message has no fields)
message
turbo.proto:63int32 errorCode = 1
uint32 mppSlots = 2
uint32 cfSlots = 3
rpc GetQueryConcurrency (, )
turbo.proto:36message
turbo.proto:69(message has no fields)
message
turbo.proto:72int32 errorCode = 1
uint32 mppConcurrency = 2
uint32 cfConcurrency = 3
service ScalingService
turbo.proto:191rpc CollectMetrics (stream , stream )
turbo.proto:192message
turbo.proto:196uint32 queryConcurrency = 1
message
turbo.proto:200(message has no fields)
rpc CheckMetrics (, )
turbo.proto:193message
turbo.proto:203(message has no fields)
message
turbo.proto:206string alarm_message = 1
The service definitions for worker coordination, all requests are sent from worker to coordinator.
rpc RegisterWorker (, )
turbo.proto:81also create a lease for the worker
message
turbo.proto:103optional workerInfo = 1
message
turbo.proto:107int32 errorCode = 1
int64 workerId = 2
the unique id assigned by the coordinator for this worker
int64 leaseStartTimeMs = 3
the time since the epoch in milliseconds of the lease
int64 leasePeriodMs = 4
the valid period in milliseconds of the lease
rpc GetDownstreamWorkers (, )
turbo.proto:83get the downstream workers the execution outputs should be sent to
message
turbo.proto:114int64 workerId = 1
message
turbo.proto:118int32 errorCode = 1
repeated downstreamWorkers = 2
rpc GetTasksToExecute (, )
turbo.proto:85get a batch of tasks for the worker to execute
message
turbo.proto:123int64 workerId = 1
message
turbo.proto:137int32 errorCode = 1
repeated taskInputs = 2
rpc CompleteTasks (, )
turbo.proto:87tell the coordinator that the tasks are completed
message
turbo.proto:142int64 workerId = 1
repeated taskResults = 2
message
turbo.proto:147int32 errorCode = 1
rpc ExtendLease (, )
turbo.proto:89report heartbeat and extend the lease for a worker
message
turbo.proto:151int64 workerId = 1
message
turbo.proto:155int32 errorCode = 1
int64 leaseStartTimeMs = 2
the new start time in milliseconds since the epoch
rpc TerminateWorker (, )
turbo.proto:91tell the coordinator that the worker is about to terminate and release the lease
message
turbo.proto:160int64 workerId = 1
message
turbo.proto:164int32 errorCode = 1
the service definitions for the serverless workers in vHive
rpc Process (, )
turbo.proto:170message
turbo.proto:175begin request/response definition for vHive worker services
string workerType = 1
string json = 2
message
turbo.proto:180string json = 1
rpc GetMemory (, )
turbo.proto:171message
turbo.proto:184(message has no fields)
message
turbo.proto:187uint64 memoryMB = 1
message
turbo.proto:127Used in:
int32 taskId = 1
string payload = 2
message
turbo.proto:132Used in:
int32 taskId = 1
bool success = 2
message
turbo.proto:94Used in: ,
string ip = 1
the ip address of the worker
int32 port = 2
the tcp port that the worker receives data streams from
int64 transId = 3
the id of the transaction (query)
int32 stageId = 4
the id of the stage in the operator this worker is working for
string operatorName = 5
the name of the operator this stage belongs to
repeated int32 hashValues = 6
in a hash-partitioned shuffle, the hash values to be processed by this worker