(DependencyCarrier executor,
PlannerContext plannerContext,
List<Row> bulkParams,
SubQueryResults subQueryResults)
| 319 | } |
| 320 | |
| 321 | @Override |
| 322 | public CompletableFuture<BulkResponse> executeBulk(DependencyCarrier executor, |
| 323 | PlannerContext plannerContext, |
| 324 | List<Row> bulkParams, |
| 325 | SubQueryResults subQueryResults) { |
| 326 | // Do another execution to overwrite `mostRecentJobID` |
| 327 | session.quickExec("SELECT 1", new BaseResultReceiver(), null); |
| 328 | var response = new BulkResponse(2); |
| 329 | response.update(0, 1L, null); |
| 330 | response.update(1, 1L, null); |
| 331 | return completedFuture(response); |
| 332 | } |
| 333 | } |
| 334 | ); |
| 335 |