| 1305 | } |
| 1306 | |
| 1307 | func (qc *AQLQueryContext) runBatchExecutor(e BatchExecutor, isLastBatch bool) { |
| 1308 | start := utils.Now() |
| 1309 | e.preExec(isLastBatch, start) |
| 1310 | |
| 1311 | e.filter() |
| 1312 | |
| 1313 | e.join() |
| 1314 | |
| 1315 | e.project() |
| 1316 | |
| 1317 | e.reduce() |
| 1318 | |
| 1319 | e.postExec(start) |
| 1320 | } |
| 1321 | |
| 1322 | // copyHostToDevice copy vector party slice to device vector party slice |
| 1323 | func copyHostToDevice(vps memCom.HostVectorPartySlice, deviceVPSlice deviceVectorPartySlice, stream unsafe.Pointer, device int) (bytesCopied, numTransfers int) { |