跳到主要内容
版本: 1.1

Get Stream Graph

URL: http://localhost:8888/openapi/getStreamGraph

Origin Url: http://localhost:8888/openapi/getStreamGraph

Type: POST

Request headers

Header NameHeader Value

Parameters

Path parameters
ParameterTypeValueDescription
URL parameters
RequiredParameterTypeValueDescription
Body parameters
JSON
{
"id": 6,
"name": "Name",
"dialect": "dialect_lsq59",
"type": "Local",
"savePointStrategy": 1,
"savePointPath": "/savepoints",
"parallelism": 4,
"fragment": false,
"statementSet": "false",
"batchModel": "true",
"clusterId": 1,
"clusterConfigurationId": 2,
"databaseId": 3,
"alertGroupId": 7001,
"note": "note_1yqdr",
"step": 1,
"jobInstanceId": 8001,
"status": "RUNNING",
"versionId": 9001,
"enabled": true,
"statement": "SELECT * FROM table",
"clusterName": "clusterName_g02m1",
"configJson": {
"udfConfig": {
"templateId": 1,
"selectKeys": [
{}
],
"className": "className_wh0cp"
},
"customConfig": [
{
"key": "test",
"value": "test"
}
]
},
"path": "path_f1cu8",
"clusterConfigurationName": "clusterConfigurationName_drlr1",
"databaseName": "databaseName_cnt5m",
"envName": "envName_u51ma",
"alertGroupName": "alertGroupName_ezvtk",
"useResult": "true",
"useChangeLog": "false",
"useAutoCancel": "false",
"session": "session_id",
"jobName": "MyJob",
"maxRowNum": 100,
"envId": 1,
"variables": {}
}
JSON document
{
"note":"Note",
"configJson":{
"udfConfig":{
"selectKeys":[
{}
],
"className":"Class Name",
"templateId":"Template ID"
},
"customConfig":[
{
"value":"value",
"key":"key"
}
]
},
"alertGroupId":"Alert Group ID",
"dialect":"Dialect",
"jobInstanceId":"Job Instance ID",
"databaseName":"Database Name",
"session":"Session",
"parallelism":"Parallelism",
"clusterConfigurationId":"Cluster Configuration ID",
"batchModel":"Batch Model",
"clusterId":"ClusterInstance ID",
"type":"Run Mode",
"statementSet":"Use Statement Set",
"enabled":"Enabled",
"path":"Path",
"clusterName":"ClusterInstance Name",
"savePointPath":"Save Point Path",
"statement":"Statement",
"id":"ID",
"databaseId":"Database ID",
"savePointStrategy":"Save Point Strategy",
"jobName":"Job Name",
"alertGroupName":"Alert Group Name",
"useAutoCancel":"Use Auto Cancel",
"variables":{},
"clusterConfigurationName":"Cluster Configuration Name",
"envId":"Environment ID",
"useResult":"UseResult",
"maxRowNum":"Max Row Number",
"fragment":"Fragment Flag",
"versionId":"Version ID",
"envName":"Environment Name",
"name":"Name",
"useChangeLog":"UseChangeLog",
"step":"Step",
"status":"Job status"
}
Form URL-Encoded
RequiredParameterTypeValueDescription
Multipart
RequiredParameterTypeValueDescription

Response

Response example

Response document
{
"msg":"Result Message",
"code":"Result Code",
"data":{
"_children":{},
"_nodeFactory":{
"_cfgBigDecimalExact":"No comment,Type =Boolean"
}
},
"success":"Result is Success",
"time":"Result Time"
}

Demo

 http://127.0.0.1:8888/openapi/getStreamGraph 
{
/* required-start */
"statement":"CREATE TABLE Orders (\r\n order_number INT,\r\n price DECIMAL(32,2),\r\n order_time TIMESTAMP(3)\r\n) WITH (\r\n 'connector' = 'datagen',\r\n 'rows-per-second' = '1',\r\n 'fields.order_number.kind' = 'sequence',\r\n 'fields.order_number.start' = '1',\r\n 'fields.order_number.end' = '1000'\r\n);\r\nCREATE TABLE pt (\r\nordertotal INT,\r\nnumtotal INT\r\n) WITH (\r\n 'connector' = 'print'\r\n);\r\ninsert into pt select 1 as ordertotal ,sum(order_number)*2 as numtotal from Orders",
/* required-end */
/* default-start */
"useStatementSet":false,
"fragment":false,
"parallelism":1,
/* default-start */
/* custom-start */
"configuration":{
"table.exec.resource.default-parallelism":2
}
/* custom-end */
}