package app

Get desktop application:
View/edit binary Protocol Buffers messages

The MPC service definition.

• rpc Ping (PingRequest, PingReply)

  service.proto:195

  message PingRequest

  service.proto:12

  • string Msg = 1

  message PingReply

  service.proto:14

  • string Msg = 1

• rpc OpenNetwork (Empty, Empty)

  service.proto:196

• rpc CloseNetwork (Empty, Empty)

  service.proto:197

• rpc Batch (BatchRequest, BatchReply)

  service.proto:199

• rpc AsyncBatch (BatchRequest, Reply)

  service.proto:200

• rpc BatchResult (TaskInfo, BatchReply)

  service.proto:201

• rpc LastJobStatus (TaskInfo, Reply)

  service.proto:202

• rpc LoadCSV (LoadCSVRequest, Reply)

  service.proto:204

  message LoadCSVRequest

  service.proto:21

  • optional TaskInfo TaskID = 1

  • optional LoadCSVParameter Parameter = 2

• rpc ExportCSV (ExportCSVRequest, Reply)

  service.proto:205

  message ExportCSVRequest

  service.proto:26

  • optional TaskInfo TaskID = 1

  • optional ExportCSVParameter Parameter = 2

• rpc LoadData (LoadDataRequest, Reply)

  service.proto:206

  message LoadDataRequest

  service.proto:31

  • optional TaskInfo TaskID = 1

  • optional LoadDataParameter Parameter = 2

• rpc ExportData (ExportDataRequest, ExportDataReply)

  service.proto:207

  message ExportDataRequest

  service.proto:36

  • optional TaskInfo TaskID = 1

  • optional ExportDataParameter Parameter = 2

  message ExportDataReply

  service.proto:41

  • optional Reply Rep = 1

  • optional ExportedData Data = 2

• rpc ShareTable (ShareTableRequest, Reply)

  service.proto:208

  message ShareTableRequest

  service.proto:46

  • optional TaskInfo TaskID = 1

  • optional ShareTableParameter Parameter = 2

• rpc RevealTable (RevealTableRequest, Reply)

  service.proto:209

  message RevealTableRequest

  service.proto:51

  • optional TaskInfo TaskID = 1

  • optional RevealTableParameter Parameter = 2

• rpc JoinTable (JoinTableRequest, Reply)

  service.proto:210

• rpc AsyncJoinTable (JoinTableRequest, Reply)

  service.proto:211

• rpc FilterTable (FilterTableRequest, Reply)

  service.proto:212

• rpc AsyncFilterTable (FilterTableRequest, Reply)

  service.proto:213

• rpc AggregateTable (AggregateTableRequest, Reply)

  service.proto:214

• rpc AsyncAggregateTable (AggregateTableRequest, Reply)

  service.proto:215

• rpc ConcatCols (ConcatColsRequest, Reply)

  service.proto:216

  message ConcatColsRequest

  service.proto:71

  • optional TaskInfo TaskID = 1

  • optional ConcatColsParameter Parameter = 2

• rpc Concat (ConcatRequest, Reply)

  service.proto:217

  message ConcatRequest

  service.proto:76

  • optional TaskInfo TaskID = 1

  • optional ConcatParameter Parameter = 2

• rpc Select (SelectRequest, Reply)

  service.proto:218

  message SelectRequest

  service.proto:81

  • optional TaskInfo TaskID = 1

  • optional SelectParameter Parameter = 2

• rpc CreateCol (CreateColRequest, Reply)

  service.proto:219

• rpc AsyncCreateCol (CreateColRequest, Reply)

  service.proto:220

• rpc DeleteTables (DeleteTablesRequest, Reply)

  service.proto:221

  message DeleteTablesRequest

  service.proto:91

  • optional TaskInfo TaskID = 1

  • optional DeleteTablesParameter Parameter = 2

• rpc ForceClean (ForceCleanRequest, ForceCleanReply)

  service.proto:223

  message ForceCleanRequest

  service.proto:145

  (message has no fields)

  message ForceCleanReply

  service.proto:146

  (message has no fields)

• rpc Initialize (InitializeRequest, InitializeReply)

  service.proto:224

  message InitializeRequest

  service.proto:147

  (message has no fields)

  message InitializeReply

  service.proto:148

  (message has no fields)

• rpc Execute (ExecuteRequest, ExecuteReply)

  service.proto:226

• rpc AsyncExecute (ExecuteRequest, Reply)

  service.proto:227

• rpc ExecuteResult (TaskInfo, ExecuteReply)

  service.proto:228

