Method retryQuery

server/src/main/java/io/crate/session/Session.java:295–318

(UUID jobId,
                            AnalyzedStatement stmt,
                            RoutingProvider routingProvider,
                            RowConsumer consumer,
                            Row params,
                            CoordinatorTxnCtx txnCtx,
                            TimeoutToken timeoutToken)

    }

    private void retryQuery(UUID jobId,
                            AnalyzedStatement stmt,
                            RoutingProvider routingProvider,
                            RowConsumer consumer,
                            Row params,
                            CoordinatorTxnCtx txnCtx,
                            TimeoutToken timeoutToken) {
        PlannerContext plannerContext = planner.createContext(
            routingProvider,
            jobId,
            txnCtx,
            0,
            params,
            cursors,
            currentTransactionState,
            timeoutToken

        );
        Plan plan = planner.plan(stmt, plannerContext);
        if (timeoutToken != null) {
            timeoutToken.check("retry:plan");
        }
        Plan.execute(plan, executor, plannerContext, consumer, params, SubQueryResults.EMPTY);
    }

    private Portal getSafePortal(String portalName) {
        Portal portal = portals.get(portalName);