REST API v1
Contents
REST API v1#
Note that: now the api version is v1 and the base uri is /api/v1
.
Batch Resource#
GET /batches#
Returns all the batches.
Request Parameters#
Name | Description | Type |
---|---|---|
batchType | The batch type, such as spark/flink, if no batchType is specified, return all types |
String |
batchState | The valid batch state can be one of the following: PENDING, RUNNING, FINISHED, ERROR, CANCELED |
String |
batchUser | The user name that created the batch | String |
createTime | Return the batch that created after this timestamp | Long |
endTime | Return the batch that ended before this timestamp | Long |
from | The start index to fetch sessions | Int |
size | Number of sessions to fetch | Int |
Response Body#
Name | Description | Type |
---|---|---|
from | The start index of fetched sessions | Int |
total | Number of sessions fetched | Int |
batches | Batch List | List |
POST /batches#
Request Body#
Name | Description | Type |
---|---|---|
batchType | The batch type, such as Spark, Flink | String |
resource | The resource containing the application to execute | Path (required) |
className | Application main class | String(required) |
name | The name of this batch. | String |
conf | Configuration properties | Map of key=val |
args | Command line arguments for the application | List of Strings |
Response Body#
The created Batch object.
GET /batches/{batchId}#
Returns the batch information.
Response Body#
The Batch.
DELETE /batches/${batchId}#
Kill the batch if it is still running.
Request Parameters#
Name | Description | Type |
---|---|---|
hive.server2.proxy.user | the proxy user to impersonate | String(optional) |
Response Body#
Name | Description | Type |
---|---|---|
success | Whether killed the batch successfully | Boolean |
msg | The kill batch message | String |
GET /batches/${batchId}/localLog#
Gets the local log lines from this batch.
Request Parameters#
Name | Description | Type |
---|---|---|
from | Offset | Int |
size | Max number of log lines to return | Int |
Response Body#
Name | Description | Type |
---|---|---|
logRowSet | The log lines | List of Strings |
rowCount | The log row count | Int |
Batch#
Name | Description | Type |
---|---|---|
id | The batch id | String |
user | The user created the batch | String |
batchType | The batch type | String |
name | The batch name | String |
appId | The batch application Id | String |
appUrl | The batch application tracking url | String |
appState | The batch application state | String |
appDiagnostic | The batch application diagnostic | String |
kyuubiInstance | The kyuubi instance that created the batch | String |
state | The kyuubi batch operation state | String |
createTime | The batch create time | Long |
endTime | The batch end time, if it has not been terminated, the value is 0 | Long |