Default package

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc executeQuery (QueryRequest, QueryResult)

  analytics.proto:30

  Execute query and return query result.

  message QueryRequest

  analytics.proto:38

  • string query = 1

  • bytes queryConfig = 2

  message QueryResult

  analytics.proto:53

  Query result

  • bytes queryResult = 1

    The query result.

• rpc cancelQuery (QueryCancelRequest, QueryCancelResult)

  analytics.proto:34

  Cancel query which is specified by queryId in QueryCancelRequest.

  message QueryCancelRequest

  analytics.proto:47

  • optional QueryId queryId = 1

    The query which will be cancelled.

  message QueryCancelResult

  analytics.proto:59

  Query cancel result

  • bytes cancelResult = 1

    The cancel result.

• rpc process (Request, Response)

  container.proto:30

  接收master/driver发送过来的消息，异步处理

  message Request

  container.proto:39

  • bytes payload = 1

  message Response

  container.proto:43

  • bytes payload = 1

• rpc close (google.protobuf.Empty, google.protobuf.Empty)

  container.proto:34

  关闭结束container

• rpc executePipeline (PipelineReq, stream PipelineRes)

  driver.proto:30

  接受client提交过来的pipelineTasks

  message PipelineReq

  driver.proto:39

  • bytes payload = 1

  message PipelineRes

  driver.proto:43

  • bytes payload = 1

• rpc close (google.protobuf.Empty, google.protobuf.Empty)

  driver.proto:34

  关闭结束driver

• rpc registerContainer (RegisterRequest, RegisterResponse)

  master.proto:30

  提交注册container/driver

  message RegisterRequest

  master.proto:54

  • bytes payload = 1

  • bool isDriver = 2

  message RegisterResponse

  master.proto:59

  • bool success = 1

  • bytes payload = 2

• rpc receiveHeartbeat (HeartbeatRequest, HeartbeatResponse)

  master.proto:34

  处理executor/driver发送的心跳信息

  message HeartbeatResponse

  master.proto:71

  • bool success = 1

  • bool registered = 2

  • bytes payload = 3

• rpc receiveException (HeartbeatRequest, google.protobuf.Empty)

  master.proto:38

  处理executor/driver发送的异常信息

• rpc close (google.protobuf.Empty, google.protobuf.Empty)

  master.proto:42

  关闭结束master

• rpc queryMetrics (MetricQueryRequest, MetricQueryResponse)

  metrics.proto:29

  message MetricQueryRequest

  metrics.proto:33

  (message has no fields)

  message MetricQueryResponse

  metrics.proto:36

  • bytes payload = 1

• rpc requireResource (RequireResourceRequest, RequireResourceResponse)

  resource.proto:27

  message RequireResourceRequest

  resource.proto:41

  • string requireId = 1

  • int32 workersNum = 2

  • AllocateStrategy allocStrategy = 3

  message RequireResourceResponse

  resource.proto:47

  • string requireId = 1

  • bool success = 2

  • string msg = 3

  • repeated Worker worker = 4

• rpc releaseResource (ReleaseResourceRequest, ReleaseResourceResponse)

  resource.proto:30

  message ReleaseResourceRequest

  resource.proto:54

  • string releaseId = 1

  • repeated Worker worker = 2

  message ReleaseResourceResponse

  resource.proto:59

  • string releaseId = 1

  • bool success = 2

  • string msg = 3

• rpc restart (RestartRequest, google.protobuf.Empty)

  supervisor.proto:30

  启动container

  message RestartRequest

  supervisor.proto:39

  • int32 pid = 1

• rpc status (google.protobuf.Empty, StatusResponse)

  supervisor.proto:34

  check status

  message StatusResponse

  supervisor.proto:43

  • bool isAlive = 1

Used in: RequireResourceRequest

• ROUND_ROBIN = 0

• PROCESS_FAIR = 1

Used in: FilterNode

• repeated bytes bytes = 1

• repeated int32 containerId = 1

• bytes payload = 1

Used in: PushDown

• uint64 in = 1

• uint64 out = 2

• bool is_single = 3

Used in: FilterNodes, PushDown

• FilterType filter_type = 1

• repeated FilterNode filters = 2

• oneof content

  • IntList int_content = 3

  • LongList long_content = 4

  • StringList str_content = 5

  • BytesList bytes_content = 6

Used in: PushDown

• repeated bytes keys = 1

• repeated FilterNode filter_nodes = 2

Used in: FilterNode

• EMPTY = 0

• ONLY_VERTEX = 1

• IN_EDGE = 2

• OUT_EDGE = 3

• VERTEX_TS = 4

• EDGE_TS = 5

• MULTI_EDGE_TS = 6

• VERTEX_LABEL = 7

• EDGE_LABEL = 8

• VERTEX_VALUE_DROP = 9

• EDGE_VALUE_DROP = 10

• TTL = 11

• AND = 12

• OR = 13

• VERTEX_MUST_CONTAIN = 14

• GENERATED = 15

• OTHER = 16

Used as request type in: MasterService.receiveException, MasterService.receiveHeartbeat

• int32 id = 1

• int64 timestamp = 2

• bytes payload = 3

• bytes name = 4

Used in: FilterNode

• repeated int32 int = 1

Used in: FilterNode

• repeated int64 long = 1

• oneof filter

  • FilterNode filter_node = 1

  • FilterNodes filter_nodes = 2

• optional EdgeLimit edge_limit = 3

• repeated SortType sort_type = 4

Used in: QueryCancelRequest

• string queryId = 1

• bytes request = 1

• bytes result = 1

Used in: PushDown

• SRC_ID = 0

• DIRECTION = 1

• DESC_TIME = 2

• TIME = 3

• LABEL = 4

• DST_ID = 5

Used in: FilterNode

• repeated string str = 1

• map<string, bytes> kvInfo = 1

Used in: ReleaseResourceRequest, RequireResourceResponse

• string host = 1

• int32 processId = 2

• int32 rpcPort = 3

• int32 shufflePort = 4

• int32 workerId = 5

• string containerId = 6

• int32 processIndex = 7