org.apache.lens.server.api.query

Class QueryContext

java.lang.Object

org.apache.lens.server.api.query.AbstractQueryContext

org.apache.lens.server.api.query.QueryContext

All Implemented Interfaces:

Serializable

public class QueryContext
extends AbstractQueryContext

The Class QueryContext.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.lens.server.api.query.AbstractQueryContext

AbstractQueryContext.DriverEstimateRunnable

Constructor Summary

Constructors

Constructor and Description
QueryContext(PreparedQueryContext prepared, String user, LensConf qconf, org.apache.hadoop.conf.Configuration conf) Creates context from PreparedQueryContext
QueryContext(String query, String user, LensConf qconf, org.apache.hadoop.conf.Configuration conf, Collection<LensDriver> drivers) Creates context from query

Method Summary

Methods

Modifier and Type	Method and Description
static QueryContext	createContextWithSingleDriver(String query, String user, LensConf qconf, org.apache.hadoop.conf.Configuration conf, LensDriver driver, String lensSessionPublicId, boolean mergeDriverConf) Utility create method to create context with single driver.
Priority	decidePriority(LensDriver driver, QueryPriorityDecider queryPriorityDecider)
boolean	finished()
long	getClosedTime() The closed time.
String	getClusterUser()
boolean	getCompressOutput()
String	getDriverOpHandle() The driver op handle.
String	getDriverResultPath() The hdfsout path.
DriverQueryStatus	getDriverStatus() The driver status.
long	getEndTime() The end time.
org.apache.hadoop.fs.Path	getHDFSResultDir()
long	getLaunchTime() The launch time.
String	getLogHandle() Get query handle string
long	getMaxResultSplitRows()
String	getOuptutFileExtn()
Priority	getPriority() The priority.
QueryHandle	getQueryHandle() The query handle.
String	getQueryHandleString()
String	getQueryName() The query name.
QueryOutputFormatter	getQueryOutputFormatter() The query output formatter.
String	getResultEncoding()
String	getResultFooter()
String	getResultHeader()
String	getResultSetParentDir()
String	getResultSetPath() The result set path.
com.google.common.collect.ImmutableSet<QueryLaunchingConstraint>	getSelectedDriverQueryConstraints()
com.google.common.collect.ImmutableSet<WaitingQueriesSelectionPolicy>	getSelectedDriverSelectionPolicies()
QueryStatus	getStatus() The status.
long	getSubmissionTime() The submission time.
boolean	isDriverPersistent() The is driver persistent.
boolean	isFinishedQueryPersisted() The finished query persisted.
boolean	isPersistent() The is persistent.
boolean	isResultAvailableInDriver()
boolean	launched()
boolean	queued()
boolean	running()
void	setClosedTime(long closedTime) The closed time.
void	setDriverOpHandle(String driverOpHandle) The driver op handle.
void	setDriverResultPath(String driverResultPath) The hdfsout path.
void	setEndTime(long endTime) The end time.
void	setFinishedQueryPersisted(boolean finishedQueryPersisted) The finished query persisted.
void	setLaunchTime(long launchTime) The launch time.
void	setQueryHandle(QueryHandle queryHandle) The query handle.
void	setQueryName(String queryName) The query name.
void	setQueryOutputFormatter(QueryOutputFormatter queryOutputFormatter) The query output formatter.
void	setResultSetPath(String resultSetPath) The result set path.
void	setStatus(QueryStatus newStatus)
void	setStatusSkippingTransitionTest(QueryStatus newStatus)
boolean	splitResultIntoMultipleFiles() Split result into multiple files.
LensQuery	toLensQuery() To lens query.
String	toString()
void	unSetDriverPersistent() Set whether result is persisted on driver to false.
void	updateConf(Map<String,String> confoverlay) Update conf.
void	validateTransition(QueryStatus newStatus)

Methods inherited from class org.apache.lens.server.api.query.AbstractQueryContext

clearTransientStateAfterCompleted, clearTransientStateAfterLaunch, estimateCostForDrivers, getConf, getDatabase, getDriverConf, getDriverContext, getDriverEstimateRunnables, getDriverQuery, getDriverQueryCost, getDriverRewriteError, getDriverRewriterPlan, getFinalDriverQuery, getHiveConf, getLensConf, getLensSessionIdentifier, getPhase1RewrittenQuery, getQueue, getSelectedDriver, getSelectedDriverConf, getSelectedDriverQuery, getSelectedDriverQueryCost, getSelectedDriverQueryPlan, getSubmittedUser, getTableWeights, getUserQuery, initTransientState, isDriverQueryExplicitlySet, isOlapQuery, setConf, setDriverContext, setDriverCost, setDriverQueries, setDriverQuery, setDriverRewriteError, setFinalDriverQuery, setLensSessionIdentifier, setOlapQuery, setPhase1RewrittenQuery, setSelectedDriver, setSelectedDriverQuery, setSelectedDriverQueryCost

Methods inherited from class java.lang.Object

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

Constructor Detail

QueryContext

public QueryContext(String query,
            String user,
            LensConf qconf,
            org.apache.hadoop.conf.Configuration conf,
            Collection<LensDriver> drivers)

Creates context from query

Parameters:

query - the query

user - the user

qconf - The query lensconf

conf - the conf

QueryContext

public QueryContext(PreparedQueryContext prepared,
            String user,
            LensConf qconf,
            org.apache.hadoop.conf.Configuration conf)

Creates context from PreparedQueryContext

Parameters:

prepared - the prepared

user - the user

qconf - the qconf

conf - the conf

Method Detail

createContextWithSingleDriver

