org.apache.drill.exec.server.rest

Class BaseQueryRunner

java.lang.Object

org.apache.drill.exec.server.rest.BaseQueryRunner

Direct Known Subclasses:

QueryRunner, RestQueryRunner

public abstract class BaseQueryRunner
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected int	maxRows
protected UserBitShared.QueryId	queryId
protected WebUserConnection	webUserConnection
protected WorkManager	workManager

Constructor Summary

Constructors

Constructor and Description
BaseQueryRunner(WorkManager workManager, WebUserConnection webUserConnection)

Method Summary

Modifier and Type	Method and Description
protected void	applyDefaultSchema(String defaultSchema)
protected void	applyOptions(Map<String,String> options)
protected void	applyRowLimit(int limit)
protected void	applyUserName(String userName)
protected void	startQuery(UserBitShared.QueryType queryType, String query, UserClientConnection clientConn)

Methods inherited from class java.lang.Object

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

Field Detail

workManager

protected final WorkManager workManager

webUserConnection

protected final WebUserConnection webUserConnection

maxRows

protected int maxRows

queryId

protected UserBitShared.QueryId queryId

Constructor Detail

BaseQueryRunner

public BaseQueryRunner(WorkManager workManager,
                       WebUserConnection webUserConnection)

Method Detail

applyUserName

protected void applyUserName(String userName)

applyOptions

protected void applyOptions(Map<String,String> options)

applyDefaultSchema

protected void applyDefaultSchema(String defaultSchema)
                           throws org.apache.calcite.tools.ValidationException

Throws:

org.apache.calcite.tools.ValidationException

applyRowLimit

protected void applyRowLimit(int limit)

startQuery

protected void startQuery(UserBitShared.QueryType queryType,
                          String query,
                          UserClientConnection clientConn)