http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/driver/InstallerDriver.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/driver/InstallerDriver.java b/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/driver/InstallerDriver.java deleted file mode 100644 index 61e7916..0000000 --- a/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/driver/InstallerDriver.java +++ /dev/null @@ -1,133 +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.installer.driver; - -import java.io.File; - -import javax.xml.bind.JAXBContext; -import javax.xml.bind.Unmarshaller; - -import org.apache.log4j.Logger; - -import org.apache.asterix.event.service.AsterixEventService; -import org.apache.asterix.event.service.ILookupService; -import org.apache.asterix.event.service.ServiceProvider; -import org.apache.asterix.installer.command.CommandHandler; -import org.apache.asterix.installer.command.ConfigureCommand; -import org.apache.asterix.installer.schema.conf.Configuration; - -public class InstallerDriver { - - private static final Logger LOGGER = Logger.getLogger(InstallerDriver.class.getName()); - - public static final String MANAGIX_INTERNAL_DIR = ".installer"; - public static final String ENV_MANAGIX_HOME = "MANAGIX_HOME"; - public static final String MANAGIX_CONF_XML = "conf" + File.separator + "managix-conf.xml"; - public static final String ASTERIX_DIR = "asterix"; - - private static String managixHome; - - public static void initConfig(boolean ensureLookupServiceIsRunning) throws Exception { - File configFile = new File(managixHome + File.separator + MANAGIX_CONF_XML); - JAXBContext configCtx = JAXBContext.newInstance(Configuration.class); - Unmarshaller unmarshaller = configCtx.createUnmarshaller(); - Configuration conf = (Configuration) unmarshaller.unmarshal(configFile); - String asterixDir = managixHome + File.separator + ASTERIX_DIR; - String eventHome = managixHome + File.separator + MANAGIX_INTERNAL_DIR; - AsterixEventService.initialize(conf, asterixDir, eventHome); - - ILookupService lookupService = ServiceProvider.INSTANCE.getLookupService(); - if (ensureLookupServiceIsRunning) { - if (!conf.isConfigured()) { - try { - configure(); - /* read back the configuration file updated as part of configure command*/ - conf = (Configuration) unmarshaller.unmarshal(configFile); - } catch (Exception e) { - e.printStackTrace(); - } - } - if (!lookupService.isRunning(conf)) { - lookupService.startService(conf); - } - } - - } - - private static void configure() throws Exception { - ConfigureCommand cmd = new ConfigureCommand(); - cmd.execute(new String[] { "configure" }); - } - - public static String getManagixHome() { - return managixHome; - } - - public static void setManagixHome(String managixHome) { - InstallerDriver.managixHome = managixHome; - } - - public static void main(String args[]) { - try { - if (args.length != 0) { - managixHome = System.getenv(ENV_MANAGIX_HOME); - CommandHandler cmdHandler = new CommandHandler(); - cmdHandler.processCommand(args); - } else { - printUsage(); - } - } catch (IllegalArgumentException iae) { - LOGGER.error("Unknown command"); - printUsage(); - } catch (Exception e) { - LOGGER.error(e.getMessage()); - if (e.getMessage() == null || e.getMessage().length() < 10) { - // less than 10 characters of error message is probably not enough - e.printStackTrace(); - } - } - } - - private static void printUsage() { - StringBuffer buffer = new StringBuffer("managix <command> <options>" + "\n"); - buffer.append("Commands" + "\n"); - buffer.append("create " + ":" + " Creates a new asterix instance" + "\n"); - buffer.append("delete " + ":" + " Deletes an asterix instance" + "\n"); - buffer.append("start " + ":" + " Starts an asterix instance" + "\n"); - buffer.append("stop " + ":" + " Stops an asterix instance that is in ACTIVE state" + "\n"); - buffer.append("backup " + ":" + " Creates a back up for an existing asterix instance" + "\n"); - buffer.append("restore " + ":" + " Restores an asterix instance" + "\n"); - buffer.append("alter " + ":" + " Alter the instance's configuration settings" + "\n"); - buffer.append("describe " + ":" + " Describes an existing asterix instance" + "\n"); - buffer.append("validate " + ":" + " Validates the installer/cluster configuration" + "\n"); - buffer.append("configure" + ":" + " Auto-generate configuration for local psedu-distributed Asterix instance" - + "\n"); - buffer.append("install " + ":" + " Installs a library to an asterix instance" + "\n"); - buffer.append("uninstall" + ":" + " Uninstalls a library from an asterix instance" + "\n"); - buffer.append("log " + ":" - + " Produce a tar archive contianing log files from the master and worker nodes" + "\n"); - buffer.append("shutdown " + ":" + " Shutdown the installer service" + "\n"); - buffer.append("help " + ":" + " Provides usage description of a command" + "\n"); - buffer.append("version " + ":" + " Provides version of Asterix/Managix" + "\n"); - - buffer.append("\nTo get more information about a command, use managix help -cmd <command>"); - LOGGER.info(buffer.toString()); - } - -}
http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/driver/InstallerUtil.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/driver/InstallerUtil.java b/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/driver/InstallerUtil.java deleted file mode 100644 index 1ac60ba..0000000 --- a/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/driver/InstallerUtil.java +++ /dev/null @@ -1,77 +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.installer.driver; - -import java.io.File; -import java.io.FileNotFoundException; -import java.io.IOException; - -import javax.xml.bind.JAXBContext; -import javax.xml.bind.JAXBException; -import javax.xml.bind.Unmarshaller; - -import org.apache.asterix.common.configuration.AsterixConfiguration; -import org.apache.asterix.event.schema.cluster.Cluster; -import org.apache.asterix.event.schema.cluster.Node; - -public class InstallerUtil { - - private static final String DEFAULT_ASTERIX_CONFIGURATION_PATH = "conf" + File.separator - + "asterix-configuration.xml"; - - public static final String TXN_LOG_DIR = "txnLogs"; - public static final String TXN_LOG_DIR_KEY_SUFFIX = "txnLogDir"; - public static final String ASTERIX_CONFIGURATION_FILE = "asterix-configuration.xml"; - public static final String TXN_LOG_CONFIGURATION_FILE = "log.properties"; - public static final int CLUSTER_NET_PORT_DEFAULT = 1098; - public static final int CLIENT_NET_PORT_DEFAULT = 1099; - public static final int HTTP_PORT_DEFAULT = 8888; - public static final int WEB_INTERFACE_PORT_DEFAULT = 19001; - - public static String getNodeDirectories(String asterixInstanceName, Node node, Cluster cluster) { - String storeDataSubDir = asterixInstanceName + File.separator + "data" + File.separator; - String[] storeDirs = null; - StringBuffer nodeDataStore = new StringBuffer(); - String storeDirValue = cluster.getStore(); - if (storeDirValue == null) { - throw new IllegalStateException(" Store not defined for node " + node.getId()); - } - storeDataSubDir = node.getId() + File.separator + storeDataSubDir; - - storeDirs = storeDirValue.split(","); - for (String ns : storeDirs) { - nodeDataStore.append(ns + File.separator + storeDataSubDir.trim()); - nodeDataStore.append(","); - } - nodeDataStore.deleteCharAt(nodeDataStore.length() - 1); - return nodeDataStore.toString(); - } - - public static AsterixConfiguration getAsterixConfiguration(String asterixConf) - throws FileNotFoundException, IOException, JAXBException { - if (asterixConf == null) { - asterixConf = InstallerDriver.getManagixHome() + File.separator + DEFAULT_ASTERIX_CONFIGURATION_PATH; - } - File file = new File(asterixConf); - JAXBContext ctx = JAXBContext.newInstance(AsterixConfiguration.class); - Unmarshaller unmarshaller = ctx.createUnmarshaller(); - AsterixConfiguration asterixConfiguration = (AsterixConfiguration) unmarshaller.unmarshal(file); - return asterixConfiguration; - } -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/error/InstallerException.java ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/error/InstallerException.java b/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/error/InstallerException.java deleted file mode 100644 index dccfd4a..0000000 --- a/asterixdb/asterix-installer/src/main/java/org/apache/asterix/installer/error/InstallerException.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.installer.error; - -public class InstallerException extends Exception { - - private static final long serialVersionUID = 1L; - - public InstallerException(String message) { - super(message); - } - -} http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/clusters/demo/demo.xml ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/clusters/demo/demo.xml b/asterixdb/asterix-installer/src/main/resources/clusters/demo/demo.xml deleted file mode 100644 index 500172c..0000000 --- a/asterixdb/asterix-installer/src/main/resources/clusters/demo/demo.xml +++ /dev/null @@ -1,57 +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. - !--> -<cluster xmlns="cluster"> - <!-- - This defines a cluster that runs 2 worker nodes on a single machine. - Also, each worker node is assigned to 2 partitions in the same - directory (and thus on the same external storage device). - Both of these decisions are usually not advisable for production - use. - --> - <name>demo</name> - <working_dir> - <dir>/tmp/asterix-installer</dir> - <NFS>true</NFS> - </working_dir> - <log_dir>/tmp/asterix/logs</log_dir> - <store>storage</store> - <java_home></java_home> - <master_node> - <id>master</id> - <client_ip>127.0.0.1</client_ip> - <cluster_ip>127.0.0.1</cluster_ip> - <cluster_port>1099</cluster_port> - <client_port>1098</client_port> - <http_port>8888</http_port> - </master_node> - <node> - <id>node1</id> - <cluster_ip>127.0.0.1</cluster_ip> - <txn_log_dir>/tmp/asterix/node1/txnLogs</txn_log_dir> - <iodevices>/tmp/asterix/node1/1,/tmp/asterix/node1/2</iodevices> - <nc_api_port>19004</nc_api_port> - </node> - <node> - <id>node2</id> - <cluster_ip>127.0.0.1</cluster_ip> - <txn_log_dir>/tmp/asterix/node2/txnLogs</txn_log_dir> - <iodevices>/tmp/asterix/node2/1,/tmp/asterix/node2/2</iodevices> - <nc_api_port>19005</nc_api_port> - </node> -</cluster> http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/clusters/local/local.xml ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/clusters/local/local.xml b/asterixdb/asterix-installer/src/main/resources/clusters/local/local.xml deleted file mode 100644 index b26d836..0000000 --- a/asterixdb/asterix-installer/src/main/resources/clusters/local/local.xml +++ /dev/null @@ -1,63 +0,0 @@ -<?xml version="1.0" encoding="UTF-8" standalone="yes"?> -<!-- - ! 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. - !--> -<cluster xmlns="cluster"> - <java_home>/usr/lib/jvm/jdk-8-oracle-x64/jre</java_home> - <log_dir>/tmp/asterix/logs</log_dir> - <txn_log_dir>/tmp/asterix/txnLogs</txn_log_dir> - <store>storage</store> - <working_dir> - <dir>/tmp/asterix-installer</dir> - <NFS>true</NFS> - </working_dir> - <!-- Sets the time duration between two heartbeats from each node controller in milliseconds (default: 10000) --> - <heartbeat_period>10000</heartbeat_period> - <!-- Sets the maximum number of missed heartbeats before a node is marked as dead (default: 5) --> - <max_heartbeat_lapse_periods>5</max_heartbeat_lapse_periods> - <!-- Sets the time duration between two profile dumps from each node controller in milliseconds. 0 to disable. (default: 0) --> - <profile_dump_period>0</profile_dump_period> - <!-- Limits the number of historical jobs remembered by the system to the specified value. (default: 10) --> - <job_history_size>10</job_history_size> - <!-- Limits the amount of time results for asynchronous jobs should be retained by the system in milliseconds. (default: 24 hours) --> - <result_time_to_live>86400000</result_time_to_live> - <!-- The duration within which an instance of the result cleanup should be invoked in milliseconds. (default: 1 minute) --> - <result_sweep_threshold>60000</result_sweep_threshold> - <master_node> - <id>master</id> - <client_ip>127.0.0.1</client_ip> - <cluster_ip>127.0.0.1</cluster_ip> - <client_port>1098</client_port> - <cluster_port>1099</cluster_port> - <http_port>8888</http_port> - </master_node> - <node> - <id>nc1</id> - <cluster_ip>127.0.0.1</cluster_ip> - <txn_log_dir>/tmp/asterix/nc1/txnLogs</txn_log_dir> - <iodevices>/tmp/asterix/nc1/p1,/tmp/asterix/nc1/p2</iodevices> - <nc_api_port>19004</nc_api_port> - </node> - <node> - <id>nc2</id> - <cluster_ip>127.0.0.1</cluster_ip> - <txn_log_dir>/tmp/asterix/nc2/txnLogs</txn_log_dir> - <iodevices>/tmp/asterix/nc2/p1,/tmp/asterix/nc2/p2</iodevices> - <nc_api_port>19005</nc_api_port> - </node> -</cluster> http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/clusters/local/local_chained_declustering_rep.xml ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/clusters/local/local_chained_declustering_rep.xml b/asterixdb/asterix-installer/src/main/resources/clusters/local/local_chained_declustering_rep.xml deleted file mode 100644 index c445835..0000000 --- a/asterixdb/asterix-installer/src/main/resources/clusters/local/local_chained_declustering_rep.xml +++ /dev/null @@ -1,81 +0,0 @@ -<?xml version="1.0" encoding="UTF-8" standalone="yes"?> -<!-- - ! 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. - !--> -<cluster xmlns="cluster"> - <java_home>/usr/lib/jvm/jdk-8-oracle-x64/jre</java_home> - <log_dir>/tmp/asterix/logs</log_dir> - <txn_log_dir>/tmp/asterix/txnLogs</txn_log_dir> - <store>storage</store> - <working_dir> - <dir>/tmp/asterix-installer</dir> - <NFS>true</NFS> - </working_dir> - <!-- Sets the time duration between two heartbeats from each node controller in milliseconds (default: 10000) --> - <heartbeat_period>1000</heartbeat_period> - <!-- Sets the maximum number of missed heartbeats before a node is marked as dead (default: 5) --> - <max_heartbeat_lapse_periods>5</max_heartbeat_lapse_periods> - <!-- Sets the time duration between two profile dumps from each node controller in milliseconds. 0 to disable. (default: 0) --> - <profile_dump_period>0</profile_dump_period> - <!-- Limits the number of historical jobs remembered by the system to the specified value. (default: 10) --> - <job_history_size>10</job_history_size> - <!-- Limits the amount of time results for asynchronous jobs should be retained by the system in milliseconds. (default: 24 hours) --> - <result_time_to_live>86400000</result_time_to_live> - <!-- The duration within which an instance of the result cleanup should be invoked in milliseconds. (default: 1 minute) --> - <result_sweep_threshold>60000</result_sweep_threshold> - - <metadata_node>nc1</metadata_node> - - <high_availability> - <enabled>true</enabled> - <data_replication> - <strategy>chained_declustering</strategy> - <replication_port>2000</replication_port> - <replication_factor>2</replication_factor> - <replication_time_out>30</replication_time_out> - </data_replication> - <fault_tolerance> - <strategy>auto</strategy> - </fault_tolerance> - </high_availability> - - <master_node> - <id>master</id> - <client_ip>127.0.0.1</client_ip> - <cluster_ip>127.0.0.1</cluster_ip> - <client_port>1098</client_port> - <cluster_port>1099</cluster_port> - <http_port>8888</http_port> - </master_node> - <node> - <id>nc1</id> - <cluster_ip>127.0.0.1</cluster_ip> - <txn_log_dir>/tmp/asterix/nc1/txnLogs</txn_log_dir> - <iodevices>/tmp/asterix/nc1/p1,/tmp/asterix/nc1/p2</iodevices> - <replication_port>2000</replication_port> - <nc_api_port>19004</nc_api_port> - </node> - <node> - <id>nc2</id> - <cluster_ip>127.0.0.1</cluster_ip> - <txn_log_dir>/tmp/asterix/nc2/txnLogs</txn_log_dir> - <iodevices>/tmp/asterix/nc2/p1,/tmp/asterix/nc2/p2</iodevices> - <replication_port>2001</replication_port> - <nc_api_port>19005</nc_api_port> - </node> -</cluster> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/clusters/local/local_metadata_only_rep.xml ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/clusters/local/local_metadata_only_rep.xml b/asterixdb/asterix-installer/src/main/resources/clusters/local/local_metadata_only_rep.xml deleted file mode 100644 index fbe0de8..0000000 --- a/asterixdb/asterix-installer/src/main/resources/clusters/local/local_metadata_only_rep.xml +++ /dev/null @@ -1,85 +0,0 @@ -<?xml version="1.0" encoding="UTF-8" standalone="yes"?> -<!-- - ! 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. - !--> -<cluster xmlns="cluster"> - <java_home>/usr/lib/jvm/jdk-8-oracle-x64/jre</java_home> - <log_dir>/tmp/asterix/logs</log_dir> - <txn_log_dir>/tmp/asterix/txnLogs</txn_log_dir> - <store>storage</store> - <working_dir> - <dir>/tmp/asterix-installer</dir> - <NFS>true</NFS> - </working_dir> - <!-- Sets the time duration between two heartbeats from each node controller in milliseconds (default: 10000) --> - <heartbeat_period>1000</heartbeat_period> - <!-- Sets the maximum number of missed heartbeats before a node is marked as dead (default: 5) --> - <max_heartbeat_lapse_periods>5</max_heartbeat_lapse_periods> - <!-- Sets the time duration between two profile dumps from each node controller in milliseconds. 0 to disable. (default: 0) --> - <profile_dump_period>0</profile_dump_period> - <!-- Sets the default number of job attempts allowed if not specified in the job specification. (default: 5) --> - <default_max_job_attempts>5</default_max_job_attempts> - <!-- Limits the number of historical jobs remembered by the system to the specified value. (default: 10) --> - <job_history_size>10</job_history_size> - <!-- Limits the amount of time results for asynchronous jobs should be retained by the system in milliseconds. (default: 24 hours) --> - <result_time_to_live>86400000</result_time_to_live> - <!-- The duration within which an instance of the result cleanup should be invoked in milliseconds. (default: 1 minute) --> - <result_sweep_threshold>60000</result_sweep_threshold> - - <metadata_node>nc1</metadata_node> - - <high_availability> - <enabled>true</enabled> - <data_replication> - <strategy>metadata_only</strategy> - <replication_port>2000</replication_port> - <replication_time_out>30</replication_time_out> - </data_replication> - <fault_tolerance> - <strategy>metadata_node</strategy> - <replica> - <node_id>nc2</node_id> - </replica> - </fault_tolerance> - </high_availability> - - <master_node> - <id>master</id> - <client_ip>127.0.0.1</client_ip> - <cluster_ip>127.0.0.1</cluster_ip> - <client_port>1098</client_port> - <cluster_port>1099</cluster_port> - <http_port>8888</http_port> - </master_node> - <node> - <id>nc1</id> - <cluster_ip>127.0.0.1</cluster_ip> - <txn_log_dir>/tmp/asterix/nc1/txnLogs</txn_log_dir> - <iodevices>/tmp/asterix/nc1/p1,/tmp/asterix/nc1/p2</iodevices> - <replication_port>2000</replication_port> - <nc_api_port>19004</nc_api_port> - </node> - <node> - <id>nc2</id> - <cluster_ip>127.0.0.1</cluster_ip> - <txn_log_dir>/tmp/asterix/nc2/txnLogs</txn_log_dir> - <iodevices>/tmp/asterix/nc2/p1,/tmp/asterix/nc2/p2</iodevices> - <replication_port>2001</replication_port> - <nc_api_port>19005</nc_api_port> - </node> -</cluster> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/conf/asterix-configuration.xml ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/conf/asterix-configuration.xml b/asterixdb/asterix-installer/src/main/resources/conf/asterix-configuration.xml deleted file mode 100644 index 35d114e..0000000 --- a/asterixdb/asterix-installer/src/main/resources/conf/asterix-configuration.xml +++ /dev/null @@ -1,268 +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. - !--> -<asterixConfiguration xmlns="asterixconf"> - - <property> - <name>nc.java.opts</name> - <value>-Xmx3096m</value> - <description>JVM parameters for each Node Contoller (NC)</description> - </property> - - <property> - <name>cc.java.opts</name> - <value>-Xmx1024m</value> - <description>JVM parameters for each Cluster Contoller (CC) - </description> - </property> - - <property> - <name>max.wait.active.cluster</name> - <value>60</value> - <description>Maximum wait (in seconds) for a cluster to be ACTIVE (all nodes are available) - before a submitted query/statement can be executed. (Default = 60 seconds) - </description> - </property> - - <property> - <name>storage.buffercache.pagesize</name> - <value>128KB</value> - <description>The page size in bytes for pages in the buffer cache. - (Default = "131072" // 128KB) - </description> - </property> - - <property> - <name>storage.buffercache.size</name> - <value>512MB</value> - <description>The size of memory allocated to the disk buffer cache. - The value should be a multiple of the buffer cache page size(Default - = "536870912" // 512MB) - </description> - </property> - - <property> - <name>storage.buffercache.maxopenfiles</name> - <value>214748364</value> - <description>The maximum number of open files in the buffer cache. - (Default = "214748364") - </description> - </property> - - <property> - <name>storage.memorycomponent.pagesize</name> - <value>128KB</value> - <description>The page size in bytes for pages allocated to memory - components. (Default = "131072" // 128KB) - </description> - </property> - - <property> - <name>storage.memorycomponent.numpages</name> - <value>256</value> - <description>The number of pages to allocate for a memory component. - This budget is shared by all the memory components of the primary - index and all its secondary indexes across all I/O devices on a node. - Note: in-memory components usually has fill factor of 75% since - the pages are 75% full and the remaining 25% is un-utilized. (Default = 256) - </description> - </property> - - <property> - <name>storage.metadata.memorycomponent.numpages</name> - <value>64</value> - <description>The number of pages to allocate for a memory component. - (Default = 64) - </description> - </property> - - <property> - <name>storage.memorycomponent.numcomponents</name> - <value>2</value> - <description>The number of memory components to be used per lsm index. - (Default = 2) - </description> - </property> - - <property> - <name>storage.memorycomponent.globalbudget</name> - <value>1GB</value> - <description>The total size of memory in bytes that the sum of all open memory - components cannot exceed. Consider this as the buffer cache for all memory - components of all indexes in a node. When this budget is fully used, a victim - dataset will be chosen. The chosen dataset must be evicted and closed to make - a space for another dataset. (Default = 512MB) - </description> - </property> - - <property> - <name>storage.lsm.bloomfilter.falsepositiverate</name> - <value>0.01</value> - <description>The maximum acceptable false positive rate for bloom - filters associated with LSM indexes. (Default = "0.01" // 1%) - </description> - </property> - - <property> - <name>txn.log.buffer.numpages</name> - <value>8</value> - <description>The number of in-memory log buffer pages. (Default = "8") - </description> - </property> - - <property> - <name>txn.log.buffer.pagesize</name> - <value>512KB</value> - <description>The size of pages in the in-memory log buffer. (Default = - "524288" // 512KB) - </description> - </property> - - <property> - <name>txn.log.partitionsize</name> - <value>2GB</value> - <description>The maximum size of a log file partition allowed before - rotating the log to the next partition. (Default = "2147483648" // - 2GB) - </description> - </property> - - <property> - <name>txn.log.checkpoint.lsnthreshold</name> - <value>67108864</value> - <description>The size of the window that the maximum LSN is allowed to - be ahead of the checkpoint LSN by. (Default = ""67108864" // 64M) - </description> - </property> - - <property> - <name>txn.log.checkpoint.pollfrequency</name> - <value>120</value> - <description>The time in seconds between that the checkpoint thread - waits between polls. (Default = "120" // 120s) - </description> - </property> - - <property> - <name>txn.log.checkpoint.history</name> - <value>0</value> - <description>The number of old log partition files to keep before - discarding. (Default = "0") - </description> - </property> - - <property> - <name>txn.lock.escalationthreshold</name> - <value>1000</value> - <description>The number of entity level locks that need to be acquired - before the locks are coalesced and escalated into a dataset level - lock. (Default = "1000") - </description> - </property> - - <property> - <name>txn.lock.shrinktimer</name> - <value>5000</value> - <description>The time in milliseconds to wait before deallocating - unused lock manager memory. (Default = "5000" // 5s) - </description> - </property> - - <property> - <name>txn.lock.timeout.waitthreshold</name> - <value>60000</value> - <description>The time in milliseconds to wait before labeling a - transaction which has been waiting for a lock timed-out. (Default = - "60000" // 60s) - </description> - </property> - - <property> - <name>txn.lock.timeout.sweepthreshold</name> - <value>10000</value> - <description>The time in milliseconds the timeout thread waits between - sweeps to detect timed-out transactions. (Default = "10000" // 10s) - </description> - </property> - - <property> - <name>txn.job.recovery.memorysize</name> - <value>64MB</value> - <description>The memory allocated per job during recovery. - (Default = "67108864" // 64MB) - </description> - </property> - - <property> - <name>compiler.sortmemory</name> - <value>32MB</value> - <description>The amount of memory in bytes given to sort operations. - (Default = "33554432" // 32MB) - </description> - </property> - - <property> - <name>compiler.joinmemory</name> - <value>32MB</value> - <description>The amount of memory in bytes given to join operations. - (Default = "33554432" // 32MB) - </description> - </property> - - <property> - <name>compiler.framesize</name> - <value>128KB</value> - <description>The Hyracks frame size that the compiler configures per - job. (Default = "131072" // 128KB) - </description> - </property> - - <property> - <name>compiler.pregelix.home</name> - <value>~/pregelix</value> - </property> - - <property> - <name>web.port</name> - <value>19001</value> - <description>The port for the ASTERIX web interface. (Default = 19001) - </description> - </property> - - <property> - <name>web.queryinterface.port</name> - <value>19006</value> - <description>The port for the ASTERIX web query interface. (Default = 19006) - </description> - </property> - - <property> - <name>api.port</name> - <value>19002</value> - <description>The port for the ASTERIX API server. (Default = 19002) - </description> - </property> - - <property> - <name>log.level</name> - <value>INFO</value> - <description>The minimum log level to be displayed. (Default = INFO) - </description> - </property> - -</asterixConfiguration> http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/conf/log4j.properties ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/conf/log4j.properties b/asterixdb/asterix-installer/src/main/resources/conf/log4j.properties deleted file mode 100644 index 9d84a21..0000000 --- a/asterixdb/asterix-installer/src/main/resources/conf/log4j.properties +++ /dev/null @@ -1,26 +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. -log4j.rootLogger=info, A1 - -log4j.appender.A1=org.apache.log4j.ConsoleAppender -log4j.appender.A1.layout=org.apache.log4j.PatternLayout -# Print the date in ISO 8601 format -log4j.appender.A1.layout.ConversionPattern=%-p: %m%n - -log4j.logger.org.apache.asterix.event.management=error -log4j.logger.org.apache.zookeeper=error http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/conf/managix-conf.xml ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/conf/managix-conf.xml b/asterixdb/asterix-installer/src/main/resources/conf/managix-conf.xml deleted file mode 100644 index 789f546..0000000 --- a/asterixdb/asterix-installer/src/main/resources/conf/managix-conf.xml +++ /dev/null @@ -1,35 +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. - !--> -<configuration xmlns="installer"> - <is_configured>false</is_configured> - <backup> - <hdfs> - <version>0.20.2</version> - <url></url> - <backupDir></backupDir> - </hdfs> - </backup> - <zookeeper> - <homeDir>/tmp/zookeeper</homeDir> - <clientPort>2900</clientPort> - <servers> - <server>127.0.0.1</server> - </servers> - </zookeeper> -</configuration> http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/create.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/create.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/create.aql deleted file mode 100644 index 87ad2b0..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/create.aql +++ /dev/null @@ -1,69 +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. - */ -drop dataverse TinySocial if exists; -create dataverse TinySocial; -use dataverse TinySocial; - -create type EmploymentType as open { - organization-name: string, - start-date: date, - end-date: date? -} - -create type MugshotUserType as { - id: int32, - alias: string, - name: string, - user-since: datetime, - address: { - street: string, - city: string, - state: string, - zip: string, - country: string - }, - friend-ids: {{ int32 }}, - employment: [EmploymentType] -} - -create type MugshotMessageType as closed { - message-id: int32, - author-id: int32, - timestamp: datetime, - in-response-to: int32?, - sender-location: point?, - tags: {{ string }}, - message: string -} - -create dataset MugshotUsers(MugshotUserType) - primary key id; -create dataset MugshotMessages(MugshotMessageType) - primary key message-id; - -create index msUserSinceIdx - on MugshotUsers(user-since); -create index msTimestampIdx - on MugshotMessages(timestamp); -create index msAuthorIdx - on MugshotMessages(author-id) type btree; -create index msSenderLocIndex - on MugshotMessages(sender-location) type rtree; -create index msMessageIdx - on MugshotMessages(message) type keyword; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/delete.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/delete.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/delete.aql deleted file mode 100644 index 8079f66..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/delete.aql +++ /dev/null @@ -1,22 +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. - */ -use dataverse TinySocial; - -delete $user from dataset MugshotUsers -where $user.id = 999; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/equi-join.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/equi-join.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/equi-join.aql deleted file mode 100644 index 2dab34a..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/equi-join.aql +++ /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. - */ -use dataverse TinySocial; - -for $user in dataset MugshotUsers -for $message in dataset MugshotMessages -where $message.author-id = $user.id - and $user.user-since >= datetime('2010-07-22T00:00:00') - and $user.user-since <= datetime('2012-07-29T23:59:59') -return { - "uname" : $user.name, - "message" : $message.message -}; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/function-definition.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/function-definition.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/function-definition.aql deleted file mode 100644 index fee9eb0..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/function-definition.aql +++ /dev/null @@ -1,31 +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. - */ -use dataverse TinySocial; - -drop function unemployed@0 if exists; - -create function unemployed() { - for $msu in dataset MugshotUsers - where (every $e in $msu.employment - satisfies not(is-null($e.end-date))) - return { - "name" : $msu.name, - "address" : $msu.address - } -}; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/function-use.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/function-use.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/function-use.aql deleted file mode 100644 index 5695b31..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/function-use.aql +++ /dev/null @@ -1,23 +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. - */ -use dataverse TinySocial; - -for $un in unemployed() -where $un.address.zip = "94065" -return $un http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/group-sort-limit.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/group-sort-limit.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/group-sort-limit.aql deleted file mode 100644 index e0c4cfd..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/group-sort-limit.aql +++ /dev/null @@ -1,31 +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. - */ -use dataverse TinySocial; - -for $msg in dataset MugshotMessages -where $msg.timestamp >= datetime("2014-02-20T00:00:00") - and $msg.timestamp < datetime("2014-03-20T00:00:00") -group by $aid := $msg.author-id with $msg -let $cnt := count($msg) -order by $cnt desc -limit 3 -return { - "author" : $aid, - "no messages" : $cnt -}; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/insert.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/insert.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/insert.aql deleted file mode 100644 index 720a34f..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/insert.aql +++ /dev/null @@ -1,41 +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. - */ -use dataverse TinySocial; - -insert into dataset MugshotUsers -( - { - "id":999, - "alias":"John", - "name":"JohnDoe", - "address":{ - "street":"789 Jane St", - "city":"San Harry", - "zip":"98767", - "state":"CA", - "country":"USA" - }, - "user-since":datetime("2010-08-15T08:10:00"), - "friend-ids":{{ 5, 9, 11 }}, - "employment":[{ - "organization-name":"Kongreen", - "start-date":date("2012-06-05") - }] - } -); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/join-group.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/join-group.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/join-group.aql deleted file mode 100644 index 255f800..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/join-group.aql +++ /dev/null @@ -1,32 +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. - */ -use dataverse TinySocial; - -for $user in dataset MugshotUsers -for $message in dataset MugshotMessages -where $message.author-id = $user.id -group by $name := $user.name with $message -let $avglen := avg(for $m in $message - return string-length($m.message)) -order by $avglen desc -limit 10 -return { - "uname" : $name, - "msg-length" : $avglen -}; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/left-outer-fuzzy-join.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/left-outer-fuzzy-join.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/left-outer-fuzzy-join.aql deleted file mode 100644 index ee4e626..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/left-outer-fuzzy-join.aql +++ /dev/null @@ -1,37 +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. - */ -use dataverse TinySocial; - -set simfunction "jaccard"; -set simthreshold "0.3"; - -for $msg in dataset MugshotMessages -let $msgsSimilarTags := ( - for $m2 in dataset MugshotMessages - where $m2.tags ~= $msg.tags - and $m2.message-id != $msg.message-id - return $m2.message - ) -where count($msgsSimilarTags) > 0 -order by count($msgsSimilarTags) -limit 10 -return { - "message" : $msg.message, - "similarly tagged" : $msgsSimilarTags -}; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/left-outer-join-aggr.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/left-outer-join-aggr.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/left-outer-join-aggr.aql deleted file mode 100644 index ff461bc..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/left-outer-join-aggr.aql +++ /dev/null @@ -1,32 +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. - */ -use dataverse TinySocial; - -for $user in dataset MugshotUsers -let $result := { - "uname" : $user.name, - "msg-length" : avg( - for $message in dataset MugshotMessages - where $message.author-id = $user.id - return string-length($message.message) - ) - } -order by $result.msg-length desc -limit 10 -return $result; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/left-outer-join.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/left-outer-join.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/left-outer-join.aql deleted file mode 100644 index 04e1ceb..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/left-outer-join.aql +++ /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. - */ -use dataverse TinySocial; - -for $user in dataset MugshotUsers -where $user.user-since >= datetime('2010-07-22T00:00:00') - and $user.user-since <= datetime('2012-07-29T23:59:59') -return { - "uname" : $user.name, - "messages" : - for $message in dataset MugshotMessages - where $message.author-id = $user.id - return $message.message -}; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/load.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/load.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/load.aql deleted file mode 100644 index e85739a..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/load.aql +++ /dev/null @@ -1,25 +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. - */ -use dataverse TinySocial; - -load dataset MugshotUsers using localfs -(("path"="127.0.0.1://../../../examples/mugshot/data/mugshot_users.adm"),("format"="adm")); - -load dataset MugshotMessages using localfs -(("path"="127.0.0.1://../../../examples/mugshot/data/mugshot_messages.adm"),("format"="adm")); http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/lookup.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/lookup.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/lookup.aql deleted file mode 100644 index ec5cfe8..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/lookup.aql +++ /dev/null @@ -1,23 +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. - */ -use dataverse TinySocial; - -for $user in dataset MugshotUsers -where $user.id = 8 -return $user; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/range-scan.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/range-scan.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/range-scan.aql deleted file mode 100644 index 788379a..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/range-scan.aql +++ /dev/null @@ -1,24 +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. - */ -use dataverse TinySocial; - -for $user in dataset MugshotUsers -where $user.user-since >= datetime('2010-07-22T00:00:00') - and $user.user-since <= datetime('2012-07-29T23:59:59') -return $user; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/simple-aggregation.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/simple-aggregation.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/simple-aggregation.aql deleted file mode 100644 index 44e1281..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/simple-aggregation.aql +++ /dev/null @@ -1,26 +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. - */ -use dataverse TinySocial; - -avg( - for $m in dataset MugshotMessages - where $m.timestamp >= datetime("2014-01-01T00:00:00") - and $m.timestamp < datetime("2014-04-01T00:00:00") - return string-length($m.message) -) http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/spatial-join.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/spatial-join.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/spatial-join.aql deleted file mode 100644 index eb50cb1..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/spatial-join.aql +++ /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. - */ -use dataverse TinySocial; - -for $t in dataset MugshotMessages -return { - "message" : $t.message, - "nearby-messages": - for $t2 in dataset MugshotMessages - where spatial-distance($t.sender-location, - $t2.sender-location) <= 1 - return { "msgtxt" : $t2.message } -}; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/ten-of-each.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/ten-of-each.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/ten-of-each.aql deleted file mode 100644 index ec829eb..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/ten-of-each.aql +++ /dev/null @@ -1,27 +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. - */ -use dataverse TinySocial; - -for $user in dataset MugshotUsers -limit 10 -return $user; - -for $message in dataset MugshotMessages -limit 10 -return $message; http://git-wip-us.apache.org/repos/asf/asterixdb/blob/5dcf139e/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/universal.aql ---------------------------------------------------------------------- diff --git a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/universal.aql b/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/universal.aql deleted file mode 100644 index ab25894..0000000 --- a/asterixdb/asterix-installer/src/main/resources/examples/mugshot/aql/universal.aql +++ /dev/null @@ -1,28 +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. - */ -use dataverse TinySocial; - -for $msu in dataset MugshotUsers -where (every $e in $msu.employment - satisfies not(is-null($e.end-date))) -limit 10 -return { - "name" : $msu.name, - "address" : $msu.address -};
