Package org.apache.drill.exec.work.user

Class UserWorker

java.lang.Object

org.apache.drill.exec.work.user.UserWorker

public class UserWorker
extends Object

Constructor Summary

Constructors

Constructor	Description
UserWorker(WorkManager.WorkerBee bee)

Method Summary

Modifier and Type	Method	Description
GeneralRPCProtos.Ack	cancelQuery(UserBitShared.QueryId query)
UserProtos.QueryPlanFragments	getQueryPlan(UserClientConnection connection, UserProtos.GetQueryPlanFragments req)
OptionManager	getSystemOptions()
GeneralRPCProtos.Ack	resumeQuery(UserBitShared.QueryId queryId)
void	submitCatalogMetadataWork(UserSession session, UserProtos.GetCatalogsReq req, ResponseSender sender)
void	submitColumnsMetadataWork(UserSession session, UserProtos.GetColumnsReq req, ResponseSender sender)
void	submitPreparedStatementWork(UserClientConnection connection, UserProtos.CreatePreparedStatementReq req, ResponseSender sender)
void	submitSchemasMetadataWork(UserSession session, UserProtos.GetSchemasReq req, ResponseSender sender)
void	submitServerMetadataWork(UserSession session, UserProtos.GetServerMetaReq req, ResponseSender sender)
void	submitTablesMetadataWork(UserSession session, UserProtos.GetTablesReq req, ResponseSender sender)
UserBitShared.QueryId	submitWork(UserClientConnection connection, UserProtos.RunQuery query)

Methods inherited from class java.lang.Object

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

Constructor Details

UserWorker

public UserWorker(WorkManager.WorkerBee bee)

Method Details

submitWork

public UserBitShared.QueryId submitWork(UserClientConnection connection,
 UserProtos.RunQuery query)

cancelQuery

public GeneralRPCProtos.Ack cancelQuery(UserBitShared.QueryId query)

resumeQuery

public GeneralRPCProtos.Ack resumeQuery(UserBitShared.QueryId queryId)

getSystemOptions

public OptionManager getSystemOptions()

getQueryPlan

public UserProtos.QueryPlanFragments getQueryPlan(UserClientConnection connection,
 UserProtos.GetQueryPlanFragments req)

submitCatalogMetadataWork

public void submitCatalogMetadataWork(UserSession session,
 UserProtos.GetCatalogsReq req,
 ResponseSender sender)

submitSchemasMetadataWork

public void submitSchemasMetadataWork(UserSession session,
 UserProtos.GetSchemasReq req,
 ResponseSender sender)

submitTablesMetadataWork

public void submitTablesMetadataWork(UserSession session,
 UserProtos.GetTablesReq req,
 ResponseSender sender)

submitColumnsMetadataWork

public void submitColumnsMetadataWork(UserSession session,
 UserProtos.GetColumnsReq req,
 ResponseSender sender)

submitPreparedStatementWork

public void submitPreparedStatementWork(UserClientConnection connection,
 UserProtos.CreatePreparedStatementReq req,
 ResponseSender sender)

submitServerMetadataWork

public void submitServerMetadataWork(UserSession session,
 UserProtos.GetServerMetaReq req,
 ResponseSender sender)