BlockingScanNode is a BlockingPlanNode that handles rpc calls to fetch data from datanode
| 137 | |
| 138 | // BlockingScanNode is a BlockingPlanNode that handles rpc calls to fetch data from datanode |
| 139 | type BlockingScanNode struct { |
| 140 | blockingPlanNodeImpl |
| 141 | |
| 142 | qc QueryContext |
| 143 | host topology.Host |
| 144 | dataNodeClient dataCli.DataNodeQueryClient |
| 145 | topo topology.HealthTrackingDynamicTopoloy |
| 146 | } |
| 147 | |
| 148 | func (sn *BlockingScanNode) Execute(ctx context.Context) (result queryCom.AQLQueryResult, err error) { |
| 149 | done := ctx.Done() |
nothing calls this directly
no outgoing calls
no test coverage detected