Method
createContext
(RoutingProvider routingProvider,
UUID jobId,
CoordinatorTxnCtx txnCtx,
int fetchSize,
@Nullable Row params,
Cursors cursors,
TransactionState transactionState,
Session.TimeoutToken timeoutToken)
Source from the content-addressed store, hash-verified
| 221 | } |
| 222 | |
| 223 | public PlannerContext createContext(RoutingProvider routingProvider, |
| 224 | UUID jobId, |
| 225 | CoordinatorTxnCtx txnCtx, |
| 226 | int fetchSize, |
| 227 | @Nullable Row params, |
| 228 | Cursors cursors, |
| 229 | TransactionState transactionState, |
| 230 | Session.TimeoutToken timeoutToken) { |
| 231 | return new PlannerContext( |
| 232 | clusterService.state(), |
| 233 | routingProvider, |
| 234 | jobId, |
| 235 | txnCtx, |
| 236 | nodeCtx, |
| 237 | fetchSize, |
| 238 | params, |
| 239 | cursors, |
| 240 | transactionState, |
| 241 | new PlanStats(nodeCtx, txnCtx, nodeCtx.tableStats()), |
| 242 | this.logicalPlanner::optimize, |
| 243 | timeoutToken |
| 244 | ); |
| 245 | } |
| 246 | |
| 247 | private void initAwarenessAttributes(Settings settings) { |
| 248 | awarenessAttributes = |