API Documentation
- API Overview
- Connectors
- Connection Profiles
- Connection Tables
- Jobs
- Pipelines
- UDFs
Pipelines
Create a new pipeline
The API will create a single job for the pipeline.
POST
/
v1
/
pipelines
{
"action": "none",
"actionInProgress": true,
"actionText": "<string>",
"checkpointIntervalMicros": 1,
"createdAt": 1,
"graph": {
"edges": [
{
"destId": 1,
"edgeType": "<string>",
"keyType": "<string>",
"srcId": 1,
"valueType": "<string>"
}
],
"nodes": [
{
"description": "<string>",
"nodeId": 1,
"operator": "<string>",
"parallelism": 1
}
]
},
"id": "<string>",
"name": "<string>",
"preview": true,
"query": "<string>",
"stop": "none",
"udfs": [
{
"definition": "<string>",
"language": "python"
}
]
}
Body
application/json
Response
200
application/json
Created pipeline and job
The response is of type object
.
{
"action": "none",
"actionInProgress": true,
"actionText": "<string>",
"checkpointIntervalMicros": 1,
"createdAt": 1,
"graph": {
"edges": [
{
"destId": 1,
"edgeType": "<string>",
"keyType": "<string>",
"srcId": 1,
"valueType": "<string>"
}
],
"nodes": [
{
"description": "<string>",
"nodeId": 1,
"operator": "<string>",
"parallelism": 1
}
]
},
"id": "<string>",
"name": "<string>",
"preview": true,
"query": "<string>",
"stop": "none",
"udfs": [
{
"definition": "<string>",
"language": "python"
}
]
}