fix: added depth in json and pass in metadata entry (#23332)

This commit is contained in:
Keshav Mohta 2025-09-12 12:31:20 +05:30 committed by GitHub
parent d1e829ed8c
commit 1f379a8697
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 17 additions and 3 deletions

View File

@ -274,6 +274,7 @@ class StorageServiceSource(TopologyRunnerMixin, Source, ABC):
isPartitioned=entry.isPartitioned,
partitionColumns=entry.partitionColumns,
separator=entry.separator,
depth=entry.depth,
)
for entry in manifest.entries
if entry.containerName == container_name

View File

@ -46,10 +46,17 @@
"$ref": "../../entity/data/table.json#/definitions/column"
},
"default": null
},
"depth": {
"title": "Depth",
"description": "Depth level in the storage path hierarchy where data files reside.",
"type": "integer",
"default": 0
}
},
"required": [
"containerName" ,"dataPath"
"containerName",
"dataPath"
]
}
},
@ -63,6 +70,8 @@
"default": null
}
},
"required": ["entries"],
"required": [
"entries"
],
"additionalProperties": false
}

View File

@ -30,6 +30,10 @@ export interface ManifestMetadataEntry {
* The path where the data resides in the container, excluding the bucket name
*/
dataPath: string;
/**
* Depth level in the storage path hierarchy where data files reside.
*/
depth?: number;
/**
* Flag indicating whether the container's data is partitioned
*/