sync

Author: satanson

BatchUpsertDemo.sh

@@ -0,0 +1,2 @@
+#!/bin/bash
+/home/grakra/ssd/jdk1.8.0_131/bin/java -javaagent:/home/grakra/ssd/idea-IC-181.4892.42/lib/idea_rt.jar=46245:/home/grakra/ssd/idea-IC-181.4892.42/bin -Dfile.encoding=UTF-8 -classpath /home/grakra/workspace/hadoop_docker/hbase_client_conf:/home/grakra/ssd/jdk1.8.0_131/jre/lib/charsets.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/deploy.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/ext/cldrdata.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/ext/dnsns.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/ext/jaccess.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/ext/jfxrt.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/ext/localedata.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/ext/nashorn.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/ext/sunec.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/ext/sunjce_provider.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/ext/sunpkcs11.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/ext/zipfs.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/javaws.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/jce.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/jfr.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/jfxswt.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/jsse.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/management-agent.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/plugin.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/resources.jar:/home/grakra/ssd/jdk1.8.0_131/jre/lib/rt.jar:/home/grakra/workspace/java_etudes/target/classes:/home/grakra/ssd/.m2/repository/com/google/guava/guava/13.0.1/guava-13.0.1.jar:/home/grakra/ssd/.m2/repository/org/testng/testng/6.4/testng-6.4.jar:/home/grakra/ssd/.m2/repository/junit/junit/3.8.1/junit-3.8.1.jar:/home/grakra/ssd/.m2/repository/org/beanshell/bsh/2.0b4/bsh-2.0b4.jar:/home/grakra/ssd/.m2/repository/com/beust/jcommander/1.12/jcommander-1.12.jar:/home/grakra/ssd/.m2/repository/org/yaml/snakeyaml/1.6/snakeyaml-1.6.jar:/home/grakra/ssd/.m2/repository/org/apache/commons/commons-lang3/3.6/commons-lang3-3.6.jar:/home/grakra/ssd/.m2/repository/io/dropwizard/metrics/metrics-core/3.2.6/metrics-core-3.2.6.jar:/home/grakra/ssd/.m2/repository/org/slf4j/slf4j-api/1.7.22/slf4j-api-1.7.22.jar:/home/grakra/ssd/.m2/repository/javax/json/javax.json-api/1.1.2/javax.json-api-1.1.2.jar:/home/grakra/ssd/.m2/repository/org/glassfish/javax.json/1.1.2/javax.json-1.1.2.jar:/home/grakra/ssd/btrace-bin-1.3.11.3/build/btrace-client.jar:/home/grakra/ssd/btrace-bin-1.3.11.3/build/btrace-boot.jar:/home/grakra/workspace/hadoop_all/hbase/lib/hbase-client-2.1.5.jar:/home/grakra/workspace/hadoop_all/hbase/lib/hbase-protocol-2.1.5.jar:/home/grakra/workspace/hadoop_all/phoenix/phoenix-5.0.0-HBase-2.1.5-wacai-client.jar:/home/grakra/ssd/.m2/repository/org/apache/zookeeper/zookeeper/3.4.8/zookeeper-3.4.8.jar:/home/grakra/ssd/.m2/repository/org/slf4j/slf4j-log4j12/1.6.1/slf4j-log4j12-1.6.1.jar:/home/grakra/ssd/.m2/repository/log4j/log4j/1.2.16/log4j-1.2.16.jar:/home/grakra/ssd/.m2/repository/jline/jline/0.9.94/jline-0.9.94.jar:/home/grakra/ssd/.m2/repository/io/netty/netty/3.7.0.Final/netty-3.7.0.Final.jar:/home/grakra/ssd/.m2/repository/io/netty/netty-all/4.0.23.Final/netty-all-4.0.23.Final.jar phoenix.snipplet.BatchUpsertDemo

Dockerfile-hadoop_debian-8.8

@@ -18,4 +18,4 @@ RUN useradd -u 1000 -s /bin/bash -m hdfs
 RUN usermod -a -G sudo hdfs
 RUN echo hdfs ALL=(ALL) NOPASSWD : ALL > /etc/sudoers
 RUN apt-get update
-RUN apt-get install -y --no-install-recommends iptables && rm -rf /var/lib/apt/lists/*
+RUN apt-get install -y --no-install-recommends iptables net-tools && rm -rf /var/lib/apt/lists/*

emp.sql

@@ -13,7 +13,9 @@ UPSERT INTO EMP VALUES( NEXT VALUE FOR emp_id, 'bob', 28, 'M', 'dave', 'bob@gmai
 UPSERT INTO EMP VALUES( NEXT VALUE FOR emp_id, 'candy', 31, 'M', 'dave', '[email protected]');
 UPSERT INTO EMP VALUES( NEXT VALUE FOR emp_id, 'dave', 31, 'M', 'george', '[email protected]');
 
-CREATE INDEX emp_idx0 ON emp(age DESC, gender, email);
+CREATE INDEX emp_idx0 ON emp(age DESC) include (name,boss) async;
+CREATE INDEX emp_idx1 ON emp(name DESC) include (gender,boss) async;
+CREATE INDEX emp_idx2 ON emp(name DESC, email) include (age,boss) async;
 
 UPSERT INTO EMP VALUES( NEXT VALUE FOR emp_id, 'edword', 0, 'M', 'dave', '[email protected]');
 UPSERT INTO EMP VALUES( NEXT VALUE FOR emp_id, 'ford', 1, 'M', 'dave', '[email protected]');