Function TEST_F

bolt/exec/tests/RoundRobinPartitionFunctionTest.cpp:46–61

};

TEST_F(RoundRobinPartitionFunctionTest, basic) {
  exec::RoundRobinPartitionFunction partitionFunction(10);

  auto pool = memory::memoryManager()->addLeafPool();
  test::VectorMaker vm(pool.get());

  auto data = vm.rowVector(ROW({}, {}), 1024);
  std::vector<uint32_t> partitions;
  for (auto i = 0; i < 31; ++i) {
    SCOPED_TRACE(i);
    auto partition = partitionFunction.partition(*data, partitions);
    ASSERT_TRUE(partition.has_value());
    ASSERT_EQ(i % 10, partition.value());
    ASSERT_TRUE(partitions.empty());
  }
}

TEST_F(RoundRobinPartitionFunctionTest, spec) {
  auto roundRobinSpec = std::make_unique<RoundRobinPartitionFunctionSpec>();