• rpc CreateResource (CreateResourceRequest, Reply)

  service.proto:230

  message CreateResourceRequest

  service.proto:188

  • optional TaskInfo TaskID = 1

  • optional OTTripleConfig TripleConfig = 2

• rpc DeleteResource (TaskInfo, Reply)

  service.proto:231

• rpc UploadFile (stream UploadFileRequest, Reply)

  service.proto:233

  message UploadFileRequest

  service.proto:96

  • oneof Data

    • string FileName = 1

    • bytes Content = 2

• rpc DownloadFile (DownloadFileRequest, stream DownloadFileReply)

  service.proto:234

  message DownloadFileRequest

  service.proto:139

  • string FileName = 1

  message DownloadFileReply

  service.proto:141

  • bytes Content = 1

* 离线任务grpc服务定义

• rpc syncJobJson (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:16

  * 同步任务

• rpc syncJobList (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:22

  * 同步阶段任务

• rpc commit (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:28

  * 提交任务

• rpc isFinished (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:34

  * 任务是否结束

• rpc finishTask (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:40

  * 结束任务

• rpc stopTask (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:46

  * 删除任务

• rpc queryTask (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:52

  * 删除任务

• rpc getMaxCompletedTaskId (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:58

  * 得到已完成的最大的子任务id

• rpc getChidTasks (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:63

  * 得到目标侧任务信息

• rpc errorAll (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:69

  * 任务error

• rpc getPodInfo (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:75

  * 获得pod信息

• rpc evalPodResource (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:81

  * 评估pod资源

• rpc handlePodResource (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:87

  * 处理pod资源

• rpc test (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:92

  * 测试

• rpc heartBeat (GrpcOfflineRequest, GrpcOfflineResponse)

  offline.proto:98

  * 心跳

Used in: ExportedData, LoadDataParameter

• string Name = 1

• database.ColumnType Type = 2

• string Default = 3

• repeated APIDataColumn.ColumnValue Values = 4

Used in: APIDataColumn

• oneof DataOneof

  • bytes BytesData = 1

  • int64 IntData = 2

  • int32 BoolData = 3

Used in: AggregateTableRequest, BatchParameter

• string InTable = 1

• string OutTable = 2

• int32 Col = 3

• int32 GroupbyCol = 4

• string GroupbyRefTable = 5

• AggregateParameter.AggregateType Type = 6

Used in: AggregateParameter

• Sum = 0

• Count = 1

Used as request type in: MPC.AggregateTable, MPC.AsyncAggregateTable

• optional TaskInfo TaskID = 1

• optional AggregateParameter Parameter = 2

Used in: BatchReply

• repeated BatchOutput.APIOutputData Results = 1

Used in: BatchOutput

• oneof Output

  • ExportedData ExportDataOutput = 1

Used in: BatchRequest

• oneof Parameter

  • LoadCSVParameter LoadCSVReq = 1

  • ExportCSVParameter ExportCSVReq = 2

  • ShareTableParameter SharedTableReq = 3

  • RevealTableParameter RevealTableReq = 4

  • JoinParameter JoinTableReq = 5

  • FilterParameter FilterTableReq = 6

  • AggregateParameter AggregateTableReq = 7

  • ConcatColsParameter ConcatColsReq = 8

  • ConcatParameter ConcatReq = 9

  • SelectParameter SelectReq = 10

  • CreateColParameter CreateColReq = 11

  • DeleteTablesParameter DeleteTablesReq = 12

  • LoadDataParameter LoadDataReq = 13

  • ExportDataParameter ExportDataReq = 14

Used as response type in: MPC.Batch, MPC.BatchResult

• optional Reply Rep = 1

• optional BatchOutput Output = 2

Used as request type in: MPC.AsyncBatch, MPC.Batch

Used as field type in: Stage

• optional TaskInfo TaskID = 1

• repeated BatchParameter Parameters = 2

Used in: ExecuteRequest

• repeated Instruction Ins = 1

• string Origin = 1

• string New = 2

• string JobID = 1

• repeated StageList stages = 2

Used in: BatchParameter, ConcatColsRequest

• string InTable1 = 1

• string InTable2 = 2

• string OutTable = 3

Used in: BatchParameter, ConcatRequest

• string InTable1 = 1

• string InTable2 = 2

• string OutTable = 3

Used in: BatchParameter, CreateColRequest

• string InTable = 1

• string OutTable = 2

• string ColName = 3

• repeated int32 Operands = 4

• CreateColParameter.Operator Op = 5

• int64 Scalar = 6

Used in: CreateColParameter

• SetIntZero = 0

• SetIntOne = 1

• Add = 2

• Sub = 3

• Mul = 4

• And = 5

• Or = 6

• Not = 7

• Xor = 8

• GT = 9

• GE = 10

• EQ = 11

• LT = 12

• LE = 13

Used as request type in: MPC.AsyncCreateCol, MPC.CreateCol

• optional TaskInfo TaskID = 1

• optional CreateColParameter Parameter = 2

Used in: BatchParameter, DeleteTablesRequest

• repeated string Tables = 1

Used as request type in: MPC.CloseNetwork, MPC.OpenNetwork

Used as response type in: MPC.CloseNetwork, MPC.OpenNetwork

(message has no fields)

Used in: ExecuteReply

• repeated ExecuteOutput.ExecuteOutputData Results = 1

Used in: ExecuteOutput

• oneof Output

  • ExportedInt ExportedIntOutput = 1

  • ExportedIntArray ExportedIntArrayOutput = 2

  • ExportedIntMatrix ExportedIntMatrixOutput = 3

Used as response type in: MPC.Execute, MPC.ExecuteResult

• optional Reply Rep = 1

• optional ExecuteOutput Output = 2

Used as request type in: MPC.AsyncExecute, MPC.Execute

• optional TaskInfo TaskID = 1

• optional Code Code = 2

Used in: BatchParameter, ExportCSVRequest

• string InTable = 1

• string OutFile = 2

• string Seperator = 3

• bool WithoutHeader = 4

Used in: BatchParameter, ExportDataRequest

• string InTable = 1

Used in: BatchOutput.APIOutputData, ExportDataReply

• string InTable = 1

• repeated APIDataColumn Columns = 2

Used in: ExecuteOutput.ExecuteOutputData

• int64 Value = 1

Used in: ExecuteOutput.ExecuteOutputData

• repeated int64 Values = 1

Used in: ExecuteOutput.ExecuteOutputData

• int64 Row = 1

• int64 Col = 2

• repeated int64 Values = 3

Used in: BatchParameter, FilterTableRequest

• string InTable = 1

• string OutTable = 2

• int32 LeftCol = 3

• FilterParameter.FilterCondition Relation = 4

• int32 RightCol = 5

• int64 Scalar = 6

• string RefStr = 7

Used in: FilterParameter

• EQ = 0

• NEQ = 1

• GT = 2

• LT = 3

• GE = 4

• LE = 5

Used as request type in: MPC.AsyncFilterTable, MPC.FilterTable

• optional TaskInfo TaskID = 1

• optional FilterParameter Parameter = 2

Used as request type in: OfflineService.commit, OfflineService.errorAll, OfflineService.evalPodResource, OfflineService.finishTask, OfflineService.getChidTasks, OfflineService.getMaxCompletedTaskId, OfflineService.getPodInfo, OfflineService.handlePodResource, OfflineService.heartBeat, OfflineService.isFinished, OfflineService.queryTask, OfflineService.stopTask, OfflineService.syncJobJson, OfflineService.syncJobList, OfflineService.test

• string id = 1

• int32 subId = 2

• int32 taskType = 3

• string jobJson = 4

• string test = 5

• string jobDistributorSign = 6

• string jobDistributorCert = 7

Used as response type in: OfflineService.commit, OfflineService.errorAll, OfflineService.evalPodResource, OfflineService.finishTask, OfflineService.getChidTasks, OfflineService.getMaxCompletedTaskId, OfflineService.getPodInfo, OfflineService.handlePodResource, OfflineService.heartBeat, OfflineService.isFinished, OfflineService.queryTask, OfflineService.stopTask, OfflineService.syncJobJson, OfflineService.syncJobList, OfflineService.test

• bool flag = 1

• int32 subId = 2

• int32 maxIndex = 3

• string message = 4

• string test = 5

• string res = 6

• string jobExecutorSign = 7

• string jobExecutorCert = 8

• bool signVerify = 9

• string id = 1

• int32 podNum = 2

• string name = 3

• int32 subId = 4

• int32 status = 5

• string type = 6

• string target = 7

• int32 cpu = 8

• int32 memory = 9

• map<string, string> parameters = 10

• int64 Operation = 1

• int64 Operation = 1

Used in: Code

• string Src1 = 1

• string Src2 = 2

• Operator Op = 3

• string Des = 4

• int64 Imm = 5

• repeated int64 IntArr = 6

• optional IntMatrix Mat = 7

• double Float = 8

Used in: Instruction

• int64 Row = 1

• int64 Col = 2

• repeated int64 Values = 3

Used in: BatchParameter, JoinTableRequest

• string LeftTable = 1

• int32 LeftJoinCol = 2

• string RightTable = 3

• int32 RightJoinCol = 4

• string OutTable = 5

• JoinParameter.JoinType Join = 6

Used in: JoinParameter

• Inner = 0

• Full = 1

• Left = 2

• Right = 3

• Diff = 4

Used as request type in: MPC.AsyncJoinTable, MPC.JoinTable

• optional TaskInfo TaskID = 1

• optional JoinParameter Parameter = 2

Used in: LoadCSVParameter

• string Name = 1

• database.ColumnType Type = 2

• string Default = 3

Used in: BatchParameter, LoadCSVRequest

• string InFile = 1

• string OutTable = 2

• repeated LoadCSVColumn Columns = 3

• string Seperator = 4

• bool WithoutHeader = 5

Used in: BatchParameter, LoadDataRequest

• string Name = 1

• repeated APIDataColumn Columns = 2

Used in: CreateResourceRequest

• uint64 IntBuffer = 1

• uint32 IntThread = 2

• uint64 IntBucket = 3

• uint64 BinaryBuffer = 4

• uint32 BinaryThread = 5

• uint64 BinaryBucket = 6

Used in: Instruction

• NOP = 0

• NewInt = 1

• NewBinary = 2

• NewIntArray = 3

• NewBinaryArray = 4

• NewPackedBinary = 5

• NewIntMatrix = 6

• NewFloat = 7

• Destroy = 9

• LoadTxt = 10

• LoadMySQL = 11

• LoadCsv = 12

• LoadStdinCsv = 13

• LoadStdinOrc = 14

• LoadOrc = 15

• Share = 20

• Move = 29

• Reveal = 30

• StoreTxt = 40

• StoreMySQL = 41

• StoreCsv = 42

• StoreStdinCsv = 43

• StoreStdinOrc = 44

• StoreOrc = 45

• ExportInt = 50

• ExportIntArray = 51

• ExportIntMatrix = 52

• ExportSharedInt = 53

• ExportSharedIntArray = 54

• FilterCsv = 60

• NewRandomInt = 70

• NewRandomIntMatrix = 76

• NewSharedInt = 80

• NewSharedIntArray = 83

• ConvertToInt = 90

• ConvertToIntArray = 91

• And = 100

• Or = 101

• Add = 102

• Sub = 103

• Mul = 104

• DotProduct = 105

• ImmSub = 106

• Not = 107

• MulXT = 110

• MulYT = 111

• MulXYT = 112

• TestEQ = 120

• TestNE = 121

• TestGT = 122

• TestGE = 123

• TestLT = 124

• TestLE = 125

Used as response type in: MPC.AggregateTable, MPC.AsyncAggregateTable, MPC.AsyncBatch, MPC.AsyncCreateCol, MPC.AsyncExecute, MPC.AsyncFilterTable, MPC.AsyncJoinTable, MPC.Concat, MPC.ConcatCols, MPC.CreateCol, MPC.CreateResource, MPC.DeleteResource, MPC.DeleteTables, MPC.ExportCSV, MPC.FilterTable, MPC.JoinTable, MPC.LastJobStatus, MPC.LoadCSV, MPC.LoadData, MPC.RevealTable, MPC.Select, MPC.ShareTable, MPC.UploadFile

Used as field type in: BatchReply, ExecuteReply, ExportDataReply

• int32 Status = 1

• string Msg = 2

Used in: BatchParameter, RevealTableRequest

• int32 Target = 1

• string InTable = 2

• string OutTable = 3

Used in: BatchParameter, SelectRequest

• string InTable = 1

• string OutTable = 2

• repeated int32 Cols = 3

Used in: BatchParameter, ShareTableRequest

• int32 owner = 1

• string ClearTable = 2

• string SharedTable = 3

Used in: StageList

• string type = 1

• optional BatchRequest batchRequest = 2

• string target = 3

• optional taskInfo taskInfo = 4

Used in: CompiledJob

• repeated Stage stage = 1

Used as request type in: MPC.BatchResult, MPC.DeleteResource, MPC.ExecuteResult, MPC.LastJobStatus

Used as field type in: AggregateTableRequest, BatchRequest, ConcatColsRequest, ConcatRequest, CreateColRequest, CreateResourceRequest, DeleteTablesRequest, ExecuteRequest, ExportCSVRequest, ExportDataRequest, FilterTableRequest, JoinTableRequest, LoadCSVRequest, LoadDataRequest, RevealTableRequest, SelectRequest, ShareTableRequest

• string TaskID = 1

• string JobID = 2

• string Target = 3

• int32 Party = 4

Used in: Stage

• string code = 1