@Test public void testPreparedPlanSimpleNoInvalidation() throws Exception { helpTestPlanInvalidation("select * from #temp"); assertEquals(3, this.core.getPrepPlanCache().getCacheHitCount()); }
public SessionAwareCache<PreparedPlan> getPrepPlanCache() { return prepPlanCache; }
DQPCore implements DQP { public SessionAwareCache<PreparedPlan> getPrepPlanCache() { return prepPlanCache; } }
DQPCore implements DQP { public SessionAwareCache<PreparedPlan> getPrepPlanCache() { return prepPlanCache; }  }
DQPCore implements DQP { public SessionAwareCache<PreparedPlan> getPrepPlanCache() { return prepPlanCache; }  void stop(); List<RequestMetadata> getRequestsForSession(String sessionId); ClientState getClientState(String key, boolean create); List<RequestMetadata> getRequests(); List<RequestMetadata> getLongRunningRequests(); int getLongRunningRequestCount(); @Override ResultsFuture<ResultsMessage> executeRequest(long reqID,RequestMessage requestMsg); ResultsFuture<ResultsMessage> executeRequest(long reqID,RequestMessage requestMsg, Long queryTimeout); ResultsFuture<ResultsMessage> processCursorRequest(long reqID,
            int batchFirst, int fetchSize); int getActivePlanCount(); long getTotalPlansProcessed(); boolean blockOnOutputBuffer(RequestWorkItem item); int getWaitingPlanCount(); int getMaxWaitingPlanWatermark(); ResultsFuture<?> closeLobChunkStream(int lobRequestId,
            long requestId, String streamId); ResultsFuture<LobChunk> requestNextLobChunk(int lobRequestId,
            long requestId, String streamId); WorkerPoolStatisticsMetadata getWorkerPoolStatistics(); TeiidExecutor getProcessWorkerPool(); void terminateSession(String sessionId); boolean cancelRequest(String sessionId, long executionId); PlanNode getPlan(String sessionId, long executionId); ResultsFuture<?> closeRequest(long requestId); Collection<TransactionMetadata> getTransactions(); void terminateTransaction(String xid); TempTableDataManager getDataTierManager(); BufferManager getBufferManager(); TransactionService getTransactionService(); SessionAwareCache<CachedResults> getResltSetCache(); void start(DQPConfiguration theConfig); void setBufferManager(BufferManager mgr); void setTransactionService(TransactionService service); void setEventDistributor(EventDistributor eventDistributor); @Override boolean cancelRequest(long requestID); ResultsFuture<?> begin(); ResultsFuture<?> commit(); ResultsFuture<?> rollback(); ResultsFuture<?> commit(final XidImpl xid, final boolean onePhase); ResultsFuture<?> end(XidImpl xid, int flags); ResultsFuture<?> forget(XidImpl xid); ResultsFuture<Integer> prepare(final XidImpl xid); ResultsFuture<Xid[]> recover(int flag); ResultsFuture<?> rollback(final XidImpl xid); ResultsFuture<?> start(final XidImpl xid, final int flags, final int timeout); MetadataResult getMetadata(long requestID); MetadataResult getMetadata(long requestID, String preparedSql,
            boolean allowDoubleQuotedVariable); boolean isExceptionOnMaxSourceRows(); int getMaxSourceRows(); int getMaxRowsFetchSize(); void setResultsetCache(SessionAwareCache<CachedResults> cache); void setPreparedPlanCache(SessionAwareCache<PreparedPlan> cache); int getUserRequestSourceConcurrency(); int getMaxActivePlans(); SessionAwareCache<PreparedPlan> getPrepPlanCache(); String getRuntimeVersion(); static ResultsFuture<?> executeQuery(final Object command, final VDBMetaData vdb, final String user, final String app,
            final long timeoutInMilli, final DQPCore engine, final ResultsListener listener); void setLocalProfile(LocalProfile localProfile); void setSessionService(SessionService sessionService); SessionService getSessionService(); }
DQPCore implements DQP { public SessionAwareCache<PreparedPlan> getPrepPlanCache() { return prepPlanCache; }  void stop(); List<RequestMetadata> getRequestsForSession(String sessionId); ClientState getClientState(String key, boolean create); List<RequestMetadata> getRequests(); List<RequestMetadata> getLongRunningRequests(); int getLongRunningRequestCount(); @Override ResultsFuture<ResultsMessage> executeRequest(long reqID,RequestMessage requestMsg); ResultsFuture<ResultsMessage> executeRequest(long reqID,RequestMessage requestMsg, Long queryTimeout); ResultsFuture<ResultsMessage> processCursorRequest(long reqID,
            int batchFirst, int fetchSize); int getActivePlanCount(); long getTotalPlansProcessed(); boolean blockOnOutputBuffer(RequestWorkItem item); int getWaitingPlanCount(); int getMaxWaitingPlanWatermark(); ResultsFuture<?> closeLobChunkStream(int lobRequestId,
            long requestId, String streamId); ResultsFuture<LobChunk> requestNextLobChunk(int lobRequestId,
            long requestId, String streamId); WorkerPoolStatisticsMetadata getWorkerPoolStatistics(); TeiidExecutor getProcessWorkerPool(); void terminateSession(String sessionId); boolean cancelRequest(String sessionId, long executionId); PlanNode getPlan(String sessionId, long executionId); ResultsFuture<?> closeRequest(long requestId); Collection<TransactionMetadata> getTransactions(); void terminateTransaction(String xid); TempTableDataManager getDataTierManager(); BufferManager getBufferManager(); TransactionService getTransactionService(); SessionAwareCache<CachedResults> getResltSetCache(); void start(DQPConfiguration theConfig); void setBufferManager(BufferManager mgr); void setTransactionService(TransactionService service); void setEventDistributor(EventDistributor eventDistributor); @Override boolean cancelRequest(long requestID); ResultsFuture<?> begin(); ResultsFuture<?> commit(); ResultsFuture<?> rollback(); ResultsFuture<?> commit(final XidImpl xid, final boolean onePhase); ResultsFuture<?> end(XidImpl xid, int flags); ResultsFuture<?> forget(XidImpl xid); ResultsFuture<Integer> prepare(final XidImpl xid); ResultsFuture<Xid[]> recover(int flag); ResultsFuture<?> rollback(final XidImpl xid); ResultsFuture<?> start(final XidImpl xid, final int flags, final int timeout); MetadataResult getMetadata(long requestID); MetadataResult getMetadata(long requestID, String preparedSql,
            boolean allowDoubleQuotedVariable); boolean isExceptionOnMaxSourceRows(); int getMaxSourceRows(); int getMaxRowsFetchSize(); void setResultsetCache(SessionAwareCache<CachedResults> cache); void setPreparedPlanCache(SessionAwareCache<PreparedPlan> cache); int getUserRequestSourceConcurrency(); int getMaxActivePlans(); SessionAwareCache<PreparedPlan> getPrepPlanCache(); String getRuntimeVersion(); static ResultsFuture<?> executeQuery(final Object command, final VDBMetaData vdb, final String user, final String app,
            final long timeoutInMilli, final DQPCore engine, final ResultsListener listener); void setLocalProfile(LocalProfile localProfile); void setSessionService(SessionService sessionService); SessionService getSessionService();  }