org.apache.lens.driver.es.translator

Class ESVisitor

java.lang.Object

org.apache.lens.driver.es.translator.ESVisitor

All Implemented Interfaces:

ASTVisitor

Direct Known Subclasses:

ESAggregateVisitor, ESTermVisitor

public abstract class ESVisitor
extends Object
implements ASTVisitor

The abstract visitor for constructing elastic search queries from ASTNode

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.lens.driver.es.translator.ASTVisitor

ASTVisitor.OrderBy

Method Summary

Modifier and Type	Method and Description
ESQuery	getQuery()
static ESQuery	rewrite(ESDriverConfig config, org.apache.hadoop.hive.ql.parse.ASTNode rootQueryNode)
static ESQuery	rewrite(ESDriverConfig config, String hql)
void	visitAllCols()
void	visitCriteria(ASTCriteriaVisitor visitedSubTree)
void	visitFrom(String database, String table)
void	visitLimit(int limit)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.lens.driver.es.translator.ASTVisitor

completeVisit, visitAggregation, visitGroupBy, visitOrderBy, visitSimpleSelect

Method Detail

rewrite

public static ESQuery rewrite(ESDriverConfig config,
                              String hql)
                       throws LensException

Throws:

LensException

rewrite

public static ESQuery rewrite(ESDriverConfig config,
                              org.apache.hadoop.hive.ql.parse.ASTNode rootQueryNode)
                       throws LensException

Throws:

LensException

visitFrom

public void visitFrom(String database,
                      String table)

Specified by:

visitFrom in interface ASTVisitor

visitLimit

public void visitLimit(int limit)

Specified by:

visitLimit in interface ASTVisitor

visitCriteria

public void visitCriteria(ASTCriteriaVisitor visitedSubTree)

Specified by:

visitCriteria in interface ASTVisitor

visitAllCols

public void visitAllCols()

Specified by:

visitAllCols in interface ASTVisitor

getQuery

public ESQuery getQuery()