Package 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	Description
protected int	maxRows
protected UserBitShared.QueryId	queryId
protected final WebUserConnection	webUserConnection
protected final WorkManager	workManager

Constructor Summary

Constructors

Constructor	Description
BaseQueryRunner(WorkManager workManager, WebUserConnection webUserConnection)

Method Summary

Modifier and Type	Method	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 Details

workManager

protected final WorkManager workManager

webUserConnection

protected final WebUserConnection webUserConnection

maxRows

protected int maxRows

queryId

protected UserBitShared.QueryId queryId

Constructor Details

BaseQueryRunner

public BaseQueryRunner(WorkManager workManager,
 WebUserConnection webUserConnection)

Method Details

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)