Function TEST_F

bolt/exec/tests/VectorHasherTest.cpp:176–239

};

TEST_F(VectorHasherTest, flat) {
  auto hasher = exec::VectorHasher::create(BIGINT(), 1);
  ASSERT_EQ(hasher->channel(), 1);
  ASSERT_EQ(hasher->typeKind(), TypeKind::BIGINT);

  auto vector = BaseVector::create(BIGINT(), 100, pool());
  auto flatVector = vector->asFlatVector<int64_t>();
  for (int32_t i = 0; i < 100; i++) {
    if (i % 5 == 0) {
      flatVector->setNull(i, true);
    } else {
      flatVector->set(i, i);
    }
  }

  raw_vector<uint64_t> hashes(100);
  std::fill(hashes.begin(), hashes.end(), 0);
  hasher->decode(*vector, oddRows_);
  hasher->hash(oddRows_, false, hashes);
  for (int32_t i = 0; i < 100; i++) {
    if (i % 2 == 0) {
      EXPECT_EQ(hashes[i], 0);
    } else if (i % 5 == 0) {
      EXPECT_EQ(hashes[i], exec::VectorHasher::kNullHash) << "at " << i;
    } else {
      EXPECT_EQ(hashes[i], folly::hasher<int64_t>()(i)) << "at " << i;
    }
  }

  hasher->decode(*vector, allRows_);
  hasher->hash(allRows_, false, hashes);
  for (int32_t i = 0; i < 100; i++) {
    if (i % 5 == 0) {
      EXPECT_EQ(hashes[i], exec::VectorHasher::kNullHash) << "at " << i;
    } else {
      EXPECT_EQ(hashes[i], folly::hasher<int64_t>()(i)) << "at " << i;
    }
  }

  // Test precompute methods for single null value.
  hasher->precompute(*vector);
  hasher->hashPrecomputed(allRows_, false, hashes);
  for (int32_t i = 0; i < 100; i++) {
    EXPECT_EQ(exec::VectorHasher::kNullHash, hashes[i]);
  }

  // Test precompute methods for single value '7'.
  flatVector->set(0, 7);
  hasher->precompute(*vector);
  hasher->hashPrecomputed(allRows_, false, hashes);
  auto expected = folly::hasher<int64_t>()(7);
  for (int32_t i = 0; i < 100; i++) {
    EXPECT_EQ(expected, hashes[i]);
  }

  // Test precompute methods for mixed value '7' with value '55'.
  flatVector->set(0, 55);
  hasher->precompute(*vector);