http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/common/src/main/resources/drill-default.conf ---------------------------------------------------------------------- diff --git a/sandbox/prototype/common/src/main/resources/drill-default.conf b/sandbox/prototype/common/src/main/resources/drill-default.conf deleted file mode 100644 index 760a6d2..0000000 --- a/sandbox/prototype/common/src/main/resources/drill-default.conf +++ /dev/null @@ -1,11 +0,0 @@ -drill: { - logical: { - operator.packages: ["org.apache.drill.common.logical.data"], - expression.packages: ["org.apache.drill.common.expression"], - function.packages: ["org.apache.drill.common.expression"], - storage.packages: [] - }, - physical: { - operator.packages: ["org.apache.drill.common.physical.pop"] - } -}
http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/common/src/main/resources/drill-module.conf ---------------------------------------------------------------------- diff --git a/sandbox/prototype/common/src/main/resources/drill-module.conf b/sandbox/prototype/common/src/main/resources/drill-module.conf deleted file mode 100644 index 2b265ea..0000000 --- a/sandbox/prototype/common/src/main/resources/drill-module.conf +++ /dev/null @@ -1,4 +0,0 @@ -// This file tells Drill to consider this module when class path scanning. -// This file can also include any supplementary configuration information. -// This file is in HOCON format, see https://github.com/typesafehub/config/blob/master/HOCON.md for more information. -drill.exec.storage.packages += org.apache.drill.exec.store.mock \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/common/src/test/java/org/apache/drill/common/expression/parser/TreeTest.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/common/src/test/java/org/apache/drill/common/expression/parser/TreeTest.java b/sandbox/prototype/common/src/test/java/org/apache/drill/common/expression/parser/TreeTest.java deleted file mode 100644 index 1cab357..0000000 --- a/sandbox/prototype/common/src/test/java/org/apache/drill/common/expression/parser/TreeTest.java +++ /dev/null @@ -1,48 +0,0 @@ -package org.apache.drill.common.expression.parser; - -import java.io.File; - -import org.antlr.runtime.ANTLRStringStream; -import org.antlr.runtime.CommonTokenStream; -import org.antlr.runtime.tree.CommonTree; -import org.antlr.runtime.tree.DOTTreeGenerator; -import org.antlr.stringtemplate.StringTemplate; -import org.apache.drill.common.config.DrillConfig; -import org.apache.drill.common.expression.FunctionRegistry; -import org.apache.drill.common.expression.LogicalExpression; -import org.apache.drill.common.expression.parser.ExprParser.parse_return; - -import com.fasterxml.jackson.databind.ObjectMapper; -import com.fasterxml.jackson.databind.SerializationFeature; -import com.google.common.base.Charsets; -import com.google.common.io.Files; - -public class TreeTest { - public static void main(String[] args) throws Exception { - - ExprLexer lexer = new ExprLexer( - new ANTLRStringStream( - "if ($F1) then case when (_MAP.R_NAME = 'AFRICA') then 2 else 4 end else if(4==3) then 1 else if(x==3) then 7 else (if(2==1) then 6 else 4 end) end")); - // ExprLexer lexer = new ExprLexer(new - // ANTLRStringStream("if ('blue.red') then 'orange' else if (false) then 1 else 0 end")); - // ExprLexer lexer = new ExprLexer(new ANTLRStringStream("2+2")); - - CommonTokenStream tokens = new CommonTokenStream(lexer); - - ExprParser parser = new ExprParser(tokens); - parser.setRegistry(new FunctionRegistry(DrillConfig.create())); - parse_return ret = parser.parse(); - LogicalExpression e = ret.e; - ObjectMapper mapper = new ObjectMapper(); - mapper.enable(SerializationFeature.INDENT_OUTPUT); - System.out.println(mapper.writeValueAsString(e)); - - // print the tree - CommonTree tree = (CommonTree) ret.getTree(); - DOTTreeGenerator gen = new DOTTreeGenerator(); - StringTemplate st = gen.toDOT(tree); - - Files.write(st.toString(), new File("/Users/jnadeau/Documents/tree.dot"), Charsets.UTF_8); - - } -} http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/common/src/test/java/org/apache/drill/storage/CheckStorageConfig.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/common/src/test/java/org/apache/drill/storage/CheckStorageConfig.java b/sandbox/prototype/common/src/test/java/org/apache/drill/storage/CheckStorageConfig.java deleted file mode 100644 index 53fcb9e..0000000 --- a/sandbox/prototype/common/src/test/java/org/apache/drill/storage/CheckStorageConfig.java +++ /dev/null @@ -1,48 +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.drill.storage; - -import static org.junit.Assert.assertEquals; - -import java.util.Collection; - -import org.apache.drill.common.config.DrillConfig; -import org.apache.drill.common.logical.LogicalPlan; -import org.apache.drill.common.logical.StorageEngineConfig; -import org.apache.drill.common.util.FileUtils; -import org.apache.drill.common.util.PathScanner; -import org.junit.Test; - -import com.google.common.base.Charsets; -import com.google.common.collect.Lists; -import com.google.common.io.Files; - -public class CheckStorageConfig { - static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(CheckStorageConfig.class); - - @Test - public void ensureStorageEnginePickup() { - Collection<?> engines = PathScanner.scanForImplementations(StorageEngineConfig.class, Lists.newArrayList("org")); - assertEquals(engines.size(), 1); - } - - @Test - public void checkPlanParsing() throws Exception{ - LogicalPlan plan = LogicalPlan.parse(DrillConfig.create(), FileUtils.getResourceAsString("/storage_engine_plan.json")); - } -} http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/common/src/test/java/org/apache/drill/storage/Simple.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/common/src/test/java/org/apache/drill/storage/Simple.java b/sandbox/prototype/common/src/test/java/org/apache/drill/storage/Simple.java deleted file mode 100644 index 4748cc1..0000000 --- a/sandbox/prototype/common/src/test/java/org/apache/drill/storage/Simple.java +++ /dev/null @@ -1,33 +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.drill.storage; - -import org.apache.drill.common.config.DrillConfig; -import org.apache.drill.common.logical.LogicalPlan; -import org.apache.drill.common.util.FileUtils; - -public class Simple { - static final org.slf4j.Logger logger = org.slf4j.LoggerFactory.getLogger(Simple.class); - - public static void main(String[] args) throws Exception { - DrillConfig c = DrillConfig.create(); - LogicalPlan plan = LogicalPlan.parse(c, FileUtils.getResourceAsString("/jdbc_plan.json")); - System.out.println(plan.toJsonString(c)); - } - -} http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/common/src/test/resources/basic_physical.json ---------------------------------------------------------------------- diff --git a/sandbox/prototype/common/src/test/resources/basic_physical.json b/sandbox/prototype/common/src/test/resources/basic_physical.json deleted file mode 100644 index 4d1d329..0000000 --- a/sandbox/prototype/common/src/test/resources/basic_physical.json +++ /dev/null @@ -1,42 +0,0 @@ -{ - head:{ - type:"APACHE_DRILL_PHYSICAL", - version:"1", - generator:{ - type:"manual" - } - }, - storage:{ - fs1:{ - type:"mock" - } - }, - graph:[ - { - @id:1, - pop:"scan", - storageengine:"fs1", - entries:[ - {"test1"} - ], - output:[ - { "name":"key", mode: "VECTOR", type:"SINT32"}, - { "name":"value", mode: "VECTOR", type:"SINT32"} - ] - }, - { - @id:2, - child:1, - pop: "store", - mode: "SYSTEM_CHOICE", - storageengine: "fs1", - entries:[ - { - path:"/sort/sorted/${partition_number}.seq", - key:"Text", - type:"JAVA_SEQUENCE" - } - ] - } - ] -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/common/src/test/resources/donuts-model.json ---------------------------------------------------------------------- diff --git a/sandbox/prototype/common/src/test/resources/donuts-model.json b/sandbox/prototype/common/src/test/resources/donuts-model.json deleted file mode 100644 index f91f7e0..0000000 --- a/sandbox/prototype/common/src/test/resources/donuts-model.json +++ /dev/null @@ -1,19 +0,0 @@ -{ - version: '1.0', - defaultSchema: 'DONUTS', - schemas: [ - { - name: 'DONUTS', - tables: [ - { - name: 'DONUTS', - type: 'custom', - factory: 'org.apache.drill.jdbc.DrillTable$Factory', - operand: { - path: "/donuts.json" - } - } - ] - } - ] -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/common/src/test/resources/drill-module.conf ---------------------------------------------------------------------- diff --git a/sandbox/prototype/common/src/test/resources/drill-module.conf b/sandbox/prototype/common/src/test/resources/drill-module.conf deleted file mode 100644 index 0e2c84e..0000000 --- a/sandbox/prototype/common/src/test/resources/drill-module.conf +++ /dev/null @@ -1 +0,0 @@ -drill.logical.storage.packages += "org.apache.drill.storage" http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/common/src/test/resources/dsort-logical.json ---------------------------------------------------------------------- diff --git a/sandbox/prototype/common/src/test/resources/dsort-logical.json b/sandbox/prototype/common/src/test/resources/dsort-logical.json deleted file mode 100644 index 83d30e8..0000000 --- a/sandbox/prototype/common/src/test/resources/dsort-logical.json +++ /dev/null @@ -1,40 +0,0 @@ -{ - head:{ type:"apache_drill_logical_plan", version:"1", generator:{ type:"manual", info:"na"}}}, - storage:[ { type:"fs", name:"fs1", root:"file:///" }], - query:[ { op: "sequence", sequence: [ - { - op:"scan", - storageengine:"fs1", - ref: "data", - selection: { - path: "/sort/unsorted/*.seq", - type: "JAVA_SEQUENCE" - } - }, - { - op: "order", - orderings: [ - {order: "desc", expr: "data.key" } - ] - }, - { - op: "project", - projections: [ - { ref: "output.key", expr: "data.key" }, - { ref: "output.value", expr: "data.value" } - ] - }, - { - op: "store", - storageengine: "fs1", - target: { - path: "/sort/sorted/${partition}.seq", - type: "JAVA_SEQUENCE", - partition: { - type: "ORDERED", - exprs: ["key"] - } - } - } - ]}] -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/common/src/test/resources/jdbc_plan.json ---------------------------------------------------------------------- diff --git a/sandbox/prototype/common/src/test/resources/jdbc_plan.json b/sandbox/prototype/common/src/test/resources/jdbc_plan.json deleted file mode 100644 index 2d3b9d2..0000000 --- a/sandbox/prototype/common/src/test/resources/jdbc_plan.json +++ /dev/null @@ -1,33 +0,0 @@ -{ - "head":{"type":"APACHE_DRILL_LOGICAL", - "version":"1", - "generator":{"type":"manual","info":"na"} - }, - "storage":{ - "donuts-json":{"type":"classpath"}, - "queue":{"type":"queue"} - }, - "query":[ - {"op":"sequence", - "do":[ - { - "op":"scan", - "memo":"initial_scan", - "ref":"_MAP", - "storageengine":"donuts-json" - ,"selection":{"path":"/donuts.json","type":"JSON"} - }, - { - "op":"filter", - "expr":"(3 < 4)" - }, - { - "op":"store", - "storageengine":"queue", - "memo":"output sink", - "target":{"number":0} - } - ] - } - ] -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/common/src/test/resources/logback.xml ---------------------------------------------------------------------- diff --git a/sandbox/prototype/common/src/test/resources/logback.xml b/sandbox/prototype/common/src/test/resources/logback.xml deleted file mode 100644 index b79b811..0000000 --- a/sandbox/prototype/common/src/test/resources/logback.xml +++ /dev/null @@ -1,45 +0,0 @@ -<?xml version="1.0" encoding="UTF-8" ?> -<configuration> - - <appender name="SOCKET" class="de.huxhorn.lilith.logback.appender.ClassicMultiplexSocketAppender"> - <Compressing>true</Compressing> - <ReconnectionDelay>10000</ReconnectionDelay> - <IncludeCallerData>true</IncludeCallerData> - <RemoteHosts>localhost</RemoteHosts> - </appender> - - <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"> - <!-- encoders are assigned the type - ch.qos.logback.classic.encoder.PatternLayoutEncoder by default --> - <encoder> - <pattern>%d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern> - </encoder> - </appender> - -<!-- - <appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender"> - <file>/logs/test-common.log</file> - <encoder> - <pattern>%date %level [%thread] %logger{10} [%file:%line] %msg%n</pattern> - </encoder> - <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> - <fileNamePattern>/logs/test-common.%d{yyyy-MM-dd}.log</fileNamePattern> - <maxHistory>30</maxHistory> - </rollingPolicy> - </appender> - --> - <logger name="org.apache.drill" additivity="false"> - <level value="debug" /> - <appender-ref ref="SOCKET" /> - <appender-ref ref="STDOUT" /> -<!-- <appender-ref ref="FILE" /> --> - </logger> - - <root> - <level value="error" /> - <appender-ref ref="SOCKET" /> - <appender-ref ref="STDOUT" /> -<!-- <appender-ref ref="FILE" /> --> - </root> - -</configuration> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/common/src/test/resources/simple_plan.json ---------------------------------------------------------------------- diff --git a/sandbox/prototype/common/src/test/resources/simple_plan.json b/sandbox/prototype/common/src/test/resources/simple_plan.json deleted file mode 100644 index 2457b1f..0000000 --- a/sandbox/prototype/common/src/test/resources/simple_plan.json +++ /dev/null @@ -1,133 +0,0 @@ -{ - head:{ - type:"apache_drill_logical_plan", - version:"1", - generator:{ - type:"manual", - info:"na" - } - }, - storage:{ - logs: { - type:"text", - file: "local://logs/*.log", - compress:"gzip", - line-delimiter:"\n", - record-maker:{ - type:"first-row", - delimiter:"," - } - }, - { - type:"mongo", - name:"users", - connection:"mongodb://blue:red@localhost/users" - }, - { - type:"mysql", - name:"mysql", - connection:"jdbc:mysql://localhost/main" - } - ], - query:[ - { - @id:"1", - op:"scan", - memo:"initial_scan", - storageengine:"local-logs", - selection: {} - }, - { - @id:"2", - input:"1", - memo:"transform1", - op:"transform", - transforms:[ - { - ref:"userId", - expr:"regex_like('activity.cookie', \"persistent=([^;]*)\")" - }, - { - ref:"session", - expr:"regex_like('activity.cookie', \"session=([^;]*)\")" - } - ] - }, - { - @id:"3", - input:"2", - memo:"transform2", - op:"transform", - transforms:[ - { - ref:"userId", - expr:"regex_like('activity.cookie', \"persistent=([^;]*)\")" - }, - { - ref:"session", - expr:"regex_like('activity.cookie', \"session=([^;]*)\")" - } - ] - }, - { - @id:"7", - input:"3", - op:"sequence", - do:[ - { - op:"transform", - memo:"seq_transform", - transforms:[ - { - ref:"happy", - expr:"regex_like('ep2', \"dink\")" - } - ] - } - , - { - op:"transform", - memo:"last_transform", - transforms:[ - { - ref:"abc", - expr:"123" - } - ] - } - ] - }, - { - @id:"10", - input:"3", - op:"transform", - memo:"t3", - transforms:[ - { - ref:"happy", - expr:"regex_like('ep2', \"dink\")" - } - ] - }, - { - @id:12, - op:"join", - type: "inner", - left:"7", - right:"10", - conditions: [{relationship:"==", left: "1", right: "1" }] - } - , - { - input: 12, - op: "store", - memo: "output sink", - target: { - file: "console:///stdout" - } - - } - - - ] -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/common/src/test/resources/storage_engine_plan.json ---------------------------------------------------------------------- diff --git a/sandbox/prototype/common/src/test/resources/storage_engine_plan.json b/sandbox/prototype/common/src/test/resources/storage_engine_plan.json deleted file mode 100644 index efde80d..0000000 --- a/sandbox/prototype/common/src/test/resources/storage_engine_plan.json +++ /dev/null @@ -1,30 +0,0 @@ -{ - head:{ - type:"APACHE_DRILL_LOGICAL", - version:"1", - generator:{ - type:"manual", - info:"na" - } - }, - storage:{ - mock-engine: { - type:"mock", - url: "http://www.apache.org/"; - } - }, - query:[ - { - @id:"1", - op:"scan", - storageengine:"mock-engine", - selection: {} - }, - { - input: 1, - op: "store", - storageengine:"mock-engine", - target: {} - } - ] -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/pom.xml ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/pom.xml b/sandbox/prototype/contrib/pom.xml deleted file mode 100644 index e521ffe..0000000 --- a/sandbox/prototype/contrib/pom.xml +++ /dev/null @@ -1,22 +0,0 @@ -<?xml version="1.0"?> -<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"; xmlns="http://maven.apache.org/POM/4.0.0"; - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";> - <modelVersion>4.0.0</modelVersion> - <parent> - <artifactId>drill-root</artifactId> - <groupId>org.apache.drill</groupId> - <version>1.0.0-m1-SNAPSHOT</version> - </parent> - <groupId>org.apache.drill.contrib</groupId> - <artifactId>contrib-parent</artifactId> - <name>contrib/Parent Pom</name> - <packaging>pom</packaging> - - <dependencies> - - </dependencies> - <modules> - <module>storage-hbase</module> - <module>sqlline</module> - </modules> -</project> http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/sqlline/pom.xml ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/sqlline/pom.xml b/sandbox/prototype/contrib/sqlline/pom.xml deleted file mode 100644 index fa8cc7f..0000000 --- a/sandbox/prototype/contrib/sqlline/pom.xml +++ /dev/null @@ -1,38 +0,0 @@ -<?xml version="1.0"?> -<project - xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"; - xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";> - <modelVersion>4.0.0</modelVersion> - <parent> - <artifactId>prototype-parent</artifactId> - <groupId>org.apache.drill</groupId> - <version>1.0-SNAPSHOT</version> - </parent> - <artifactId>sqlline</artifactId> - <name>contrib/sqlline</name> - - <dependencies> - <dependency> - <groupId>org.apache.drill</groupId> - <artifactId>sqlparser</artifactId> - <version>1.0-SNAPSHOT</version> - </dependency> - - <dependency> - <groupId>sqlline</groupId> - <artifactId>sqlline</artifactId> - <version>1.1.0</version> - </dependency> - <!-- Specify xalan and xerces versions to avoid setXIncludeAware error. --> - <dependency> - <groupId>xerces</groupId> - <artifactId>xercesImpl</artifactId> - <version>2.9.1</version> - </dependency> - <dependency> - <groupId>xalan</groupId> - <artifactId>xalan</artifactId> - <version>2.7.1</version> - </dependency> - </dependencies> -</project> http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/storage-hbase/pom.xml ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/storage-hbase/pom.xml b/sandbox/prototype/contrib/storage-hbase/pom.xml deleted file mode 100644 index a13b970..0000000 --- a/sandbox/prototype/contrib/storage-hbase/pom.xml +++ /dev/null @@ -1,17 +0,0 @@ -<?xml version="1.0"?> -<project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"; xmlns="http://maven.apache.org/POM/4.0.0"; - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";> - <modelVersion>4.0.0</modelVersion> - <parent> - <artifactId>contrib-parent</artifactId> - <groupId>org.apache.drill.contrib</groupId> - <version>1.0.0-m1-SNAPSHOT</version> - </parent> - - <artifactId>storage-hbase</artifactId> - - <name>contrib/hbase-storage-engine</name> - - <dependencies> - </dependencies> -</project> http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/synth-log/README.md ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/synth-log/README.md b/sandbox/prototype/contrib/synth-log/README.md deleted file mode 100644 index b4efc63..0000000 --- a/sandbox/prototype/contrib/synth-log/README.md +++ /dev/null @@ -1,55 +0,0 @@ -log-synth -========= - -The basic idea here is to have a random log generator build fairly realistic log files for analysis. The analyses specified here are fairly typical use cases for trying to figure out where the load on a web-site is coming from. - -How to Run It -============ - -Install Java 7, maven and get this software using git. - -On a mac, this can help get the right version of Java - - export JAVA_HOME=$(/usr/libexec/java_home) - -Then do this to build a jar file with all dependencies included - - mvn package - -Then use this to write one million log lines into the file "log" and to write the associated user database into the file "users". - - java -cp target/log-synth-0.1-SNAPSHOT-jar-with-dependencies.jar org.apache.drill.synth.Main 1M log users - -This program will produce a line of output on the standard output for each 10,000 lines of log produced. Each line will contain the number of log lines produced so far and the number of unique users in the user profile database. - - -The Data Source -============== -The data source here is a set of heavily biased random numbers to generate traffic sources, response times and queries. In order to give a realistic long-tail experience the data are generated using special random number generators available in the Mahout library. - -There are three basic entities involved in the random process that generates these logs that are IP addresses, users and queries. Users have a basic traffic rate and a variable number of users sit behind each IP address. Queries are composed of words which are generated somewhat differently by each user. The response time for each query is determined based on the terms in the queries with a very few terms causing much longer queries than others. Each log line contains an IP address, a user cookie, a query and a response time. - -Logs of various sizes can be generated using the generator tools. - -The Queries -============== -The general goal of the queries is to find out what and/or who is causing long query times and where lots of traffic is coming from. - -The questions we would like to answer include: - -* What are the top IP addresses by request count? -* What are the top IP addresses by unique user? -* What are the most common search terms? -* What are the most common search terms in the slowest 5% of the queries? -* What is the daily number of searches, (approximate) number of unique users, (approximate) number of unique IP addresses and distribution of response times (average, min, max, 25, 50 and 75%-iles). - -Methods -======== -The general process for generating log lines is to select a user, possibly one we have not seen before. If the user is new, then we need to select an IP address for the user. Otherwise, we remember the IP address for each user. - -Queries have an overall frequency distribution that is long-tailed, but each user has a variation on that distribution. In order to model this, we sample each user's queries from a per-user Pittman-Yor process. In order to make users have similar query term distributions, each user's query term distribution is initialized from a Pittman-Yor process that has already been sampled a number of times. - -We also need to maintain an average response time per term. The response time for each query is exponentially distributed with a mean equal to the sum of the average response times for the terms. Response times for words are sampled either from an exponential distribution, from a log-gamma distribution or from a gamma distribution with a moderately low shape parameter so that we can have interestingly long tails for response time. - -Users are assigned to IP addresses using a Pittman-Yor process with a discount of 0.9. This gives long-tailed distribution to the number of users per IP address. This results in 90% of all IP addresses having only a single user. - http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/synth-log/pom.xml ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/synth-log/pom.xml b/sandbox/prototype/contrib/synth-log/pom.xml deleted file mode 100644 index a8c4e6c..0000000 --- a/sandbox/prototype/contrib/synth-log/pom.xml +++ /dev/null @@ -1,67 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> -<project xmlns="http://maven.apache.org/POM/4.0.0"; - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; - xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> - <modelVersion>4.0.0</modelVersion> - - <groupId>log-synth</groupId> - <artifactId>log-synth</artifactId> - <version>0.1-SNAPSHOT</version> - - <dependencies> - <dependency> - <groupId>org.apache.mahout</groupId> - <artifactId>mahout-math</artifactId> - <version>0.8-SNAPSHOT</version> - </dependency> - <dependency> - <groupId>junit</groupId> - <artifactId>junit</artifactId> - <version>4.8.2</version> - </dependency> - <dependency> - <groupId>org.slf4j</groupId> - <artifactId>slf4j-api</artifactId> - <version>1.6.6</version> - </dependency> - <dependency> - <groupId>org.slf4j</groupId> - <artifactId>slf4j-log4j12</artifactId> - <version>1.6.6</version> - <scope>runtime</scope> - </dependency> - </dependencies> - <build> - <plugins> - <plugin> - <artifactId>maven-assembly-plugin</artifactId> - <version>2.4</version> - <configuration> - <descriptorRefs> - <descriptorRef>jar-with-dependencies</descriptorRef> - </descriptorRefs> - </configuration> - <executions> - <execution> - <id>make-assembly</id> - <phase>package</phase> - <!-- bind to the packaging phase --> - <goals> - <goal>single</goal> - </goals> - </execution> - </executions> - </plugin> - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-compiler-plugin</artifactId> - <version>3.0</version> - <configuration> - <verbose>true</verbose> - <compilerVersion>1.7</compilerVersion> - </configuration> - </plugin> - </plugins> - </build> - -</project> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/ChineseRestaurant.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/ChineseRestaurant.java b/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/ChineseRestaurant.java deleted file mode 100644 index 0288071..0000000 --- a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/ChineseRestaurant.java +++ /dev/null @@ -1,118 +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.drill.synth; - -import com.google.common.base.Preconditions; -import org.apache.mahout.common.RandomUtils; -import org.apache.mahout.math.list.DoubleArrayList; -import org.apache.mahout.math.random.Sampler; - -import java.util.Random; - -/** - * - * Generates samples from a generalized Chinese restaurant process (or Pittman-Yor process). - * - * The number of values drawn exactly once will asymptotically be equal to the discount parameter - * as the total number of draws T increases without bound. The number of unique values sampled will - * increase as O(alpha * log T) if discount = 0 or O(alpha * T^discount) for discount > 0. - */ -public final class ChineseRestaurant implements Sampler<Integer> { - private final double alpha; - private double weight = 0; - private double discount = 0; - private final DoubleArrayList weights = new DoubleArrayList(); - private final Random rand = RandomUtils.getRandom(); - - /** - * Constructs a Dirichlet process sampler. This is done by setting discount = 0. - * @param alpha The strength parameter for the Dirichlet process. - */ - public ChineseRestaurant(double alpha) { - this(alpha, 0); - } - - /** - * Constructs a Pitman-Yor sampler. - * - * @param alpha The strength parameter that drives the number of unique values as a function of draws. - * @param discount The discount parameter that drives the percentage of values that occur once in a large sample. - */ - public ChineseRestaurant(double alpha, double discount) { - Preconditions.checkArgument(alpha > 0); - Preconditions.checkArgument(discount >= 0 && discount <= 1); - this.alpha = alpha; - this.discount = discount; - } - - public Integer sample() { - double u = rand.nextDouble() * (alpha + weight); - for (int j = 0; j < weights.size(); j++) { - // select existing options with probability (w_j - d) / (alpha + w) - if (u < weights.get(j) - discount) { - weights.set(j, weights.get(j) + 1); - weight++; - return j; - } else { - u -= weights.get(j) - discount; - } - } - - // if no existing item selected, pick new item with probability (alpha - d*t) / (alpha + w) - // where t is number of pre-existing cases - weights.add(1); - weight++; - return weights.size() - 1; - } - - /** - * @return the number of unique values that have been returned. - */ - public int size() { - return weights.size(); - } - - /** - * @return the number draws so far. - */ - public int count() { - return (int) weight; - } - - /** - * @param j Which value to test. - * @return The number of times that j has been returned so far. - */ - public int count(int j) { - Preconditions.checkArgument(j >= 0); - - if (j < weights.size()) { - return (int) weights.get(j); - } else { - return 0; - } - } - - public void setCount(int term, double count) { - while (weights.size() <= term) { - weights.add(0); - } - weight += (count - weights.get(term)); - weights.set(term, count); - } -} http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/LogGenerator.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/LogGenerator.java b/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/LogGenerator.java deleted file mode 100644 index 38ce01c..0000000 --- a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/LogGenerator.java +++ /dev/null @@ -1,57 +0,0 @@ -package org.apache.drill.synth; - -import org.apache.mahout.math.random.Sampler; - -import java.net.Inet4Address; -import java.net.InetAddress; -import java.net.UnknownHostException; -import java.util.Random; - -/** - * Generates kind of realistic log lines consisting of a user id (a cookie), an IP address and a query. - */ -public class LogGenerator implements Sampler<LogLine> { - private LongTail<InetAddress> ipGenerator = new LongTail<InetAddress>(1, 0.5) { - Random gen = new Random(); - - @Override - protected InetAddress createThing() { - int address = gen.nextInt(); - try { - return Inet4Address.getByAddress(new byte[]{ - (byte) (address >>> 24), - (byte) (0xff & (address >>> 16)), - (byte) (0xff & (address >>> 8)), - (byte) (0xff & (address)) - }); - } catch (UnknownHostException e) { - throw new RuntimeException("Can't happen with numeric IP address", e); - } - } - }; - - private WordGenerator words = new WordGenerator("word-frequency-seed", "other-words"); - private TermGenerator terms = new TermGenerator(words, 1, 0.8); - private TermGenerator geo = new TermGenerator(new WordGenerator(null, "geo-codes"), 10, 0 - ); - - private LongTail<User> userGenerator = new LongTail<User>(50000, 0) { - @Override - protected User createThing() { - return new User(ipGenerator.sample(), geo, terms); - } - }; - - public Iterable<User> getUsers() { - return userGenerator.getThings(); - } - - public LogLine sample() { - // pick a user - return new LogLine(userGenerator.sample()); - } - - public int getUserCount() { - return userGenerator.getThings().size(); - } -} http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/LogLine.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/LogLine.java b/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/LogLine.java deleted file mode 100644 index 64bc8c7..0000000 --- a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/LogLine.java +++ /dev/null @@ -1,37 +0,0 @@ -package org.apache.drill.synth; - -import java.net.InetAddress; -import java.util.Formatter; -import java.util.List; - -/** - * A log line contains a user id, an IP address and a query. - */ -public class LogLine { - private InetAddress ip; - private long cookie; - private List<String> query; - - public LogLine(InetAddress ip, long cookie, List<String> query) { - this.cookie = cookie; - this.ip = ip; - this.query = query; - } - - public LogLine(User user) { - this(user.getAddress(), user.getCookie(), user.getQuery()); - } - - @Override - public String toString() { - Formatter r = new Formatter(); - r.format("{cookie:\"%08x\", ip:\"%s\", query:", cookie, ip.getHostAddress()); - String sep = "["; - for (String term : query) { - r.format("%s\"%s\"", sep, term); - sep = ", "; - } - r.format("]}"); - return r.toString(); - } -} http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/LongTail.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/LongTail.java b/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/LongTail.java deleted file mode 100644 index 1a46e52..0000000 --- a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/LongTail.java +++ /dev/null @@ -1,45 +0,0 @@ -package org.apache.drill.synth; - -import com.google.common.collect.Lists; -import org.apache.mahout.math.random.Sampler; - -import java.util.List; - -/** - * Samples from a set of things based on a long-tailed distribution. This converts - * the ChineseRestaurant distribution from a distribution over integers into a distribution - * over more plausible looking things like words. - */ -public abstract class LongTail<T> implements Sampler<T> { - private ChineseRestaurant base; - private List<T> things = Lists.newArrayList(); - - protected LongTail(double alpha, double discount) { - base = new ChineseRestaurant(alpha, discount); - } - - public T sample() { - int n = base.sample(); - while (n >= things.size()) { - things.add(createThing()); - } - return things.get(n); - } - - public ChineseRestaurant getBaseDistribution() { - return base; - } - - protected abstract T createThing(); - - public List<T> getThings() { - return things; - } - - public void setThing(int i, T thing) { - while (things.size() <= i) { - things.add(null); - } - things.set(i, thing); - } -} http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/Main.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/Main.java b/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/Main.java deleted file mode 100644 index 2641dd5..0000000 --- a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/Main.java +++ /dev/null @@ -1,57 +0,0 @@ -package org.apache.drill.synth; - - -import com.google.common.base.Charsets; -import com.google.common.io.Files; - -import java.io.BufferedWriter; -import java.io.File; -import java.io.IOException; - -/** - * Create a query log with a specified number of log lines and an associated user profile database. - * <p/> - * Command line args include number of log lines to generate, the name of the log file to generate and the - * name of the file to store the user profile database in. - * <p/> - * Log lines and user profile entries are single line JSON. - */ -public class Main { - public static void main(String[] args) throws IOException { - - int n = Integer.parseInt(args[0].replaceAll("[KMG]?$", "")); - - switch (args[0].charAt(args[0].length() - 1)) { - case 'G': - n *= 1e9; - break; - case 'M': - n *= 1e6; - break; - case 'K': - n *= 1e3; - break; - default: - // no suffix leads here - break; - } - - LogGenerator lg = new LogGenerator(); - BufferedWriter log = Files.newWriter(new File(args[1]), Charsets.UTF_8); - for (int i = 0; i < n; i++) { - if (i % 10000 == 0) { - System.out.printf("%d %d\n", i, lg.getUserCount()); - } - log.write(lg.sample().toString()); - log.newLine(); - } - log.close(); - - BufferedWriter profile = Files.newWriter(new File(args[2]), Charsets.UTF_8); - for (User user : lg.getUsers()) { - profile.write(user.toString()); - profile.newLine(); - } - profile.close(); - } -} http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/TermGenerator.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/TermGenerator.java b/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/TermGenerator.java deleted file mode 100644 index 85b9f54..0000000 --- a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/TermGenerator.java +++ /dev/null @@ -1,39 +0,0 @@ -package org.apache.drill.synth; - -import org.apache.mahout.math.random.Sampler; - -/** - * Generate words at random from a specialized vocabulary. Every term generator's - * frequency distribution has a common basis, but each will diverge after initialization. - */ -public class TermGenerator implements Sampler<String> { - // the word generator handles the problem of making up new words - // it also provides the seed frequencies - private WordGenerator words; - - private LongTail<String> distribution; - - public TermGenerator(WordGenerator words, final int alpha, final double discount) { - this.words = words; - distribution = new LongTail<String>(alpha, discount) { - private int count = TermGenerator.this.words.size(); - - @Override - protected String createThing() { - return TermGenerator.this.words.getString(count++); - } - }; - - int i = 0; - for (String word : this.words.getBaseWeights().keySet()) { - distribution.getBaseDistribution().setCount(i, this.words.getBaseWeights().get(word)); - distribution.setThing(i, word); - i++; - } - - } - - public String sample() { - return distribution.sample(); - } -} http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/User.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/User.java b/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/User.java deleted file mode 100644 index 3c85c1f..0000000 --- a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/User.java +++ /dev/null @@ -1,57 +0,0 @@ -package org.apache.drill.synth; - -import com.google.common.collect.Lists; -import org.apache.mahout.common.RandomUtils; -import org.apache.mahout.math.jet.random.Exponential; - -import java.net.InetAddress; -import java.util.List; - -/** - * Created with IntelliJ IDEA. - * User: tdunning - * Date: 2/2/13 - * Time: 6:15 PM - * To change this template use File | Settings | File Templates. - */ -public class User { - private Exponential queryLengthDistribution = new Exponential(0.4, RandomUtils.getRandom()); - - private long cookie = RandomUtils.getRandom().nextLong(); - - private TermGenerator terms; - private InetAddress address; - private String geoCode; - - public User(InetAddress address, TermGenerator geoCoder, TermGenerator terms) { - this.terms = terms; - geoCode = geoCoder.sample(); - this.address = address; - } - - public InetAddress getAddress() { - return address; - } - - public long getCookie() { - return cookie; - } - - public List<String> getQuery() { - int n = queryLengthDistribution.nextInt() + 1; - List<String> r = Lists.newArrayList(); - for (int i = 0; i < n; i++) { - r.add(terms.sample()); - } - return r; - } - - public String getGeoCode() { - return geoCode; - } - - @Override - public String toString() { - return String.format("{ip:\"%s\", cookie:\"%08x\", geo:\"%s\"}", address, cookie, geoCode); - } -} http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/WordGenerator.java ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/WordGenerator.java b/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/WordGenerator.java deleted file mode 100644 index f9a4d47..0000000 --- a/sandbox/prototype/contrib/synth-log/src/main/java/org/apache/drill/synth/WordGenerator.java +++ /dev/null @@ -1,107 +0,0 @@ -package org.apache.drill.synth; - -import com.google.common.base.Charsets; -import com.google.common.base.Splitter; -import com.google.common.collect.Lists; -import com.google.common.collect.Maps; -import com.google.common.io.LineProcessor; -import com.google.common.io.Resources; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import java.io.BufferedReader; -import java.io.IOException; -import java.net.URI; -import java.net.URISyntaxException; -import java.nio.file.Files; -import java.nio.file.Path; -import java.nio.file.Paths; -import java.util.Iterator; -import java.util.List; -import java.util.Map; - -/** - * Emulates an infinite list of words, a prefix of which are taken from lists of plausible words. The first words - * are taken from a resource that has frequencies in it. These frequencies can be used to initialize term - * generators to a common language. The next batch of words are taken from a long list of words with no frequencies. - * After that, words are coined by using an integer count. - */ -public class WordGenerator { - private final Logger log = LoggerFactory.getLogger(WordGenerator.class); - - private BufferedReader wordReader; - private final List<String> words = Lists.newArrayList(); - private final Map<String, Integer> baseWeights = Maps.newLinkedHashMap(); - - public WordGenerator(String seed, String others) { - // read the common words - if (seed != null) { - try { - Resources.readLines(Resources.getResource(seed), Charsets.UTF_8, - new LineProcessor<Object>() { - private boolean header = true; - private final Splitter onTabs = Splitter.on("\t"); - - public boolean processLine(String s) throws IOException { - if (!s.startsWith("#")) { - if (!header) { - Iterator<String> fields = onTabs.split(s).iterator(); - fields.next(); - String word = fields.next(); - words.add(word); - int count = (int) Math.rint(Double.parseDouble(fields.next())); - baseWeights.put(word, count); - } else { - header = false; - } - } - return true; - } - - public Object getResult() { - return null; - } - }); - } catch (IOException e) { - log.error("Can't read resource \"{}\", will continue without realistic words", seed); - } - } - - try { - wordReader = new BufferedReader(Resources.newReaderSupplier(Resources.getResource(others), Charsets.UTF_8).getInput()); - } catch (IOException e) { - log.error("Can't read resource \"{}\", will continue without realistic words", others); - wordReader = null; - } - - } - - public String getString(int n) { - if (n >= words.size()) { - synchronized (this) { - while (n >= words.size()) { - try { - String w = wordReader.readLine(); - if (w != null) { - words.add(w); - } else { - words.add("w-" + n); - } - } catch (IOException e) { - log.error("Error reading other words resource", e); - words.add("w-" + n); - } - } - } - } - return words.get(n); - } - - public Map<String, Integer> getBaseWeights() { - return baseWeights; - } - - public int size() { - return words.size(); - } -} http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/synth-log/src/main/resources/geo-codes ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/synth-log/src/main/resources/geo-codes b/sandbox/prototype/contrib/synth-log/src/main/resources/geo-codes deleted file mode 100644 index f08d1fc..0000000 --- a/sandbox/prototype/contrib/synth-log/src/main/resources/geo-codes +++ /dev/null @@ -1,297 +0,0 @@ -AL -AK -AZ -AR -CA -CO -CT -DE -FL -GA -HI -ID -IL -IN -IA -KS -KY -LA -ME -MD -MA -MI -MN -MS -MO -MT -NE -NV -NH -NJ -NM -NY -NC -ND -OH -OK -OR -PA -RI -SC -SD -TN -TX -UT -VT -VA -WA -WV -WI -WY -AS -DC -FM -GU -MH -MP -PW -PR -VI -AF -AL -DZ -AS -AD -AO -AI -AQ -AG -AR -AM -AW -AU -AT -AZ -BS -BH -BD -BB -BY -BE -BZ -BJ -BM -BT -BO -BA -BW -BV -BR -IO -BN -BG -BF -BI -KH -CM -CA -CV -KY -CF -TD -CL -CN -CX -CC -CO -KM -CG -CD -CK -CR -CI -HR -CU -CY -CZ -DK -DJ -DM -DO -TP -EC -EG -SV -GQ -ER -EE -ET -FK -FO -FJ -FI -FR -FX -GF -PF -TF -GA -GM -GE -DE -GH -GI -GR -GL -GD -GP -GU -GT -GN -GW -GY -HT -HM -VA -HN -HK -HU -IS -IN -ID -IR -IQ -IE -IL -IT -JM -JP -JO -KZ -KE -KI -KP -KR -KW -KG -LA -LV -LB -LS -LR -LY -LI -LT -LU -MO -MK -MG -MW -MY -MV -ML -MT -MH -MQ -MR -MU -YT -MX -FM -MD -MC -MN -MS -MA -MZ -MM -NA -NR -NP -NL -AN -NC -NZ -NI -NE -NG -NU -NF -MP -NO -OM -PK -PW -PA -PG -PY -PE -PH -PN -PL -PT -PR -QA -RE -RO -RU -RW -KN -LC -VC -WS -SM -ST -SA -SN -SC -SL -SG -SK -SI -SB -SO -ZA -GS -ES -LK -SH -PM -SD -SR -SJ -SZ -SE -CH -SY -TW -TJ -TZ -TH -TG -TK -TO -TT -TN -TR -TM -TC -TV -UG -UA -AE -GB -US -UM -UY -UZ -VU -VE -VN -VG -VI -WF -EH -YE -ZM -ZW \ No newline at end of file http://git-wip-us.apache.org/repos/asf/incubator-drill/blob/a593d908/sandbox/prototype/contrib/synth-log/src/main/resources/log4j.properties ---------------------------------------------------------------------- diff --git a/sandbox/prototype/contrib/synth-log/src/main/resources/log4j.properties b/sandbox/prototype/contrib/synth-log/src/main/resources/log4j.properties deleted file mode 100644 index 972574a..0000000 --- a/sandbox/prototype/contrib/synth-log/src/main/resources/log4j.properties +++ /dev/null @@ -1,11 +0,0 @@ -# Set root logger level to DEBUG and its only appender to A1. -log4j.rootLogger=DEBUG, A1 - -# A1 is set to be a ConsoleAppender. -log4j.appender.A1=org.apache.log4j.ConsoleAppender - -# A1 uses PatternLayout. -log4j.appender.A1.layout=org.apache.log4j.PatternLayout -log4j.appender.A1.layout.ConversionPattern=%-4r [%t] %-5p %c %x - %m%n - -log4j.logger.org.apache=off
