package openmldb.taskmanager

Get desktop application:
View/edit binary Protocol Buffers messages

• rpc ShowJobs (ShowJobsRequest, ShowJobsResponse)

  taskmanager.proto:172

  Job management

  message ShowJobsRequest

  taskmanager.proto:25

  • optional bool unfinished = 1

  message ShowJobsResponse

  taskmanager.proto:29

  • required int32 code = 1

  • optional string msg = 2

  • repeated JobInfo jobs = 3

• rpc ShowJob (ShowJobRequest, ShowJobResponse)

  taskmanager.proto:173

  message ShowJobRequest

  taskmanager.proto:35

  • required int32 id = 1

• rpc StopJob (StopJobRequest, StopJobResponse)

  taskmanager.proto:174

  message StopJobRequest

  taskmanager.proto:45

  • required int32 id = 1

  message StopJobResponse

  taskmanager.proto:49

  • required int32 code = 1

  • optional string msg = 2

  • optional JobInfo job = 3

• rpc DeleteJob (DeleteJobRequest, DeleteJobResponse)

  taskmanager.proto:175

  message DeleteJobRequest

  taskmanager.proto:55

  • required int32 id = 1

  message DeleteJobResponse

  taskmanager.proto:59

  • required int32 code = 1

  • optional string msg = 2

• rpc ShowBatchVersion (ShowBatchVersionRequest, ShowJobResponse)

  taskmanager.proto:178

  Spark jobs

  message ShowBatchVersionRequest

  taskmanager.proto:64

  • optional bool sync_job = 1

• rpc RunBatchSql (RunBatchSqlRequest, RunBatchSqlResponse)

  taskmanager.proto:179

  message RunBatchSqlRequest

  taskmanager.proto:68

  • required string sql = 1

  • map<string, string> conf = 2

  • optional string default_db = 3

  message RunBatchSqlResponse

  taskmanager.proto:74

  • required int32 code = 1

  • optional string msg = 2

  • optional string output = 3

• rpc RunBatchAndShow (RunBatchAndShowRequest, ShowJobResponse)

  taskmanager.proto:180

  message RunBatchAndShowRequest

  taskmanager.proto:80

  • required string sql = 1

  • map<string, string> conf = 2

  • optional string default_db = 3

  • optional bool sync_job = 4

• rpc ImportOnlineData (ImportOnlineDataRequest, ShowJobResponse)

  taskmanager.proto:181

  message ImportOnlineDataRequest

  taskmanager.proto:87

  • required string sql = 1

  • map<string, string> conf = 2

  • optional string default_db = 3

  • optional bool sync_job = 4

• rpc ImportOfflineData (ImportOfflineDataRequest, ShowJobResponse)

  taskmanager.proto:182

  message ImportOfflineDataRequest

  taskmanager.proto:94

  • required string sql = 1

  • map<string, string> conf = 2

  • optional string default_db = 3

  • optional bool sync_job = 4

• rpc ExportOfflineData (ExportOfflineDataRequest, ShowJobResponse)

  taskmanager.proto:183

  message ExportOfflineDataRequest

  taskmanager.proto:101

  • required string sql = 1

  • map<string, string> conf = 2

  • optional string default_db = 3

  • optional bool sync_job = 4

• rpc InsertOfflineData (InsertOfflineDataRequest, ShowJobResponse)

  taskmanager.proto:184

  message InsertOfflineDataRequest

  taskmanager.proto:108

  • required string sql = 1

  • map<string, string> conf = 2

  • optional string default_db = 3

  • optional bool sync_job = 4

• rpc DropOfflineTable (DropOfflineTableRequest, DropOfflineTableResponse)

  taskmanager.proto:185

  message DropOfflineTableRequest

  taskmanager.proto:115

  • required string db = 1

  • required string table = 2

  message DropOfflineTableResponse

  taskmanager.proto:120

  • required int32 code = 1

  • optional string msg = 2

• rpc GetJobLog (GetJobLogRequest, GetJobLogResponse)

  taskmanager.proto:186

  message GetJobLogRequest

  taskmanager.proto:125

  • required int32 id = 1

  message GetJobLogResponse

  taskmanager.proto:129

  • required int32 code = 1

  • optional string msg = 2

  • optional string log = 3

• rpc CreateFunction (CreateFunctionRequest, CreateFunctionResponse)

  taskmanager.proto:187

  message CreateFunctionRequest

  taskmanager.proto:135

  • optional common.ExternalFun fun = 1

  message CreateFunctionResponse

  taskmanager.proto:139

  • required int32 code = 1

  • optional string msg = 2

• rpc DropFunction (DropFunctionRequest, DropFunctionResponse)

  taskmanager.proto:188

  message DropFunctionRequest

  taskmanager.proto:144

  • optional string name = 1

  message DropFunctionResponse

  taskmanager.proto:148

  • required int32 code = 1

  • optional string msg = 2

• rpc GetVersion (EmptyMessage, GetVersionResponse)

  taskmanager.proto:191

  Other APIs

  message EmptyMessage

  taskmanager.proto:158

  (message has no fields)

  message GetVersionResponse

  taskmanager.proto:153

  • required string taskmanager_version = 1

  • required string batch_version = 2

• rpc SaveJobResult (SaveJobResultRequest, SaveJobResultResponse)

  taskmanager.proto:192

  message SaveJobResultRequest

  taskmanager.proto:160

  • required int32 result_id = 1

  • required string json_data = 2

  message SaveJobResultResponse

  taskmanager.proto:165

  • required int32 code = 1

  • optional string msg = 2

Used in: ShowJobResponse, ShowJobsResponse, StopJobResponse

• required int32 id = 1

• optional string job_type = 2

• optional string state = 3

• optional int64 start_time = 4

• optional int64 end_time = 5

• optional string parameter = 6

• optional string cluster = 7

• optional string application_id = 8

• optional string error = 9

• optional string tracking_url = 10

• optional float progress = 11

Used as response type in: TaskManagerServer.ExportOfflineData, TaskManagerServer.ImportOfflineData, TaskManagerServer.ImportOnlineData, TaskManagerServer.InsertOfflineData, TaskManagerServer.RunBatchAndShow, TaskManagerServer.ShowBatchVersion, TaskManagerServer.ShowJob

• required int32 code = 1

• optional string msg = 2

• optional JobInfo job = 3