public static QueryContext createContextWithSingleDriver(String query,
                                         String user,
                                         LensConf qconf,
                                         org.apache.hadoop.conf.Configuration conf,
                                         LensDriver driver,
                                         String lensSessionPublicId,
                                         boolean mergeDriverConf)

Utility create method to create context with single driver.

Parameters:

query - The user query

user - The submitted query

qconf - The query lens conf

conf - Query configuration object - merged with session

driver - The driver

lensSessionPublicId - The session id

Returns:

QueryContext object

updateConf

public void updateConf(Map<String,String> confoverlay)

Update conf.

Parameters:

confoverlay - the conf to set

getResultSetParentDir

public String getResultSetParentDir()

getHDFSResultDir

public org.apache.hadoop.fs.Path getHDFSResultDir()

toLensQuery

public LensQuery toLensQuery()

To lens query.

Returns:

the lens query

isResultAvailableInDriver

public boolean isResultAvailableInDriver()

unSetDriverPersistent

public void unSetDriverPersistent()

Set whether result is persisted on driver to false. Set by drivers when drivers are not persisting

setStatusSkippingTransitionTest

public void setStatusSkippingTransitionTest(QueryStatus newStatus)

setStatus

public void setStatus(QueryStatus newStatus)
               throws LensException

Throws:

LensException

getResultHeader

public String getResultHeader()

getResultFooter

public String getResultFooter()

getResultEncoding

public String getResultEncoding()

getOuptutFileExtn

public String getOuptutFileExtn()

getCompressOutput

public boolean getCompressOutput()

getMaxResultSplitRows

public long getMaxResultSplitRows()

splitResultIntoMultipleFiles

public boolean splitResultIntoMultipleFiles()

Split result into multiple files.

Returns:

true, if successful

getClusterUser

public String getClusterUser()

getLogHandle

public String getLogHandle()

Get query handle string

Specified by:

getLogHandle in class AbstractQueryContext

Returns:

getQueryHandleString

public String getQueryHandleString()

validateTransition

public void validateTransition(QueryStatus newStatus)
                        throws LensException

Throws:

LensException

finished

public boolean finished()

launched

public boolean launched()

running

public boolean running()

queued

public boolean queued()

getSelectedDriverQueryConstraints

public com.google.common.collect.ImmutableSet<QueryLaunchingConstraint> getSelectedDriverQueryConstraints()

getSelectedDriverSelectionPolicies

public com.google.common.collect.ImmutableSet<WaitingQueriesSelectionPolicy> getSelectedDriverSelectionPolicies()

decidePriority

public Priority decidePriority(LensDriver driver,
                      QueryPriorityDecider queryPriorityDecider)
                        throws LensException

Throws:

LensException

toString

@Generated(value="lombok")
public String toString()

Overrides:

toString in class Object

getQueryHandle

@Generated(value="lombok")
public QueryHandle getQueryHandle()

The query handle.

setQueryHandle

@Generated(value="lombok")
public void setQueryHandle(QueryHandle queryHandle)

The query handle.

getPriority

@Generated(value="lombok")
public Priority getPriority()

The priority.

isPersistent

@Generated(value="lombok")
public boolean isPersistent()

The is persistent.

isDriverPersistent

@Generated(value="lombok")
public boolean isDriverPersistent()

The is driver persistent.

getStatus

@Generated(value="lombok")
public QueryStatus getStatus()

The status.

getResultSetPath

@Generated(value="lombok")
public String getResultSetPath()

The result set path.

setResultSetPath

@Generated(value="lombok")
public void setResultSetPath(String resultSetPath)

The result set path.

getDriverResultPath

@Generated(value="lombok")
public String getDriverResultPath()

The hdfsout path.

setDriverResultPath

@Generated(value="lombok")
public void setDriverResultPath(String driverResultPath)

The hdfsout path.

getSubmissionTime

@Generated(value="lombok")
public long getSubmissionTime()

The submission time.

getLaunchTime

@Generated(value="lombok")
public long getLaunchTime()

The launch time.

setLaunchTime

@Generated(value="lombok")
public void setLaunchTime(long launchTime)

The launch time.

getEndTime

@Generated(value="lombok")
public long getEndTime()

The end time.

setEndTime

@Generated(value="lombok")
public void setEndTime(long endTime)

The end time.

getClosedTime

@Generated(value="lombok")
public long getClosedTime()

The closed time.

setClosedTime

@Generated(value="lombok")
public void setClosedTime(long closedTime)

The closed time.

getDriverOpHandle

@Generated(value="lombok")
public String getDriverOpHandle()

The driver op handle.

setDriverOpHandle

@Generated(value="lombok")
public void setDriverOpHandle(String driverOpHandle)

The driver op handle.

getDriverStatus

@Generated(value="lombok")
public DriverQueryStatus getDriverStatus()

The driver status.

getQueryOutputFormatter

@Generated(value="lombok")
public QueryOutputFormatter getQueryOutputFormatter()

The query output formatter.

setQueryOutputFormatter

@Generated(value="lombok")
public void setQueryOutputFormatter(QueryOutputFormatter queryOutputFormatter)

The query output formatter.

isFinishedQueryPersisted

@Generated(value="lombok")
public boolean isFinishedQueryPersisted()

The finished query persisted.

setFinishedQueryPersisted

@Generated(value="lombok")
public void setFinishedQueryPersisted(boolean finishedQueryPersisted)

The finished query persisted.

getQueryName

@Generated(value="lombok")
public String getQueryName()

The query name.

setQueryName

@Generated(value="lombok")
public void setQueryName(String queryName)

The query name.