POST
/
v1
/
pipelines
/
preview
{
  "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
​
query
string
required
​
enableSinks
boolean
​
udfs
object[] | null

Response

200
application/json
Created pipeline and job
​
actionInProgress
boolean
required
​
actionText
string
required
​
checkpointIntervalMicros
integer
required
Required range: x > 0
​
createdAt
integer
required
Required range: x > 0
​
graph
object
required
​
id
string
required
​
name
string
required
​
preview
boolean
required
​
query
string
required
​
stop
enum<string>
required
Available options:
none,
checkpoint,
graceful,
immediate,
force
​
udfs
object[]
required
​
action
enum<string>
Available options:
none,
checkpoint,
graceful,
immediate,
force
Create a new pipelineValidate a query and return pipeline graph