Skip to content

Commit ef3260f

Browse files
mkuchenbeckerclaude
andcommitted
fix: update service impl to use consolidated find methods
Align OptimizerDataServiceImpl with renamed repository methods from optimizer-1 review feedback. Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
1 parent f7f6812 commit ef3260f

File tree

1 file changed

+7
-12
lines changed

1 file changed

+7
-12
lines changed

services/optimizer/src/main/java/com/linkedin/openhouse/optimizer/service/OptimizerDataServiceImpl.java

Lines changed: 7 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -46,8 +46,8 @@ public List<TableOperationsDto> listTableOperations(
4646
String databaseName,
4747
String tableName,
4848
String tableUuid) {
49-
return operationsRepository
50-
.findFiltered(operationType, status, databaseName, tableName, tableUuid).stream()
49+
return operationsRepository.find(operationType, status, databaseName, tableName, tableUuid)
50+
.stream()
5151
.map(mapper::toDto)
5252
.collect(Collectors.toList());
5353
}
@@ -130,20 +130,14 @@ public Optional<TableStatsDto> getTableStats(String tableUuid) {
130130

131131
@Override
132132
public List<TableStatsDto> listTableStats(String databaseId, String tableName, String tableUuid) {
133-
return statsRepository.findFiltered(databaseId, tableName, tableUuid).stream()
133+
return statsRepository.find(databaseId, tableName, tableUuid).stream()
134134
.map(mapper::toDto)
135135
.collect(Collectors.toList());
136136
}
137137

138138
@Override
139139
public List<TableStatsHistoryDto> getStatsHistory(String tableUuid, Instant since, int limit) {
140-
PageRequest page = PageRequest.of(0, limit);
141-
if (since != null) {
142-
return statsHistoryRepository.findByTableUuidSince(tableUuid, since, page).stream()
143-
.map(mapper::toDto)
144-
.collect(Collectors.toList());
145-
}
146-
return statsHistoryRepository.findByTableUuid(tableUuid, page).stream()
140+
return statsHistoryRepository.find(tableUuid, since, PageRequest.of(0, limit)).stream()
147141
.map(mapper::toDto)
148142
.collect(Collectors.toList());
149143
}
@@ -170,7 +164,8 @@ public TableOperationsHistoryDto appendHistory(TableOperationsHistoryDto dto) {
170164

171165
@Override
172166
public List<TableOperationsHistoryDto> getHistory(String tableUuid, int limit) {
173-
return historyRepository.find(tableUuid, limit).stream()
167+
return historyRepository
168+
.find(null, null, tableUuid, null, null, null, null, PageRequest.of(0, limit)).stream()
174169
.map(mapper::toDto)
175170
.collect(Collectors.toList());
176171
}
@@ -186,7 +181,7 @@ public List<TableOperationsHistoryDto> listHistory(
186181
Instant until,
187182
int limit) {
188183
return historyRepository
189-
.findFiltered(
184+
.find(
190185
databaseName,
191186
tableName,
192187
tableUuid,

0 commit comments

Comments
 (0)