diff --git a/apps/dhp-mdstore-manager/src/main/java/eu/dnetlib/data/mdstore/manager/controller/MDStoreController.java b/apps/dhp-mdstore-manager/src/main/java/eu/dnetlib/data/mdstore/manager/controller/MDStoreController.java index 1cd6b3a4..290783e1 100644 --- a/apps/dhp-mdstore-manager/src/main/java/eu/dnetlib/data/mdstore/manager/controller/MDStoreController.java +++ b/apps/dhp-mdstore-manager/src/main/java/eu/dnetlib/data/mdstore/manager/controller/MDStoreController.java @@ -215,6 +215,14 @@ public class MDStoreController extends AbstractDnetController { return hdfsClient.readParquetFiles(path + "/store", limit); } + @ApiOperation("read the parquet file of a mdstore (current version)") + @GetMapping("/mdstore/{mdId}/parquet/content/{limit}") + public List> listMdstoreParquet(@PathVariable final String mdId, @PathVariable final long limit) throws MDStoreManagerException { + final String versionId = databaseUtils.findMdStore(mdId).getCurrentVersion(); + final String path = databaseUtils.findVersion(versionId).getHdfsPath(); + return hdfsClient.readParquetFiles(path + "/store", limit); + } + protected void setDatabaseUtils(final DatabaseUtils databaseUtils) { this.databaseUtils = databaseUtils; }