in amoro-ams/src/main/java/org/apache/amoro/server/dashboard/DashboardServer.java [227:376]
private EndpointGroup apiGroup() {
return () -> {
// table apis
path(
"/tables",
() -> {
get(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/details",
tableController::getTableDetail);
get(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/hive/details",
tableController::getHiveTableDetail);
post(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/upgrade",
tableController::upgradeHiveTable);
get(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/upgrade/status",
tableController::getUpgradeStatus);
get(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/optimizing-processes",
tableController::getOptimizingProcesses);
get(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/optimizing-types",
tableController::getOptimizingTypes);
get(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/optimizing-processes/{processId}/tasks",
tableController::getOptimizingProcessTasks);
get(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/snapshots",
tableController::getTableSnapshots);
get(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/snapshots/{snapshotId}/detail",
tableController::getSnapshotDetail);
get(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/partitions",
tableController::getTablePartitions);
get(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/partitions/{partition}/files",
tableController::getPartitionFileListInfo);
get(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/operations",
tableController::getTableOperations);
get("/catalogs/{catalog}/dbs/{db}/tables/{table}/tags", tableController::getTableTags);
get(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/branches",
tableController::getTableBranches);
get(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/consumers",
tableController::getTableConsumerInfos);
post(
"/catalogs/{catalog}/dbs/{db}/tables/{table}/optimizing-processes/{processId}/cancel",
tableController::cancelOptimizingProcess);
});
get("/upgrade/properties", tableController::getUpgradeHiveTableProperties);
// catalog apis
path(
"/catalogs",
() -> {
get("/{catalog}/databases/{db}/tables", tableController::getTableList);
get("/{catalog}/databases", tableController::getDatabaseList);
get("", tableController::getCatalogs);
post("", catalogController::createCatalog);
get("metastore/types", catalogController::getCatalogTypeList);
get("/{catalogName}", catalogController::getCatalogDetail);
delete("/{catalogName}", catalogController::deleteCatalog);
put("/{catalogName}", catalogController::updateCatalog);
get("/{catalogName}/delete/check", catalogController::catalogDeleteCheck);
get("/{catalogName}/config/{type}/{key}", catalogController::getCatalogConfFileContent);
});
// optimizing api
path(
"/optimize",
() -> {
get("/actions", optimizerGroupController::getActions);
get(
"/optimizerGroups/{optimizerGroup}/tables",
optimizerGroupController::getOptimizerTables);
get(
"/optimizerGroups/{optimizerGroup}/optimizers",
optimizerGroupController::getOptimizers);
get("/optimizerGroups", optimizerGroupController::getOptimizerGroups);
get(
"/optimizerGroups/{optimizerGroup}/info",
optimizerGroupController::getOptimizerGroupInfo);
post(
"/optimizerGroups/{optimizerGroup}/optimizers",
optimizerGroupController::scaleOutOptimizer);
post("/optimizers", optimizerController::createOptimizer);
delete("/optimizers/{jobId}", optimizerController::releaseOptimizer);
get("/resourceGroups", optimizerGroupController::getResourceGroup);
post("/resourceGroups", optimizerGroupController::createResourceGroup);
put("/resourceGroups", optimizerGroupController::updateResourceGroup);
delete(
"/resourceGroups/{resourceGroupName}",
optimizerGroupController::deleteResourceGroup);
get(
"/resourceGroups/{resourceGroupName}/delete/check",
optimizerGroupController::deleteCheckResourceGroup);
get("/containers/get", optimizerGroupController::getContainers);
});
// console apis
path(
"/terminal",
() -> {
get("/examples", terminalController::getExamples);
get("/examples/{exampleName}", terminalController::getSqlExamples);
post("/catalogs/{catalog}/execute", terminalController::executeScript);
get("/{sessionId}/logs", terminalController::getLogs);
get("/{sessionId}/result", terminalController::getSqlResult);
put("/{sessionId}/stop", terminalController::stopSql);
get("/latestInfos/", terminalController::getLatestInfo);
});
// file apis
path(
"/files",
() -> {
post("", platformFileInfoController::uploadFile);
get("/{fileId}", platformFileInfoController::downloadFile);
});
// setting apis
path(
"/settings",
() -> {
get("/containers", settingController::getContainerSetting);
get("/system", settingController::getSystemSetting);
});
// health api
get("/health/status", healthCheckController::healthCheck);
// version api
get("/versionInfo", versionController::getVersionInfo);
// overview apis
path(
"/overview",
() -> {
get("/summary", overviewController::getSummary);
get("/resource", overviewController::getResourceUsageHistory);
get("/optimizing", overviewController::getOptimizingStatus);
get("/dataSize", overviewController::getDataSizeHistory);
get("/top", overviewController::getTopTables);
});
};
}