Commit 4c107f1d authored by Daniel Seybold's avatar Daniel Seybold

next fix for getting record count

parent 4a0bb308
Pipeline #55298 passed with stage
in 10 minutes and 20 seconds
...@@ -2,8 +2,10 @@ package de.uulm.omi.dbms.evlautor.server.api.impl; ...@@ -2,8 +2,10 @@ package de.uulm.omi.dbms.evlautor.server.api.impl;
import de.uulm.omi.cloudiator.dbms.evaluator.model.AvailabilityYCSBMultiPhase; import de.uulm.omi.cloudiator.dbms.evaluator.model.AvailabilityYCSBMultiPhase;
import de.uulm.omi.cloudiator.dbms.evaluator.model.AvailabilityYCSBWrite; import de.uulm.omi.cloudiator.dbms.evaluator.model.AvailabilityYCSBWrite;
import de.uulm.omi.cloudiator.dbms.evaluator.model.ClusterContext;
import de.uulm.omi.cloudiator.dbms.evaluator.model.ElasticityYCSBMultiPhase; import de.uulm.omi.cloudiator.dbms.evaluator.model.ElasticityYCSBMultiPhase;
import de.uulm.omi.cloudiator.dbms.evaluator.model.ElasticityYCSBWrite; import de.uulm.omi.cloudiator.dbms.evaluator.model.ElasticityYCSBWrite;
import de.uulm.omi.cloudiator.dbms.evaluator.model.EvaluationContext;
import de.uulm.omi.cloudiator.dbms.evaluator.model.NoiseyNeighbourScenario; import de.uulm.omi.cloudiator.dbms.evaluator.model.NoiseyNeighbourScenario;
import de.uulm.omi.cloudiator.dbms.evaluator.model.PerformanceYCSBMultiPhase; import de.uulm.omi.cloudiator.dbms.evaluator.model.PerformanceYCSBMultiPhase;
import de.uulm.omi.cloudiator.dbms.evaluator.model.PerformanceYCSBWrite; import de.uulm.omi.cloudiator.dbms.evaluator.model.PerformanceYCSBWrite;
...@@ -17,12 +19,12 @@ import de.uulm.omi.evaluation.scenario.AvailabilityYCSBMultiPhaseScenario; ...@@ -17,12 +19,12 @@ import de.uulm.omi.evaluation.scenario.AvailabilityYCSBMultiPhaseScenario;
import de.uulm.omi.evaluation.scenario.AvailabilityYCSBWriteScenario; import de.uulm.omi.evaluation.scenario.AvailabilityYCSBWriteScenario;
import de.uulm.omi.evaluation.scenario.ElasticityYCSBMultiPhaseScenario; import de.uulm.omi.evaluation.scenario.ElasticityYCSBMultiPhaseScenario;
import de.uulm.omi.evaluation.scenario.ElasticityYCSBWriteScenario; import de.uulm.omi.evaluation.scenario.ElasticityYCSBWriteScenario;
import de.uulm.omi.evaluation.scenario.NoiseyNeighbour;
import de.uulm.omi.evaluation.scenario.PerformanceYCSBMultiPhaseScenario; import de.uulm.omi.evaluation.scenario.PerformanceYCSBMultiPhaseScenario;
import de.uulm.omi.evaluation.scenario.PerformanceYCSBWriteScenario; import de.uulm.omi.evaluation.scenario.PerformanceYCSBWriteScenario;
import de.uulm.omi.evaluation.scenario.ScalabilityTPCCScenario; import de.uulm.omi.evaluation.scenario.ScalabilityTPCCScenario;
import de.uulm.omi.evaluation.scenario.ScalabilityYCSBMultiPhaseScenario; import de.uulm.omi.evaluation.scenario.ScalabilityYCSBMultiPhaseScenario;
import de.uulm.omi.evaluation.scenario.ScalabilityYCSBWriteScenario; import de.uulm.omi.evaluation.scenario.ScalabilityYCSBWriteScenario;
import de.uulm.omi.evaluation.task.RemoteCommand;
import javax.validation.constraints.NotNull; import javax.validation.constraints.NotNull;
import javax.ws.rs.core.Response; import javax.ws.rs.core.Response;
import javax.ws.rs.core.SecurityContext; import javax.ws.rs.core.SecurityContext;
...@@ -47,20 +49,20 @@ public class ScenarioApiServiceImpl extends ScenarioApiService { ...@@ -47,20 +49,20 @@ public class ScenarioApiServiceImpl extends ScenarioApiService {
@NotNull Boolean cleanUp, NoiseyNeighbourScenario scenarioSpec, @NotNull Boolean cleanUp, NoiseyNeighbourScenario scenarioSpec,
SecurityContext securityContext) throws NotFoundException { SecurityContext securityContext) throws NotFoundException {
NoiseyNeighbour noiseyNeighbour = new NoiseyNeighbour(scenarioName, runs, scenarioSpec, cleanUp.booleanValue()); //NoiseyNeighbour noiseyNeighbour = new NoiseyNeighbour(scenarioName, runs, scenarioSpec, cleanUp.booleanValue());
noiseyNeighbour.execute(); //noiseyNeighbour.execute();
/*
EvaluationContext evaluationContext = new EvaluationContext(); EvaluationContext evaluationContext = new EvaluationContext();
evaluationContext.setRunCounter(0); evaluationContext.setRunCounter(0);
evaluationContext.setStartTime(System.currentTimeMillis()); evaluationContext.setStartTime(System.currentTimeMillis());
ClusterContext clusterContext = new ClusterContext(); ClusterContext clusterContext = new ClusterContext();
clusterContext.setIdApplicationInstance("1245185"); clusterContext.setIdApplicationInstance("1376257");
RemoteCommand remoteCommand = new RemoteCommand(evaluationContext,clusterContext,"cassandra"); RemoteCommand remoteCommand = new RemoteCommand(evaluationContext,clusterContext,"cassandra");
remoteCommand.call(); remoteCommand.call();
*/
return Response.ok().entity(new ApiResponseMessage(ApiResponseMessage.OK, "Evaluation started!")).build(); return Response.ok().entity(new ApiResponseMessage(ApiResponseMessage.OK, "Evaluation started!")).build();
} }
......
...@@ -146,7 +146,7 @@ public class RemoteCommand extends EvaluationTask { ...@@ -146,7 +146,7 @@ public class RemoteCommand extends EvaluationTask {
/** /**
* Log the total number of records * Log the cluster state
*/ */
logCustomEntry("CLUSTER_STATE",clusterStateResult); logCustomEntry("CLUSTER_STATE",clusterStateResult);
...@@ -238,7 +238,7 @@ public class RemoteCommand extends EvaluationTask { ...@@ -238,7 +238,7 @@ public class RemoteCommand extends EvaluationTask {
/** /**
* limited memory usage * limited memory usage
*/ */
String command = "'java -Xmx512m -jar cassandra-count -host " + host + " -keyspace ycsb -table usertable -splitSize " + splitSize + " -numSplits " + numOfSplits + " -debug 1 2>&1'"; String command = "java -Xmx512m -jar cassandra-count -host " + host + " -keyspace ycsb -table usertable -splitSize " + splitSize + " -numSplits " + numOfSplits ;
return command; return command;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment