org.apache.lens.server.query

Class LensServerDAO

java.lang.Object

org.apache.lens.server.query.LensServerDAO

public class LensServerDAO
extends Object

Top level class which logs and retrieves finished query from Database.

Constructor Summary

Constructors

Constructor and Description
LensServerDAO()

Method Summary

Modifier and Type	Method and Description
void	createFailedAttemptsTable()
void	createFinishedQueriesTable() Method to create finished queries table, this is required for embedded lens server.
void	dropFinishedQueriesTable() Drop finished queries table.
List<QueryHandle>	findFinishedQueries(List<QueryStatus.Status> states, String user, String driverName, String queryName, long fromDate, long toDate) Find finished queries.
List<FinishedLensQuery>	findFinishedQueryDetails(List<QueryStatus.Status> states, String user, String driverName, String queryName, long fromDate, long toDate) Find finished queries.
Connection	getConnection()
void	getFailedAttempts(FinishedLensQuery query)
FinishedLensQuery	getQuery(String handle) Fetch Finished query from Database.
void	init(org.apache.hadoop.conf.Configuration conf) Inits the.
void	insertFailedAttempt(org.apache.commons.dbutils.QueryRunner runner, Connection conn, String handle, FailedAttempt attempt, int index) DAO method to insert a new Finished query into Table.
void	insertFinishedQuery(FinishedLensQuery query) DAO method to insert a new Finished query into Table.

Methods inherited from class java.lang.Object

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

Constructor Detail

LensServerDAO

public LensServerDAO()

Method Detail

init

public void init(org.apache.hadoop.conf.Configuration conf)

Inits the.

Parameters:

conf - the conf

getConnection

public Connection getConnection()
                         throws SQLException

Throws:

SQLException

dropFinishedQueriesTable

public void dropFinishedQueriesTable()

Drop finished queries table.

createFinishedQueriesTable

public void createFinishedQueriesTable()
                                throws Exception

Method to create finished queries table, this is required for embedded lens server. For production server we will not be creating tables as it would be created upfront.

Throws:

Exception - the exception

createFailedAttemptsTable

public void createFailedAttemptsTable()
                               throws Exception

Throws:

Exception

insertFinishedQuery

public void insertFinishedQuery(FinishedLensQuery query)
                         throws SQLException

DAO method to insert a new Finished query into Table.

Parameters:

query - to be inserted

Throws:

SQLException - the exception

insertFailedAttempt

public void insertFailedAttempt(org.apache.commons.dbutils.QueryRunner runner,
                                Connection conn,
                                String handle,
                                FailedAttempt attempt,
                                int index)
                         throws SQLException

DAO method to insert a new Finished query into Table.

Parameters:

runner -

conn -

handle - to be inserted

index - @throws SQLException the exception

Throws:

SQLException

getFailedAttempts

public void getFailedAttempts(FinishedLensQuery query)

getQuery

public FinishedLensQuery getQuery(String handle)

Fetch Finished query from Database.

Parameters:

handle - to be fetched

Returns:

Finished query.

findFinishedQueryDetails

public List<FinishedLensQuery> findFinishedQueryDetails(List<QueryStatus.Status> states,
                                                        String user,
                                                        String driverName,
                                                        String queryName,
                                                        long fromDate,
                                                        long toDate)
                                                 throws LensException

Find finished queries.

Parameters:

states - the state

user - the user

driverName - the driver's fully qualified Name

queryName - the query name

fromDate - the from date

toDate - the to date

Returns:

the list

Throws:

LensException - the lens exception

findFinishedQueries

public List<QueryHandle> findFinishedQueries(List<QueryStatus.Status> states,
                                             String user,
                                             String driverName,
                                             String queryName,
                                             long fromDate,
                                             long toDate)
                                      throws LensException

Find finished queries.

Parameters:

states - the state

user - the user

driverName - the driver's fully qualified Name

queryName - the query name

fromDate - the from date

toDate - the to date

Returns:

the list

Throws:

LensException - the lens exception