Import the flow from the Json File
Developing
POST
flows/import/{projectId}
Request
Path Params
Body Params multipart/form-dataRequired
Responses
Request Request Example
Shell
JavaScript
Java
Swift
curl --location --request POST 'flows/import/da18bdf3-f059-4cab-9a7a-dbf28c98ffe5' \
--header 'Authorization: Bearer <token>' \
--form 'file=@"cmMtdXBsb2FkLTE3NzAwMTU1NTgxMDUtMg==/data.json"'Response Response Example
{
"message": "Flow Created Successfully",
"flow": {
"id": "17d9a0ff-6b43-4b26-a3c3-63f630a96e2f",
"projectId": "da18bdf3-f059-4cab-9a7a-dbf28c98ffe5",
"createdById": "00000000-0000-0000-0000-000000000001",
"name": "m2s_demo_jxwqxnw",
"description": null,
"version": "1.0",
"metadata": {
"catalog": "hive_prod"
},
"tags": [],
"createdAt": "2026-02-02T10:00:00.415Z",
"updatedAt": "2026-02-02T10:00:00.528Z",
"lockedById": null,
"lockedAt": null,
"nodes": [
{
"id": "ab393f04-550a-46cc-afd2-b73688cd718b",
"flowId": "17d9a0ff-6b43-4b26-a3c3-63f630a96e2f",
"type": "source",
"position": {
"x": 80,
"y": 80
},
"data": {
"alias": "txn",
"table": "dm.txn",
"sourceType": "table"
},
"displayOrder": 0,
"createdAt": "2026-02-02T10:00:00.460Z",
"updatedAt": "2026-02-02T10:00:00.460Z"
},
{
"id": "adb46096-c445-468b-85b3-57c35998cf2b",
"flowId": "17d9a0ff-6b43-4b26-a3c3-63f630a96e2f",
"type": "filter",
"position": {
"x": 380,
"y": 90
},
"data": {
"condition": "amount > 0"
},
"displayOrder": 1,
"createdAt": "2026-02-02T10:00:00.471Z",
"updatedAt": "2026-02-02T10:00:00.471Z"
},
{
"id": "ccf1770f-a13f-4641-b9c7-9439ec15736b",
"flowId": "17d9a0ff-6b43-4b26-a3c3-63f630a96e2f",
"type": "aggregate",
"position": {
"x": 680,
"y": 80
},
"data": {
"aggs": [
{
"expr": "sum(amount)",
"alias": "total_amount"
},
{
"expr": "count(1)",
"alias": "tx_count"
}
],
"groupBy": [
"customer_id"
]
},
"displayOrder": 2,
"createdAt": "2026-02-02T10:00:00.476Z",
"updatedAt": "2026-02-02T10:00:00.476Z"
},
{
"id": "93009001-b1e5-4846-a477-7beaa41311f0",
"flowId": "17d9a0ff-6b43-4b26-a3c3-63f630a96e2f",
"type": "source",
"position": {
"x": 680,
"y": 260
},
"data": {
"path": "/data/raw/customers",
"alias": "customers",
"format": "parquet",
"sourceType": "path"
},
"displayOrder": 3,
"createdAt": "2026-02-02T10:00:00.482Z",
"updatedAt": "2026-02-02T10:00:00.482Z"
},
{
"id": "e677d5c1-3b54-4e96-a48d-1f738931e02f",
"flowId": "17d9a0ff-6b43-4b26-a3c3-63f630a96e2f",
"type": "join",
"position": {
"x": 980,
"y": 170
},
"data": {
"on": "l.customer_id = r.id",
"how": "left",
"leftKey": "customer_id",
"rightKey": "id"
},
"displayOrder": 4,
"createdAt": "2026-02-02T10:00:00.488Z",
"updatedAt": "2026-02-02T10:00:00.488Z"
},
{
"id": "b1cd9f4f-447e-48b6-ac5e-e4642aa13cdf",
"flowId": "17d9a0ff-6b43-4b26-a3c3-63f630a96e2f",
"type": "derive",
"position": {
"x": 1280,
"y": 170
},
"data": {
"columns": [
{
"expr": "total_amount / nullif(tx_count, 0)",
"name": "avg_txn"
}
]
},
"displayOrder": 5,
"createdAt": "2026-02-02T10:00:00.492Z",
"updatedAt": "2026-02-02T10:00:00.492Z"
},
{
"id": "cd8678c3-03b4-4d8d-9c11-5f3f7d52c2b3",
"flowId": "17d9a0ff-6b43-4b26-a3c3-63f630a96e2f",
"type": "sink",
"position": {
"x": 1580,
"y": 170
},
"data": {
"keys": [
"customer_id"
],
"table": "dm.customer_metrics",
"catalog": "hive_prod",
"sinkType": "iceberg_merge"
},
"displayOrder": 6,
"createdAt": "2026-02-02T10:00:00.497Z",
"updatedAt": "2026-02-02T10:00:00.497Z"
}
],
"edges": [
{
"id": "d1c045b2-679a-4b6c-8336-3e01228d0291",
"flowId": "17d9a0ff-6b43-4b26-a3c3-63f630a96e2f",
"source": "ab393f04-550a-46cc-afd2-b73688cd718b",
"target": "adb46096-c445-468b-85b3-57c35998cf2b",
"sourceHandle": "out",
"targetHandle": "in",
"metadata": {},
"createdAt": "2026-02-02T10:00:00.502Z",
"updatedAt": "2026-02-02T10:00:00.502Z"
},
{
"id": "2ab066ec-d1df-459c-a752-5c9e62810dda",
"flowId": "17d9a0ff-6b43-4b26-a3c3-63f630a96e2f",
"source": "adb46096-c445-468b-85b3-57c35998cf2b",
"target": "ccf1770f-a13f-4641-b9c7-9439ec15736b",
"sourceHandle": "out",
"targetHandle": "in",
"metadata": {},
"createdAt": "2026-02-02T10:00:00.502Z",
"updatedAt": "2026-02-02T10:00:00.502Z"
},
{
"id": "2dda9438-5b11-4bbc-bed8-2906ee4007fd",
"flowId": "17d9a0ff-6b43-4b26-a3c3-63f630a96e2f",
"source": "ccf1770f-a13f-4641-b9c7-9439ec15736b",
"target": "e677d5c1-3b54-4e96-a48d-1f738931e02f",
"sourceHandle": "out",
"targetHandle": "left",
"metadata": {},
"createdAt": "2026-02-02T10:00:00.502Z",
"updatedAt": "2026-02-02T10:00:00.502Z"
},
{
"id": "45a7b328-f01e-425a-899d-16ddc84c75e7",
"flowId": "17d9a0ff-6b43-4b26-a3c3-63f630a96e2f",
"source": "93009001-b1e5-4846-a477-7beaa41311f0",
"target": "e677d5c1-3b54-4e96-a48d-1f738931e02f",
"sourceHandle": "out",
"targetHandle": "right",
"metadata": {},
"createdAt": "2026-02-02T10:00:00.502Z",
"updatedAt": "2026-02-02T10:00:00.502Z"
},
{
"id": "dbbde39d-5112-438c-b22b-48921459cbad",
"flowId": "17d9a0ff-6b43-4b26-a3c3-63f630a96e2f",
"source": "e677d5c1-3b54-4e96-a48d-1f738931e02f",
"target": "b1cd9f4f-447e-48b6-ac5e-e4642aa13cdf",
"sourceHandle": "out",
"targetHandle": "in",
"metadata": {},
"createdAt": "2026-02-02T10:00:00.502Z",
"updatedAt": "2026-02-02T10:00:00.502Z"
},
{
"id": "2385b6fe-6cd5-4d36-9bbd-25e088ca3886",
"flowId": "17d9a0ff-6b43-4b26-a3c3-63f630a96e2f",
"source": "b1cd9f4f-447e-48b6-ac5e-e4642aa13cdf",
"target": "cd8678c3-03b4-4d8d-9c11-5f3f7d52c2b3",
"sourceHandle": "out",
"targetHandle": "in",
"metadata": {},
"createdAt": "2026-02-02T10:00:00.502Z",
"updatedAt": "2026-02-02T10:00:00.502Z"
}
],
"createdBy": {
"id": "00000000-0000-0000-0000-000000000001",
"email": "admin@spark.local",
"name": "Default Admin"
},
"lockedBy": null
}
}Modified at 2026-02-02 10:42:20