You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@asterixdb.apache.org by im...@apache.org on 2017/11/30 04:55:57 UTC
[12/14] asterixdb git commit: [NO ISSUE] Delete asterix-experiments
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/AbstractSpatialIndexExperiment2Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/AbstractSpatialIndexExperiment2Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/AbstractSpatialIndexExperiment2Builder.java
deleted file mode 100644
index 848ab7c..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/AbstractSpatialIndexExperiment2Builder.java
+++ /dev/null
@@ -1,173 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import java.util.List;
-import java.util.Map;
-import java.util.Random;
-
-import org.apache.asterix.experiment.action.base.AbstractAction;
-import org.apache.asterix.experiment.action.base.ParallelActionSet;
-import org.apache.asterix.experiment.action.base.SequentialActionList;
-import org.apache.asterix.experiment.action.derived.AbstractRemoteExecutableAction;
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-import org.apache.asterix.experiment.client.SpatialIndexExperiment2OrchestratorServer;
-import org.apache.commons.lang3.StringUtils;
-
-public abstract class AbstractSpatialIndexExperiment2Builder extends AbstractLSMBaseExperimentBuilder {
-
- private static final long DOMAIN_SIZE = (1L << 32);
-
- public static final long QUERY_BEGIN_ROUND = 6;
-
- private static int N_PARTITIONS = 16;
-
- private final int nIntervals;
-
- private final String dataGenOrchHost;
-
- private final int dataGenOrchPort;
-
- private final String queryGenOrchHost;
-
- private final int queryGenOrchPort;
-
- private final long queryGenDuration;
-
- protected final long dataInterval;
-
- protected final int nQueryRuns;
-
- protected final Random randGen;
-
- protected final boolean isIndexOnlyPlan;
-
- public AbstractSpatialIndexExperiment2Builder(String name, LSMExperimentSetRunnerConfig config,
- String clusterConfigFileName, String ingestFileName, String dgenFileName, boolean isIndexOnlyPlan) {
- super(name, config, clusterConfigFileName, ingestFileName, dgenFileName, null);
- nIntervals = config.getNIntervals();
- dataGenOrchHost = config.getOrchestratorHost();
- dataGenOrchPort = config.getOrchestratorPort();
- dataInterval = config.getDataInterval();
- queryGenOrchHost = config.getQueryOrchestratorHost();
- queryGenOrchPort = config.getQueryOrchestratorPort();
- queryGenDuration = config.getQueryDuration();
- this.nQueryRuns = config.getNQueryRuns();
- this.randGen = new Random();
- this.isIndexOnlyPlan = isIndexOnlyPlan;
- }
-
- @Override
- protected void doBuildDataGen(SequentialActionList seq, Map<String, List<String>> dgenPairs) throws Exception {
- int nDgens = 0;
- for (List<String> v : dgenPairs.values()) {
- nDgens += v.size();
- }
- final SpatialIndexExperiment2OrchestratorServer oServer = new SpatialIndexExperiment2OrchestratorServer(
- dataGenOrchPort, nDgens, nIntervals, queryGenOrchPort, nDgens /*for now, query gen uses the same node as data gen*/);
-
- seq.add(new AbstractAction() {
-
- @Override
- protected void doPerform() throws Exception {
- oServer.start();
- }
- });
-
- //prepare data gen runner and query gen runner
- //note that dgenPairs.keySet() are used as query gen runners' ip address.
- ParallelActionSet dataAndQueryGenActions = new ParallelActionSet();
- int partition = 0;
- for (String dgenHost : dgenPairs.keySet()) {
- final List<String> rcvrs = dgenPairs.get(dgenHost);
- final int p = partition;
- //prepare data gen
- dataAndQueryGenActions.add(new AbstractRemoteExecutableAction(dgenHost, username, sshKeyLocation) {
-
- @Override
- protected String getCommand() {
- String ipPortPairs = StringUtils.join(rcvrs.iterator(), " ");
- String binary = "JAVA_HOME=" + javaHomePath + " "
- + localExperimentRoot.resolve("bin").resolve("datagenrunner").toString();
- if (openStreetMapFilePath == null) {
- return StringUtils.join(new String[] { binary, "-rcbi",
- "" + recordCountPerBatchDuringIngestionOnly, "-rcbq",
- "" + recordCountPerBatchDuringQuery, "-dsti", "" + dataGenSleepTimeDuringIngestionOnly,
- "-dstq", "" + dataGenSleepTimeDuringQuery, "-si", "" + locationSampleInterval, "-p",
- "" + p, "-di", "" + dataInterval, "-ni", "" + nIntervals, "-qd", "" + queryGenDuration,
- "-oh", dataGenOrchHost, "-op", "" + dataGenOrchPort, ipPortPairs }, " ");
- } else {
- return StringUtils.join(new String[] { binary, "-rcbi",
- "" + recordCountPerBatchDuringIngestionOnly, "-rcbq",
- "" + recordCountPerBatchDuringQuery, "-dsti", "" + dataGenSleepTimeDuringIngestionOnly,
- "-dstq", "" + dataGenSleepTimeDuringQuery, "-si", "" + locationSampleInterval, "-of",
- openStreetMapFilePath, "-p", "" + p, "-di", "" + dataInterval, "-ni", "" + nIntervals,
- "-qd", "" + queryGenDuration, "-oh", dataGenOrchHost, "-op", "" + dataGenOrchPort,
- ipPortPairs }, " ");
- }
- }
- });
-
- //prepare query gen
- dataAndQueryGenActions.add(new AbstractRemoteExecutableAction(dgenHost, username, sshKeyLocation) {
-
- @Override
- protected String getCommand() {
- String ipPortPairs = StringUtils.join(rcvrs.iterator(), " ");
- String binary = "JAVA_HOME=" + javaHomePath + " "
- + localExperimentRoot.resolve("bin").resolve("querygenrunner").toString();
- if (openStreetMapFilePath == null) {
- if (isIndexOnlyPlan) {
- return StringUtils.join(new String[] { binary, "-iop", "-p", "" + p, "-qd",
- "" + queryGenDuration, "-qoh", "" + queryGenOrchHost, "-qop",
- "" + queryGenOrchPort, "-rh", restHost, "-rp", "" + restPort }, " ");
- } else {
- return StringUtils.join(new String[] { binary, "-p", "" + p, "-qd", "" + queryGenDuration,
- "-qoh", "" + queryGenOrchHost, "-qop", "" + queryGenOrchPort, "-rh", restHost,
- "-rp", "" + restPort }, " ");
- }
- } else {
- if (isIndexOnlyPlan) {
- return StringUtils.join(new String[] { binary, "-iop", "-of", openStreetMapFilePath, "-p",
- "" + p, "-qd", "" + queryGenDuration, "-qoh", "" + queryGenOrchHost, "-qop",
- "" + queryGenOrchPort, "-rh", restHost, "-rp", "" + restPort }, " ");
- } else {
- return StringUtils.join(new String[] { binary, "-of", openStreetMapFilePath, "-p", "" + p,
- "-qd", "" + queryGenDuration, "-qoh", "" + queryGenOrchHost, "-qop",
- "" + queryGenOrchPort, "-rh", restHost, "-rp", "" + restPort }, " ");
- }
- }
- }
- });
-
- partition += rcvrs.size();
- }
- seq.add(dataAndQueryGenActions);
-
- // wait until all dgen / queries are done
- seq.add(new AbstractAction() {
-
- @Override
- protected void doPerform() throws Exception {
- oServer.awaitFinished();
- }
- });
- }
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/AbstractSpatialIndexExperiment3PIdxLoadBuilder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/AbstractSpatialIndexExperiment3PIdxLoadBuilder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/AbstractSpatialIndexExperiment3PIdxLoadBuilder.java
deleted file mode 100644
index 6de1c73..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/AbstractSpatialIndexExperiment3PIdxLoadBuilder.java
+++ /dev/null
@@ -1,293 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import java.io.File;
-import java.io.IOException;
-import java.nio.charset.StandardCharsets;
-import java.nio.file.Path;
-import java.nio.file.Paths;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Scanner;
-import java.util.Set;
-
-import javax.xml.bind.JAXBContext;
-import javax.xml.bind.Unmarshaller;
-
-import org.apache.asterix.event.schema.cluster.Cluster;
-import org.apache.asterix.experiment.action.base.ParallelActionSet;
-import org.apache.asterix.experiment.action.base.SequentialActionList;
-import org.apache.asterix.experiment.action.derived.AbstractRemoteExecutableAction;
-import org.apache.asterix.experiment.action.derived.ManagixActions.CreateAsterixManagixAction;
-import org.apache.asterix.experiment.action.derived.ManagixActions.DeleteAsterixManagixAction;
-import org.apache.asterix.experiment.action.derived.ManagixActions.LogAsterixManagixAction;
-import org.apache.asterix.experiment.action.derived.ManagixActions.StopAsterixManagixAction;
-import org.apache.asterix.experiment.action.derived.RemoteAsterixDriverKill;
-import org.apache.asterix.experiment.action.derived.RunAQLFileAction;
-import org.apache.asterix.experiment.action.derived.SleepAction;
-import org.apache.asterix.experiment.action.derived.TimedAction;
-import org.apache.asterix.experiment.client.LSMExperimentConstants;
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-import org.apache.http.client.HttpClient;
-import org.apache.http.impl.client.DefaultHttpClient;
-
-/**
- * This class is used to create experiments for spatial index static data evaluation, that is, no ingestion is involved.
- * Also, there is no orchestration server involved in this experiment builder.
- */
-public abstract class AbstractSpatialIndexExperiment3PIdxLoadBuilder extends AbstractExperimentBuilder {
-
- private static final String ASTERIX_INSTANCE_NAME = "a1";
-
- private final String logDirSuffix;
-
- protected final HttpClient httpClient;
-
- protected final String restHost;
-
- protected final int restPort;
-
- private final String managixHomePath;
-
- protected final String javaHomePath;
-
- protected final Path localExperimentRoot;
-
- protected final String username;
-
- protected final String sshKeyLocation;
-
- private final int duration;
-
- private final String clusterConfigFileName;
-
- private final String ingestFileName;
-
- protected final String dgenFileName;
-
- private final String countFileName;
-
- private final String statFile;
-
- protected final SequentialActionList lsAction;
-
- protected final String openStreetMapFilePath;
-
- protected final int locationSampleInterval;
-
- protected final String loadAQLFilePath;
-
- public AbstractSpatialIndexExperiment3PIdxLoadBuilder(String name, LSMExperimentSetRunnerConfig config,
- String clusterConfigFileName, String ingestFileName, String dgenFileName, String countFileName,
- String loadAQLFileName) {
- super(name);
- this.logDirSuffix = config.getLogDirSuffix();
- this.httpClient = new DefaultHttpClient();
- this.restHost = config.getRESTHost();
- this.restPort = config.getRESTPort();
- this.managixHomePath = config.getManagixHome();
- this.javaHomePath = config.getJavaHome();
- this.localExperimentRoot = Paths.get(config.getLocalExperimentRoot());
- this.username = config.getUsername();
- this.sshKeyLocation = config.getSSHKeyLocation();
- this.duration = config.getDuration();
- this.clusterConfigFileName = clusterConfigFileName;
- this.ingestFileName = ingestFileName;
- this.dgenFileName = dgenFileName;
- this.countFileName = countFileName;
- this.statFile = config.getStatFile();
- this.lsAction = new SequentialActionList();
- this.openStreetMapFilePath = config.getOpenStreetMapFilePath();
- this.locationSampleInterval = config.getLocationSampleInterval();
- this.loadAQLFilePath = loadAQLFileName;
- }
-
- protected abstract void doBuildDDL(SequentialActionList seq);
-
- protected void doPost(SequentialActionList seq) {
- }
-
- protected void doBuildDataGen(SequentialActionList seq, final Map<String, List<String>> dgenPairs) throws Exception {
- }
-
- @Override
- protected void doBuild(Experiment e) throws Exception {
- SequentialActionList execs = new SequentialActionList();
-
- String clusterConfigPath = localExperimentRoot.resolve(LSMExperimentConstants.CONFIG_DIR)
- .resolve(clusterConfigFileName).toString();
- String asterixConfigPath = localExperimentRoot.resolve(LSMExperimentConstants.CONFIG_DIR)
- .resolve(LSMExperimentConstants.ASTERIX_CONFIGURATION).toString();
-
- //stop/delete/create instance
- execs.add(new StopAsterixManagixAction(managixHomePath, ASTERIX_INSTANCE_NAME));
- execs.add(new DeleteAsterixManagixAction(managixHomePath, ASTERIX_INSTANCE_NAME));
- execs.add(new SleepAction(30000));
- execs.add(new CreateAsterixManagixAction(managixHomePath, ASTERIX_INSTANCE_NAME, clusterConfigPath,
- asterixConfigPath));
-
- //ddl statements
- execs.add(new SleepAction(15000));
- // TODO: implement retry handler
- execs.add(new RunAQLFileAction(httpClient, restHost, restPort, localExperimentRoot.resolve(
- LSMExperimentConstants.AQL_DIR).resolve(LSMExperimentConstants.BASE_TYPES)));
- doBuildDDL(execs);
-
- //prepare io state action in NC node(s)
- Map<String, List<String>> dgenPairs = readDatagenPairs(localExperimentRoot.resolve(
- LSMExperimentConstants.DGEN_DIR).resolve(dgenFileName));
- final Set<String> ncHosts = new HashSet<>();
- for (List<String> ncHostList : dgenPairs.values()) {
- for (String ncHost : ncHostList) {
- ncHosts.add(ncHost.split(":")[0]);
- }
- }
- if (statFile != null) {
- ParallelActionSet ioCountActions = new ParallelActionSet();
- for (String ncHost : ncHosts) {
- ioCountActions.add(new AbstractRemoteExecutableAction(ncHost, username, sshKeyLocation) {
-
- @Override
- protected String getCommand() {
- String cmd = "screen -d -m sh -c \"sar -b -u 1 > " + statFile + "\"";
- return cmd;
- }
- });
- }
- execs.add(ioCountActions);
- }
-
- //prepare post ls action
- SequentialActionList postLSAction = new SequentialActionList();
- File file = new File(clusterConfigPath);
- JAXBContext ctx = JAXBContext.newInstance(Cluster.class);
- Unmarshaller unmarshaller = ctx.createUnmarshaller();
- final Cluster cluster = (Cluster) unmarshaller.unmarshal(file);
- String[] storageRoots = cluster.getIodevices().split(",");
- for (String ncHost : ncHosts) {
- for (final String sRoot : storageRoots) {
- lsAction.add(new AbstractRemoteExecutableAction(ncHost, username, sshKeyLocation) {
- @Override
- protected String getCommand() {
- return "ls -Rl " + sRoot;
- }
- });
- postLSAction.add(new AbstractRemoteExecutableAction(ncHost, username, sshKeyLocation) {
- @Override
- protected String getCommand() {
- return "ls -Rl " + sRoot;
- }
- });
-
- }
- }
-
- //---------- main experiment body begins -----------
-
- //load data into pidx
- execs.add(new TimedAction(new RunAQLFileAction(httpClient, restHost, restPort, localExperimentRoot.resolve(
- LSMExperimentConstants.AQL_DIR).resolve(loadAQLFilePath))));
-
- //---------- main experiment body ends -----------
-
- //kill io state action
- if (statFile != null) {
- ParallelActionSet ioCountKillActions = new ParallelActionSet();
- for (String ncHost : ncHosts) {
- ioCountKillActions.add(new AbstractRemoteExecutableAction(ncHost, username, sshKeyLocation) {
-
- @Override
- protected String getCommand() {
- String cmd = "screen -X -S `screen -list | grep Detached | awk '{print $1}'` quit";
- return cmd;
- }
- });
- }
- execs.add(ioCountKillActions);
- }
-
- //total record count
- execs.add(new SleepAction(10000));
- if (countFileName != null) {
- execs.add(new RunAQLFileAction(httpClient, restHost, restPort, localExperimentRoot.resolve(
- LSMExperimentConstants.AQL_DIR).resolve(countFileName)));
- }
-
- //add ls action
- execs.add(postLSAction);
-
- //kill asterix cc and nc
- ParallelActionSet killCmds = new ParallelActionSet();
- for (String ncHost : ncHosts) {
- killCmds.add(new RemoteAsterixDriverKill(ncHost, username, sshKeyLocation));
- }
- killCmds.add(new RemoteAsterixDriverKill(restHost, username, sshKeyLocation));
- execs.add(killCmds);
-
- //stop asterix instance
- execs.add(new StopAsterixManagixAction(managixHomePath, ASTERIX_INSTANCE_NAME));
-
- //prepare to collect io state by putting the state file into asterix log dir
- if (statFile != null) {
- ParallelActionSet collectIOActions = new ParallelActionSet();
- for (String ncHost : ncHosts) {
- collectIOActions.add(new AbstractRemoteExecutableAction(ncHost, username, sshKeyLocation) {
-
- @Override
- protected String getCommand() {
- String cmd = "cp " + statFile + " " + cluster.getLogDir();
- return cmd;
- }
- });
- }
- execs.add(collectIOActions);
- }
-
- //collect cc and nc logs
- execs.add(new LogAsterixManagixAction(managixHomePath, ASTERIX_INSTANCE_NAME, localExperimentRoot
- .resolve(LSMExperimentConstants.LOG_DIR + "-" + logDirSuffix).resolve(getName()).toString()));
-
- e.addBody(execs);
- }
-
- protected Map<String, List<String>> readDatagenPairs(Path p) throws IOException {
- Map<String, List<String>> dgenPairs = new HashMap<>();
- Scanner s = new Scanner(p, StandardCharsets.UTF_8.name());
- try {
- while (s.hasNextLine()) {
- String line = s.nextLine();
- String[] pair = line.split("\\s+");
- List<String> vals = dgenPairs.get(pair[0]);
- if (vals == null) {
- vals = new ArrayList<>();
- dgenPairs.put(pair[0], vals);
- }
- vals.add(pair[1]);
- }
- } finally {
- s.close();
- }
- return dgenPairs;
- }
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/AbstractSpatialIndexExperiment3SIdxCreateAndQueryBuilder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/AbstractSpatialIndexExperiment3SIdxCreateAndQueryBuilder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/AbstractSpatialIndexExperiment3SIdxCreateAndQueryBuilder.java
deleted file mode 100644
index 9720346..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/AbstractSpatialIndexExperiment3SIdxCreateAndQueryBuilder.java
+++ /dev/null
@@ -1,532 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import java.io.BufferedReader;
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.FileReader;
-import java.io.IOException;
-import java.net.Inet4Address;
-import java.nio.charset.StandardCharsets;
-import java.nio.file.Path;
-import java.nio.file.Paths;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Random;
-import java.util.Scanner;
-import java.util.Set;
-
-import javax.xml.bind.JAXBContext;
-import javax.xml.bind.Unmarshaller;
-
-import org.apache.asterix.event.schema.cluster.Cluster;
-import org.apache.asterix.experiment.action.base.IAction;
-import org.apache.asterix.experiment.action.base.ParallelActionSet;
-import org.apache.asterix.experiment.action.base.SequentialActionList;
-import org.apache.asterix.experiment.action.derived.AbstractRemoteExecutableAction;
-import org.apache.asterix.experiment.action.derived.CloseOutputStreamAction;
-import org.apache.asterix.experiment.action.derived.ManagixActions.LogAsterixManagixAction;
-import org.apache.asterix.experiment.action.derived.ManagixActions.StartAsterixManagixAction;
-import org.apache.asterix.experiment.action.derived.ManagixActions.StopAsterixManagixAction;
-import org.apache.asterix.experiment.action.derived.RemoteAsterixDriverKill;
-import org.apache.asterix.experiment.action.derived.RunAQLFileAction;
-import org.apache.asterix.experiment.action.derived.RunAQLStringAction;
-import org.apache.asterix.experiment.action.derived.SleepAction;
-import org.apache.asterix.experiment.action.derived.TimedAction;
-import org.apache.asterix.experiment.client.LSMExperimentConstants;
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-import org.apache.http.client.HttpClient;
-import org.apache.http.impl.client.DefaultHttpClient;
-import org.apache.hyracks.api.util.ExperimentProfilerUtils;
-
-/**
- * This class is used to create experiments for spatial index static data evaluation, that is, no ingestion is involved.
- * Also, there is no orchestration server involved in this experiment builder.
- */
-public abstract class AbstractSpatialIndexExperiment3SIdxCreateAndQueryBuilder extends AbstractExperimentBuilder {
-
- private static final boolean PROFILE_JOB_LAUCHING_OVERHEAD = false;
-
- private static final String ASTERIX_INSTANCE_NAME = "a1";
- private static final int SKIP_LINE_COUNT = 223;
- private static final int CACHE_WARM_UP_QUERY_COUNT = 500;
- private static final int SELECT_QUERY_COUNT = 5000;
- private static final int JOIN_QUERY_COUNT = 1000;
-
- private static final int JOIN_CANDIDATE_COUNT = 100;
- private static final int MAX_QUERY_SEED = 10000;
-
- private int querySeed = 0;
-
- private int queryCount = 0;
-
- private final String logDirSuffix;
-
- protected final HttpClient httpClient;
-
- protected final String restHost;
-
- protected final int restPort;
-
- private final String managixHomePath;
-
- protected final String javaHomePath;
-
- protected final Path localExperimentRoot;
-
- protected final String username;
-
- protected final String sshKeyLocation;
-
- private final int duration;
-
- private final String clusterConfigFileName;
-
- private final String ingestFileName;
-
- protected final String dgenFileName;
-
- private final String countFileName;
-
- private final String statFile;
-
- protected final SequentialActionList lsAction;
-
- protected final String openStreetMapFilePath;
-
- protected final int locationSampleInterval;
-
- protected final String createAQLFilePath;
-
- protected final String querySeedFilePath;
-
- private final float[] radiusType = new float[] { 0.00001f, 0.0001f, 0.001f, 0.01f, 0.1f };
- private int radiusIter = 0;
- private final Random randGen;
- private BufferedReader br;
- private final boolean isIndexOnlyPlan;
- private String outputFilePath;
- private FileOutputStream outputFos;
-
- public AbstractSpatialIndexExperiment3SIdxCreateAndQueryBuilder(String name, LSMExperimentSetRunnerConfig config,
- String clusterConfigFileName, String ingestFileName, String dgenFileName, String countFileName,
- String createAQLFileName, boolean isIndexOnlyPlan) {
- super(name);
- this.logDirSuffix = config.getLogDirSuffix();
- this.httpClient = new DefaultHttpClient();
- this.restHost = config.getRESTHost();
- this.restPort = config.getRESTPort();
- this.managixHomePath = config.getManagixHome();
- this.javaHomePath = config.getJavaHome();
- this.localExperimentRoot = Paths.get(config.getLocalExperimentRoot());
- this.username = config.getUsername();
- this.sshKeyLocation = config.getSSHKeyLocation();
- this.duration = config.getDuration();
- this.clusterConfigFileName = clusterConfigFileName;
- this.ingestFileName = ingestFileName;
- this.dgenFileName = dgenFileName;
- this.countFileName = countFileName;
- this.statFile = config.getStatFile();
- this.lsAction = new SequentialActionList();
- this.openStreetMapFilePath = config.getOpenStreetMapFilePath();
- this.locationSampleInterval = config.getLocationSampleInterval();
- this.createAQLFilePath = createAQLFileName;
- this.querySeedFilePath = config.getQuerySeedFilePath();
- this.randGen = new Random();
- this.isIndexOnlyPlan = isIndexOnlyPlan;
- }
-
- protected void doPost(SequentialActionList seq) {
- }
-
- protected void doBuildDataGen(SequentialActionList seq, final Map<String, List<String>> dgenPairs) throws Exception {
- }
-
- @Override
- protected void doBuild(Experiment e) throws Exception {
- SequentialActionList execs = new SequentialActionList();
-
- String clusterConfigPath = localExperimentRoot.resolve(LSMExperimentConstants.CONFIG_DIR)
- .resolve(clusterConfigFileName).toString();
- String asterixConfigPath = localExperimentRoot.resolve(LSMExperimentConstants.CONFIG_DIR)
- .resolve(LSMExperimentConstants.ASTERIX_CONFIGURATION).toString();
-
- //start asterix instance
- execs.add(new StartAsterixManagixAction(managixHomePath, ASTERIX_INSTANCE_NAME));
- execs.add(new SleepAction(30000));
-
- //prepare io state action in NC node(s)
- Map<String, List<String>> dgenPairs = readDatagenPairs(localExperimentRoot.resolve(
- LSMExperimentConstants.DGEN_DIR).resolve(dgenFileName));
- final Set<String> ncHosts = new HashSet<>();
- for (List<String> ncHostList : dgenPairs.values()) {
- for (String ncHost : ncHostList) {
- ncHosts.add(ncHost.split(":")[0]);
- }
- }
- if (statFile != null) {
- ParallelActionSet ioCountActions = new ParallelActionSet();
- for (String ncHost : ncHosts) {
- ioCountActions.add(new AbstractRemoteExecutableAction(ncHost, username, sshKeyLocation) {
-
- @Override
- protected String getCommand() {
- String cmd = "screen -d -m sh -c \"sar -b -u 1 > " + statFile + "\"";
- return cmd;
- }
- });
- }
- execs.add(ioCountActions);
- }
-
- //prepare post ls action
- SequentialActionList postLSAction = new SequentialActionList();
- File file = new File(clusterConfigPath);
- JAXBContext ctx = JAXBContext.newInstance(Cluster.class);
- Unmarshaller unmarshaller = ctx.createUnmarshaller();
- final Cluster cluster = (Cluster) unmarshaller.unmarshal(file);
- String[] storageRoots = cluster.getIodevices().split(",");
- for (String ncHost : ncHosts) {
- for (final String sRoot : storageRoots) {
- lsAction.add(new AbstractRemoteExecutableAction(ncHost, username, sshKeyLocation) {
- @Override
- protected String getCommand() {
- return "ls -Rl " + sRoot;
- }
- });
- postLSAction.add(new AbstractRemoteExecutableAction(ncHost, username, sshKeyLocation) {
- @Override
- protected String getCommand() {
- return "ls -Rl " + sRoot;
- }
- });
-
- }
- }
-
- //---------- main experiment body begins -----------
-
- try {
- outputFilePath = openStreetMapFilePath.substring(0, openStreetMapFilePath.lastIndexOf(File.separator))
- + File.separator + "QueryGenResult-" + getName() + "-"
- + Inet4Address.getLocalHost().getHostAddress() + ".txt";
- outputFos = ExperimentProfilerUtils.openOutputFile(outputFilePath);
- } catch (Exception e1) {
- e1.printStackTrace();
- return;
- }
-
- //delete all existing secondary indexes if any
- execs.add(new RunAQLStringAction(httpClient, restHost, restPort,
- "use dataverse experiments; drop index Tweets.dhbtreeLocation;", outputFos));
- execs.add(new RunAQLStringAction(httpClient, restHost, restPort,
- "use dataverse experiments; drop index Tweets.dhvbtreeLocation;", outputFos));
- execs.add(new RunAQLStringAction(httpClient, restHost, restPort,
- "use dataverse experiments; drop index Tweets.rtreeLocation;", outputFos));
- execs.add(new RunAQLStringAction(httpClient, restHost, restPort,
- "use dataverse experiments; drop index Tweets.shbtreeLocation;", outputFos));
- execs.add(new RunAQLStringAction(httpClient, restHost, restPort,
- "use dataverse experiments; drop index Tweets.sifLocation;", outputFos));
-
- //create secondary index
- execs.add(new TimedAction(new RunAQLFileAction(httpClient, restHost, restPort, localExperimentRoot.resolve(
- LSMExperimentConstants.AQL_DIR).resolve(createAQLFilePath), outputFos), outputFos));
-
- //run count query for cleaning up OS buffer cache
- if (countFileName != null) {
- execs.add(new RunAQLFileAction(httpClient, restHost, restPort, localExperimentRoot.resolve(
- LSMExperimentConstants.AQL_DIR).resolve(countFileName), outputFos));
- }
-
- //run cache warm-up queries: run CACHE_WARM_UP_QUERY_COUNT select queries
- br = new BufferedReader(new FileReader(querySeedFilePath));
- radiusIter = 0;
- for (int i = 0; i < CACHE_WARM_UP_QUERY_COUNT; i++) {
- execs.add(getSelectQuery(isIndexOnlyPlan));
- }
-
- radiusIter = 0;
- //run queries for measurement: run SELECT_QUERY_COUNT select queries
- for (int i = 0; i < SELECT_QUERY_COUNT; i++) {
- execs.add(getSelectQuery(isIndexOnlyPlan));
- }
-
- radiusIter = 0;
- //run queries for measurement: run JOIN_QUERY_COUNT join queries
- for (int i = 0; i < JOIN_QUERY_COUNT; i++) {
- execs.add(getJoinQuery(isIndexOnlyPlan));
- }
-
- //---------- main experiment body ends -----------
-
- //kill io state action
- // if (statFile != null) {
- // ParallelActionSet ioCountKillActions = new ParallelActionSet();
- // for (String ncHost : ncHosts) {
- // ioCountKillActions.add(new AbstractRemoteExecutableAction(ncHost, username, sshKeyLocation) {
- //
- // @Override
- // protected String getCommand() {
- // String cmd = "screen -X -S `screen -list | grep Detached | awk '{print $1}'` quit";
- // return cmd;
- // }
- // });
- // }
- // execs.add(ioCountKillActions);
- // }
-
- //add ls action
- execs.add(postLSAction);
-
- //kill asterix cc and nc
- ParallelActionSet killCmds = new ParallelActionSet();
- for (String ncHost : ncHosts) {
- killCmds.add(new RemoteAsterixDriverKill(ncHost, username, sshKeyLocation));
- }
- killCmds.add(new RemoteAsterixDriverKill(restHost, username, sshKeyLocation));
- execs.add(killCmds);
-
- //stop asterix instance
- execs.add(new StopAsterixManagixAction(managixHomePath, ASTERIX_INSTANCE_NAME));
-
- //prepare to collect io state by putting the state file into asterix log dir
- if (statFile != null) {
- ParallelActionSet collectIOActions = new ParallelActionSet();
- for (String ncHost : ncHosts) {
- collectIOActions.add(new AbstractRemoteExecutableAction(ncHost, username, sshKeyLocation) {
-
- @Override
- protected String getCommand() {
- String cmd = "cp " + statFile + " " + cluster.getLogDir();
- return cmd;
- }
- });
- }
- execs.add(collectIOActions);
- }
-
- //collect profile information
- // if (ExperimentProfiler.PROFILE_MODE) {
- // if (!SpatialIndexProfiler.PROFILE_HOME_DIR.contentEquals(cluster.getLogDir())) {
- // ParallelActionSet collectProfileInfo = new ParallelActionSet();
- // for (String ncHost : ncHosts) {
- // collectProfileInfo.add(new AbstractRemoteExecutableAction(ncHost, username, sshKeyLocation) {
- // @Override
- // protected String getCommand() {
- // String cmd = "mv " + SpatialIndexProfiler.PROFILE_HOME_DIR + "*.txt " + cluster.getLogDir();
- // return cmd;
- // }
- // });
- // }
- // execs.add(collectProfileInfo);
- // }
- // }
-
- //collect cc and nc logs
- execs.add(new LogAsterixManagixAction(managixHomePath, ASTERIX_INSTANCE_NAME, localExperimentRoot
- .resolve(LSMExperimentConstants.LOG_DIR + "-" + logDirSuffix).resolve(getName()).toString()));
-
- //get query result file
- final String queryResultFilePath = outputFilePath;
- execs.add(new AbstractRemoteExecutableAction(restHost, username, sshKeyLocation) {
- @Override
- protected String getCommand() {
- String cmd = "mv "
- + queryResultFilePath
- + " "
- + localExperimentRoot.resolve(LSMExperimentConstants.LOG_DIR + "-" + logDirSuffix)
- .resolve(getName()).toString();
- return cmd;
- }
- });
- //close the outputStream
- execs.add(new CloseOutputStreamAction(outputFos));
-
- e.addBody(execs);
- }
-
- protected Map<String, List<String>> readDatagenPairs(Path p) throws IOException {
- Map<String, List<String>> dgenPairs = new HashMap<>();
- Scanner s = new Scanner(p, StandardCharsets.UTF_8.name());
- try {
- while (s.hasNextLine()) {
- String line = s.nextLine();
- String[] pair = line.split("\\s+");
- List<String> vals = dgenPairs.get(pair[0]);
- if (vals == null) {
- vals = new ArrayList<>();
- dgenPairs.put(pair[0], vals);
- }
- vals.add(pair[1]);
- }
- } finally {
- s.close();
- }
- return dgenPairs;
- }
-
- private SequentialActionList getSelectQuery(boolean isIndexOnlyPlan) throws IOException {
- //prepare radius and center point
- int skipLineCount = SKIP_LINE_COUNT;
- int lineCount = 0;
- String line = null;;
-
- querySeed += SKIP_LINE_COUNT;
- if (querySeed > MAX_QUERY_SEED) {
- querySeed -= MAX_QUERY_SEED;
- }
-
- while (lineCount < skipLineCount) {
- if ((line = br.readLine()) == null) {
- //reopen file
- br.close();
- br = new BufferedReader(new FileReader(querySeedFilePath));
- line = br.readLine();
- }
- lineCount++;
- }
-
- int beginIdx = line.indexOf("(", line.indexOf("point"));
- int endIdx = line.indexOf(")", line.indexOf("point")) + 1;
- String point = line.substring(beginIdx, endIdx);
-
- //create action
- SequentialActionList sAction = new SequentialActionList();
- IAction queryAction = new TimedAction(new RunAQLStringAction(httpClient, restHost, restPort, getSelectQueryAQL(
- radiusType[radiusIter++ % radiusType.length], point, isIndexOnlyPlan), outputFos), outputFos);
- sAction.add(queryAction);
-
- return sAction;
- }
-
- private String getSelectQueryAQL(float radius, String point, boolean isIndexOnlyPlan) {
- if (PROFILE_JOB_LAUCHING_OVERHEAD) {
- Random random = new Random();
- int btreeExtraFieldKey = random.nextInt();
- int rangeSize = (int) (radius * 100000000L);
- if (btreeExtraFieldKey == Integer.MIN_VALUE) {
- btreeExtraFieldKey = Integer.MIN_VALUE + 1;
- }
- if (btreeExtraFieldKey + rangeSize >= Integer.MAX_VALUE) {
- btreeExtraFieldKey = Integer.MAX_VALUE - rangeSize - 1;
- }
-
- StringBuilder sb = new StringBuilder();
- sb.append("use dataverse experiments; ");
- sb.append("count( ");
- sb.append("for $x in dataset Tweets").append(" ");
- sb.append("where $x.btree-extra-field1 > int32(\"" + btreeExtraFieldKey
- + "\") and $x.btree-extra-field1 < int32(\"" + (btreeExtraFieldKey + rangeSize) + "\")");
- sb.append("return $x ");
- sb.append(");");
-
- System.out.println("[squery" + (queryCount++) + "]" + sb.toString());
-
- return sb.toString();
- } else {
- StringBuilder sb = new StringBuilder();
- sb.append("use dataverse experiments; ");
- sb.append("count( ");
- sb.append("for $x in dataset Tweets").append(" ");
- sb.append("let $n := create-circle( ");
- sb.append("point").append(point).append(" ");
- sb.append(", ");
- sb.append(String.format("%f", radius));
- sb.append(" ) ");
- if (isIndexOnlyPlan) {
- sb.append("where spatial-intersect($x.sender-location, $n) ");
- } else {
- sb.append("where spatial-intersect($x.sender-location, $n) and $x.btree-extra-field1 <= int32(\"2147483647\") ");
- }
- sb.append("return $x ");
- sb.append(");");
-
- System.out.println("[squery" + (queryCount++) + "]" + sb.toString());
-
- return sb.toString();
- }
- }
-
- private SequentialActionList getJoinQuery(boolean isIndexOnlyPlan) {
- querySeed += SKIP_LINE_COUNT;
- if (querySeed > MAX_QUERY_SEED) {
- querySeed -= MAX_QUERY_SEED;
- }
-
- int lowId = querySeed * 10000 + 1;
- int highId = (querySeed + JOIN_CANDIDATE_COUNT) * 10000 + 1;
-
- //create action
- SequentialActionList sAction = new SequentialActionList();
- IAction queryAction = new TimedAction(new RunAQLStringAction(httpClient, restHost, restPort, getJoinQueryAQL(
- radiusType[radiusIter++ % (radiusType.length - 1)], lowId, highId, isIndexOnlyPlan), outputFos),
- outputFos);
- sAction.add(queryAction);
-
- return sAction;
- }
-
- private String getJoinQueryAQL(float radius, int lowId, int highId, boolean isIndexOnlyPlan) {
- if (PROFILE_JOB_LAUCHING_OVERHEAD) {
- Random random = new Random();
- int btreeExtraFieldKey = random.nextInt();
- if (btreeExtraFieldKey == Integer.MIN_VALUE) {
- btreeExtraFieldKey = Integer.MIN_VALUE + 1;
- }
-
- StringBuilder sb = new StringBuilder();
- sb.append("use dataverse experiments; ");
- sb.append("count( ");
- sb.append("for $x in dataset Tweets").append(" ");
- sb.append("where $x.tweetid = int64(\"" + btreeExtraFieldKey + "\")");
- sb.append("return $x ");
- sb.append(");");
-
- System.out.println("[squery" + (queryCount++) + "]" + sb.toString());
-
- return sb.toString();
- } else {
- StringBuilder sb = new StringBuilder();
- sb.append(" use dataverse experiments; \n");
- sb.append(" count( \n");
- sb.append(" for $x in dataset JoinSeedTweets").append(" \n");
- sb.append(" let $area := create-circle($x.sender-location, ").append(String.format("%f", radius))
- .append(" ) \n");
- sb.append(" for $y in dataset Tweets \n");
- sb.append(" where $x.tweetid >= int64(\"" + lowId + "\") ").append(
- "and $x.tweetid < int64(\"" + highId + "\") and ");
- if (isIndexOnlyPlan) {
- sb.append(" spatial-intersect($y.sender-location, $area) \n");
- } else {
- sb.append(" spatial-intersect($y.sender-location, $area) and $y.btree-extra-field1 <= int32(\"2147483647\") \n");
- }
- sb.append(" return $y \n");
- sb.append(" );\n");
-
- System.out.println("[jquery" + (queryCount++) + "]" + sb.toString());
-
- return sb.toString();
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment.java
deleted file mode 100644
index 3faf195..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment.java
+++ /dev/null
@@ -1,58 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import java.util.logging.Level;
-import java.util.logging.Logger;
-
-import org.apache.asterix.experiment.action.base.AbstractAction;
-import org.apache.asterix.experiment.action.base.IAction;
-
-public class Experiment extends AbstractAction {
-
- private static final Logger LOGGER = Logger.getLogger(Experiment.class.getName());
-
- private final String name;
-
- private IAction body;
-
- public Experiment(String name) {
- this.name = name;
- }
-
- public void addBody(IAction exec) {
- body = exec;
- }
-
- @Override
- protected void doPerform() throws Exception {
- if (body != null) {
- if (LOGGER.isLoggable(Level.INFO)) {
- LOGGER.info("Running experiment: " + name);
- }
- body.perform();
- }
- }
-
- @Override
- public String toString() {
- return name;
- }
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1ABuilder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1ABuilder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1ABuilder.java
deleted file mode 100644
index f7d2039..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1ABuilder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment1ABuilder extends AbstractExperiment1Builder {
-
- public Experiment1ABuilder(LSMExperimentSetRunnerConfig config) {
- super("1A", config, "1node.xml", "base_1_ingest.aql", "1.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1BBuilder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1BBuilder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1BBuilder.java
deleted file mode 100644
index 17e288f..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1BBuilder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment1BBuilder extends AbstractExperiment1Builder {
-
- public Experiment1BBuilder(LSMExperimentSetRunnerConfig config) {
- super("1B", config, "2node.xml", "base_2_ingest.aql", "2.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1CBuilder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1CBuilder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1CBuilder.java
deleted file mode 100644
index efc5003..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1CBuilder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment1CBuilder extends AbstractExperiment1Builder {
-
- public Experiment1CBuilder(LSMExperimentSetRunnerConfig config) {
- super("1C", config, "4node.xml", "base_4_ingest.aql", "4.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1DBuilder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1DBuilder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1DBuilder.java
deleted file mode 100644
index d6d358b..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1DBuilder.java
+++ /dev/null
@@ -1,29 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment1DBuilder extends AbstractExperiment1Builder {
-
- public Experiment1DBuilder(LSMExperimentSetRunnerConfig config) {
- super("1D", config, "8node.xml", "base_8_ingest.aql", "8.dgen");
- }
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1EBuilder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1EBuilder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1EBuilder.java
deleted file mode 100644
index c2d30a5..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment1EBuilder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment1EBuilder extends AbstractExperiment1Builder {
-
- public Experiment1EBuilder(LSMExperimentSetRunnerConfig config) {
- super("1E", config, "nuclear.xml", "nuclear_base_4_ingest.aql", "nuc.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A1Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A1Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A1Builder.java
deleted file mode 100644
index 3fc9cc7..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A1Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2A1Builder extends AbstractExperiment2ABuilder {
-
- public Experiment2A1Builder(LSMExperimentSetRunnerConfig config) {
- super("2A1", config, "1node.xml", "base_1_ingest.aql", "1.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A2Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A2Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A2Builder.java
deleted file mode 100644
index 2c08ed3..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A2Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2A2Builder extends AbstractExperiment2ABuilder {
-
- public Experiment2A2Builder(LSMExperimentSetRunnerConfig config) {
- super("2A2", config, "2node.xml", "base_2_ingest.aql", "2.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A4Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A4Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A4Builder.java
deleted file mode 100644
index a319687..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A4Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2A4Builder extends AbstractExperiment2ABuilder {
-
- public Experiment2A4Builder(LSMExperimentSetRunnerConfig config) {
- super("2A4", config, "4node.xml", "base_4_ingest.aql", "4.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A8Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A8Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A8Builder.java
deleted file mode 100644
index 3946ea3..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2A8Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2A8Builder extends AbstractExperiment2ABuilder {
-
- public Experiment2A8Builder(LSMExperimentSetRunnerConfig config) {
- super("2A8", config, "8node.xml", "base_8_ingest.aql", "8.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B1Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B1Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B1Builder.java
deleted file mode 100644
index e1f39b2..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B1Builder.java
+++ /dev/null
@@ -1,29 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2B1Builder extends AbstractExperiment2BBuilder {
-
- public Experiment2B1Builder(LSMExperimentSetRunnerConfig config) {
- super("2B1", config, "1node.xml", "base_1_ingest.aql", "1.dgen");
- }
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B2Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B2Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B2Builder.java
deleted file mode 100644
index 42f23d5..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B2Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2B2Builder extends AbstractExperiment2BBuilder {
-
- public Experiment2B2Builder(LSMExperimentSetRunnerConfig config) {
- super("2B2", config, "2node.xml", "base_2_ingest.aql", "2.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B4Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B4Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B4Builder.java
deleted file mode 100644
index f644fd8..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B4Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2B4Builder extends AbstractExperiment2BBuilder {
-
- public Experiment2B4Builder(LSMExperimentSetRunnerConfig config) {
- super("2B4", config, "4node.xml", "base_4_ingest.aql", "4.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B8Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B8Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B8Builder.java
deleted file mode 100644
index 6264513..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2B8Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2B8Builder extends AbstractExperiment2BBuilder {
-
- public Experiment2B8Builder(LSMExperimentSetRunnerConfig config) {
- super("2B8", config, "8node.xml", "base_8_ingest.aql", "8.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C1Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C1Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C1Builder.java
deleted file mode 100644
index 81c5428..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C1Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2C1Builder extends AbstractExperiment2CBuilder {
-
- public Experiment2C1Builder(LSMExperimentSetRunnerConfig config) {
- super("2C1", config, "1node.xml", "base_1_ingest.aql", "1.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C2Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C2Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C2Builder.java
deleted file mode 100644
index d1ff1d3..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C2Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2C2Builder extends AbstractExperiment2CBuilder {
-
- public Experiment2C2Builder(LSMExperimentSetRunnerConfig config) {
- super("2C2", config, "2node.xml", "base_2_ingest.aql", "2.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C4Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C4Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C4Builder.java
deleted file mode 100644
index a6594d3..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C4Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2C4Builder extends AbstractExperiment2CBuilder {
-
- public Experiment2C4Builder(LSMExperimentSetRunnerConfig config) {
- super("2C4", config, "4node.xml", "base_4_ingest.aql", "4.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C8Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C8Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C8Builder.java
deleted file mode 100644
index bccd0a5..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2C8Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2C8Builder extends AbstractExperiment2CBuilder {
-
- public Experiment2C8Builder(LSMExperimentSetRunnerConfig config) {
- super("2C8", config, "8node.xml", "base_8_ingest.aql", "8.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D1Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D1Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D1Builder.java
deleted file mode 100644
index 02d9015..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D1Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2D1Builder extends AbstractExperiment2DBuilder {
-
- public Experiment2D1Builder(LSMExperimentSetRunnerConfig config) {
- super("2D1", config, "1node.xml", "base_1_ingest.aql", "1.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D2Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D2Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D2Builder.java
deleted file mode 100644
index 1e65877..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D2Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2D2Builder extends AbstractExperiment2DBuilder {
-
- public Experiment2D2Builder(LSMExperimentSetRunnerConfig config) {
- super("2D2", config, "2node.xml", "base_2_ingest.aql", "2.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D4Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D4Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D4Builder.java
deleted file mode 100644
index 4bca31c..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D4Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2D4Builder extends AbstractExperiment2DBuilder {
-
- public Experiment2D4Builder(LSMExperimentSetRunnerConfig config) {
- super("2D4", config, "4node.xml", "base_4_ingest.aql", "4.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D8Builder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D8Builder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D8Builder.java
deleted file mode 100644
index 779aefd..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment2D8Builder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment2D8Builder extends AbstractExperiment2DBuilder {
-
- public Experiment2D8Builder(LSMExperimentSetRunnerConfig config) {
- super("2D8", config, "8node.xml", "base_8_ingest.aql", "8.dgen");
- }
-
-}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/0e21afa7/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment3ABuilder.java
----------------------------------------------------------------------
diff --git a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment3ABuilder.java b/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment3ABuilder.java
deleted file mode 100644
index b44b82d..0000000
--- a/asterixdb/asterix-experiments/src/main/java/org/apache/asterix/experiment/builder/Experiment3ABuilder.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-
-package org.apache.asterix.experiment.builder;
-
-import org.apache.asterix.experiment.client.LSMExperimentSetRunner.LSMExperimentSetRunnerConfig;
-
-public class Experiment3ABuilder extends AbstractExperiment3Builder {
-
- public Experiment3ABuilder(LSMExperimentSetRunnerConfig config) {
- super("3A", config, "1node.xml", "base_1_ingest.aql", "1.dgen");
- }
-
-}