Skip to content

Commit f5ab8c2

Browse files
committed
remove unused code
1 parent 2a68423 commit f5ab8c2

File tree

2 files changed

+0
-42
lines changed

2 files changed

+0
-42
lines changed

amoro-ams/src/main/java/org/apache/amoro/server/dashboard/controller/OptimizerController.java

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,6 @@
2525
import org.apache.amoro.resource.ResourceType;
2626
import org.apache.amoro.server.dashboard.response.OkResponse;
2727
import org.apache.amoro.server.manager.AbstractOptimizerContainer;
28-
import org.apache.amoro.server.resource.ContainerMetadata;
2928
import org.apache.amoro.server.resource.Containers;
3029
import org.apache.amoro.server.resource.OptimizerInstance;
3130
import org.apache.amoro.server.resource.OptimizerManager;
@@ -98,13 +97,4 @@ public void createOptimizer(Context ctx) {
9897
optimizerManager.createResource(resource);
9998
ctx.json(OkResponse.of("success to create optimizer"));
10099
}
101-
102-
/** check if optimizerGroup can be deleted url = /optimize/containers/get */
103-
public void getContainers(Context ctx) {
104-
ctx.json(
105-
OkResponse.of(
106-
Containers.getMetadataList().stream()
107-
.map(ContainerMetadata::getName)
108-
.collect(Collectors.toList())));
109-
}
110100
}

amoro-ams/src/main/java/org/apache/amoro/server/dashboard/controller/OptimizerGroupController.java

Lines changed: 0 additions & 32 deletions
Original file line numberDiff line numberDiff line change
@@ -184,38 +184,6 @@ public void getOptimizerGroupInfo(Context ctx) {
184184
ctx.json(OkResponse.of(optimizerResourceInfo));
185185
}
186186

187-
/**
188-
* release optimizer.
189-
*
190-
* @pathParam jobId
191-
*/
192-
public void releaseOptimizer(Context ctx) {
193-
String resourceId = ctx.pathParam("jobId");
194-
Preconditions.checkArgument(
195-
!resourceId.isEmpty(), "resource id can not be empty, maybe it's a external optimizer");
196-
197-
List<OptimizerInstance> optimizerInstances =
198-
optimizerManager.listOptimizers().stream()
199-
.filter(e -> resourceId.equals(e.getResourceId()))
200-
.collect(Collectors.toList());
201-
Preconditions.checkState(
202-
!optimizerInstances.isEmpty(),
203-
String.format(
204-
"The resource ID %s has not been indexed" + " to any optimizer.", resourceId));
205-
Resource resource = optimizerManager.getResource(resourceId);
206-
resource.getProperties().putAll(optimizerInstances.get(0).getProperties());
207-
ResourceContainer rc = Containers.get(resource.getContainerName());
208-
Preconditions.checkState(
209-
rc instanceof AbstractOptimizerContainer,
210-
"Cannot release optimizer on non-optimizer resource container %s.",
211-
resource.getContainerName());
212-
((AbstractOptimizerContainer) rc).releaseResource(resource);
213-
214-
optimizerManager.deleteResource(resourceId);
215-
optimizerManager.deleteOptimizer(resource.getGroupName(), resourceId);
216-
ctx.json(OkResponse.of("Success to release optimizer"));
217-
}
218-
219187
/** scale out optimizers, url:/optimizerGroups/{optimizerGroup}/optimizers. */
220188
public void scaleOutOptimizer(Context ctx) {
221189
String optimizerGroup = ctx.pathParam("optimizerGroup");

0 commit comments

Comments
 (0)