All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type |
Method and Description |
ResultsFuture<?> |
begin() |
boolean |
blockOnOutputBuffer(RequestWorkItem item) |
boolean |
cancelRequest(long requestID) |
boolean |
cancelRequest(String sessionId,
long executionId) |
ResultsFuture<?> |
closeLobChunkStream(int lobRequestId,
long requestId,
String streamId) |
ResultsFuture<?> |
closeRequest(long requestId) |
ResultsFuture<?> |
commit() |
ResultsFuture<?> |
commit(XidImpl xid,
boolean onePhase) |
ResultsFuture<?> |
end(XidImpl xid,
int flags) |
static ResultsFuture<?> |
executeQuery(Object command,
VDBMetaData vdb,
String user,
String app,
long timeoutInMilli,
DQPCore engine,
DQPCore.ResultsListener listener)
Execute the given query asynchly.
|
ResultsFuture<ResultsMessage> |
executeRequest(long reqID,
RequestMessage requestMsg) |
ResultsFuture<ResultsMessage> |
executeRequest(long reqID,
RequestMessage requestMsg,
Long queryTimeout) |
ResultsFuture<?> |
forget(XidImpl xid) |
int |
getActivePlanCount() |
BufferManager |
getBufferManager() |
org.teiid.dqp.internal.process.ClientState |
getClientState(String key,
boolean create) |
TempTableDataManager |
getDataTierManager() |
List<RequestMetadata> |
getLongRunningRequests() |
int |
getMaxActivePlans() |
int |
getMaxRowsFetchSize() |
int |
getMaxSourceRows() |
int |
getMaxWaitingPlanWatermark() |
MetadataResult |
getMetadata(long requestID) |
MetadataResult |
getMetadata(long requestID,
String preparedSql,
boolean allowDoubleQuotedVariable) |
PlanNode |
getPlan(String sessionId,
long executionId) |
List<RequestMetadata> |
getRequests()
|
List<RequestMetadata> |
getRequestsForSession(String sessionId)
|
String |
getRuntimeVersion() |
Collection<TransactionMetadata> |
getTransactions() |
TransactionService |
getTransactionService() |
int |
getUserRequestSourceConcurrency() |
int |
getWaitingPlanCount() |
WorkerPoolStatisticsMetadata |
getWorkerPoolStatistics() |
boolean |
isExceptionOnMaxSourceRows() |
ResultsFuture<Integer> |
prepare(XidImpl xid) |
ResultsFuture<ResultsMessage> |
processCursorRequest(long reqID,
int batchFirst,
int fetchSize) |
ResultsFuture<Xid[]> |
recover(int flag) |
ResultsFuture<LobChunk> |
requestNextLobChunk(int lobRequestId,
long requestId,
String streamId) |
ResultsFuture<?> |
rollback() |
ResultsFuture<?> |
rollback(XidImpl xid) |
void |
setBufferManager(BufferManager mgr) |
void |
setEventDistributor(EventDistributor eventDistributor) |
void |
setLocalProfile(LocalProfile localProfile)
The localprofile to use if this is an embedded DQP
|
void |
setPreparedPlanCache(SessionAwareCache<PreparedPlan> cache) |
void |
setResultsetCache(SessionAwareCache<CachedResults> cache) |
void |
setTransactionService(TransactionService service) |
void |
start(DQPConfiguration theConfig) |
ResultsFuture<?> |
start(XidImpl xid,
int flags,
int timeout) |
void |
stop()
perform a full shutdown and wait for 10 seconds for all threads to finish
|
void |
terminateSession(String sessionId) |
void |
terminateTransaction(String xid) |