Merge branch 'feat/infer_dev_260107' of https://kamco.gitea.gs.dabeeo.com/dabeeo/kamco-dabeeo-backoffice into feat/infer_dev_260107
This commit is contained in:
@@ -85,7 +85,6 @@ public class InferenceResultService {
|
||||
@Value("${inference.inference-server-name}")
|
||||
private String inferenceServerName;
|
||||
|
||||
|
||||
@Value("${file.dataset-dir}")
|
||||
private String datasetDir;
|
||||
|
||||
@@ -522,13 +521,13 @@ public class InferenceResultService {
|
||||
public List<InferenceServerStatusDto> getInferenceServerStatusList() {
|
||||
|
||||
String[] serverNames = inferenceServerName.split(",");
|
||||
int serveCnt = serverNames.length;
|
||||
int serveCnt = serverNames.length;
|
||||
|
||||
List<InferenceServerStatusDto> dtoList =
|
||||
inferenceResultCoreService.getInferenceServerStatusList();
|
||||
int size = dtoList.size();
|
||||
|
||||
List<InferenceServerStatusDto> serverStatusList = new ArrayList<>();
|
||||
List<InferenceServerStatusDto> serverStatusList = new ArrayList<>();
|
||||
|
||||
System.out.println("size =" + size);
|
||||
|
||||
@@ -550,9 +549,8 @@ public class InferenceResultService {
|
||||
String srvNm = serverNames[k];
|
||||
String srvNmChk = "N";
|
||||
|
||||
Optional<InferenceServerStatusDto> matchingDto = dtoList.stream()
|
||||
.filter(dto -> srvNm.equals(dto.getServerName()))
|
||||
.findFirst();
|
||||
Optional<InferenceServerStatusDto> matchingDto =
|
||||
dtoList.stream().filter(dto -> srvNm.equals(dto.getServerName())).findFirst();
|
||||
|
||||
/*
|
||||
int serverChekcCnt =
|
||||
@@ -569,14 +567,10 @@ public class InferenceResultService {
|
||||
dto.setKbmemused(0L);
|
||||
dto.setGpuUtil(0);
|
||||
serverStatusList.add(dto);
|
||||
}
|
||||
else
|
||||
{
|
||||
} else {
|
||||
serverStatusList.add(matchingDto.get());
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
serverStatusList.sort(Comparator.comparing(InferenceServerStatusDto::getServerName));
|
||||
|
||||
@@ -152,8 +152,7 @@ public class MapSheetLearnRepositoryImpl implements MapSheetLearnRepositoryCusto
|
||||
systemMetricEntity.cpuSystem,
|
||||
systemMetricEntity.memused,
|
||||
systemMetricEntity.kbmemused,
|
||||
gpuMetricEntity.gpuUtil
|
||||
))
|
||||
gpuMetricEntity.gpuUtil))
|
||||
.from(systemMetricEntity)
|
||||
.leftJoin(gpuMetricEntity)
|
||||
.on(
|
||||
@@ -161,9 +160,10 @@ public class MapSheetLearnRepositoryImpl implements MapSheetLearnRepositoryCusto
|
||||
.timestamp
|
||||
.in(latestGpuIds)
|
||||
.and(gpuMetricEntity.serverName.eq(systemMetricEntity.serverName)))
|
||||
.where(systemMetricEntity.timestamp.in(latestIds)
|
||||
//.and(systemMetricEntity.serverName.ne("server2"))
|
||||
) // In 절 사용
|
||||
.where(
|
||||
systemMetricEntity.timestamp.in(latestIds)
|
||||
// .and(systemMetricEntity.serverName.ne("server2"))
|
||||
) // In 절 사용
|
||||
.orderBy(systemMetricEntity.serverName.asc())
|
||||
.limit(4)
|
||||
.fetch();
|
||||
|
||||
@@ -137,7 +137,8 @@ public class ChangeDetectionRepositoryImpl extends QuerydslRepositorySupport
|
||||
ChangeDetectionDto.CogUrlData.class,
|
||||
makeCogUrl(req.getBeforeYear()).max().as("beforeCogUrl"),
|
||||
makeCogUrl(req.getAfterYear()).max().as("afterCogUrl"),
|
||||
Expressions.stringTemplate("ST_AsGeoJSON({0})", mapInkx5kEntity.geom)
|
||||
Expressions.stringTemplate(
|
||||
"ST_AsGeoJSON(ST_Transform({0}, 5186))", mapInkx5kEntity.geom)
|
||||
.as("bbox")))
|
||||
.from(imageryEntity)
|
||||
.innerJoin(mapInkx5kEntity)
|
||||
|
||||
@@ -64,6 +64,7 @@ inference:
|
||||
batch-url: http://10.100.0.11:8000/batches
|
||||
geojson-dir: /kamco-nfs/requests/
|
||||
jar-path: /kamco-nfs/dataset/shp_exporter-1.0.0.jar
|
||||
inference-server-name: server1,server2,server3,server4
|
||||
|
||||
gukyuin:
|
||||
#url: http://localhost:8080
|
||||
|
||||
Reference in New Issue
Block a user