Function TEST

cpp/src/arrow/acero/asof_join_node_test.cc:1550–1554

}

TEST(AsofJoinTest, BackpressureWithBatches) {
  // Give the first right hand table a delay to stress test race conditions
  return TestBackpressure(MakeIntegerBatches, /*batch_size=*/1, /*num_l_batches=*/20,
                          /*num_r0_batches=*/50, /*num_r1_batches=*/20, /*slow_r0=*/true);
}

template <typename BatchesMaker>
void TestSequencing(BatchesMaker maker, int num_batches, int batch_size) {