Apache
/
druid
mirror of https://github.com/apache/druid.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

more elaborate example

This commit is contained in:
xvrl 2013-03-04 14:48:05 -08:00
parent 88515ec59f
commit d1c128bdbf
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
client/src/main/java/com/metamx/druid/sql/SQLRunner.java
View File

@ -10,6 +10,7 @@ import com.metamx.druid.query.group.GroupByQuery;
import com.metamx.druid.sql.antlr4.DruidSQLLexer; import com.metamx.druid.sql.antlr4.DruidSQLLexer;
import com.metamx.druid.sql.antlr4.DruidSQLParser; import com.metamx.druid.sql.antlr4.DruidSQLParser;
import org.antlr.v4.runtime.ANTLRInputStream; import org.antlr.v4.runtime.ANTLRInputStream;
import org.antlr.v4.runtime.BailErrorStrategy;
import org.antlr.v4.runtime.CharStream; import org.antlr.v4.runtime.CharStream;
import org.antlr.v4.runtime.CommonTokenStream; import org.antlr.v4.runtime.CommonTokenStream;
import org.antlr.v4.runtime.TokenStream; import org.antlr.v4.runtime.TokenStream;
@ -23,10 +24,11 @@ import java.util.ArrayList;
public class SQLRunner public class SQLRunner
{ {
private static final String STATEMENT = "select count(*), sum(count) / count(*) as avg from wikipedia where" private static final String STATEMENT = "select count(*), (1 - count(*) / sum(count)) * 100 as ratio from wikipedia where"
+ " timestamp between '2013-02-01' and '2013-02-14'" + " timestamp between '2013-02-01' and '2013-02-14'"
+ " and namespace = 'article'" + " and (namespace = 'article' or page ~ 'Talk:.*')"
+ " and ( language = 'en' or language = 'fr' ) " + " and language in ( 'en', 'fr' ) "
+ " and user ~ '(?i)^david.*'"
+ " group by granularity(timestamp, 'day'), language"; + " group by granularity(timestamp, 'day'), language";
public static void main(String[] args) throws Exception public static void main(String[] args) throws Exception
@ -40,12 +42,12 @@ public class SQLRunner
DruidSQLLexer lexer = new DruidSQLLexer(stream); DruidSQLLexer lexer = new DruidSQLLexer(stream);
TokenStream tokenStream = new CommonTokenStream(lexer); TokenStream tokenStream = new CommonTokenStream(lexer);
DruidSQLParser parser = new DruidSQLParser(tokenStream); DruidSQLParser parser = new DruidSQLParser(tokenStream);
parser.setErrorHandler(new BailErrorStrategy());
DruidSQLParser.QueryContext q = parser.query(); DruidSQLParser.QueryContext queryContext = parser.query();
// parser.setBuildParseTree(true);
parser.setBuildParseTree(true); // System.err.println(q.toStringTree(parser));
System.err.println(q.toStringTree(parser));
Query query; Query query;