Skip to content
This repository has been archived by the owner on May 10, 2024. It is now read-only.

Commit

Permalink
Merge 0c89ba8 into 310ef06
Browse files Browse the repository at this point in the history
  • Loading branch information
Chen, Junjie committed Aug 17, 2018
2 parents 310ef06 + 0c89ba8 commit 90c37de
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions src/parquet/bloom_filter-test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ TEST(BasicTest, TestBloomFilter) {
// Deserialize Bloom filter from memory
InMemoryInputStream source(sink.GetBuffer());

BlockSplitBloomFilter de_bloom = std::move(BlockSplitBloomFilter::Deserialize(&source));
BlockSplitBloomFilter de_bloom = BlockSplitBloomFilter::Deserialize(&source);

for (int i = 0; i < 10; i++) {
EXPECT_TRUE(de_bloom.FindHash(de_bloom.Hash(i)));
Expand Down Expand Up @@ -161,7 +161,7 @@ TEST(CompatibilityTest, TestBloomFilter) {

std::unique_ptr<uint8_t[]> bitset(new uint8_t[size]());
std::shared_ptr<Buffer> buffer(new Buffer(bitset.get(), size));
handle->Read(size, &buffer);
PARQUET_THROW_NOT_OK(handle->Read(size, &buffer));

InMemoryInputStream source(buffer);
BlockSplitBloomFilter bloom_filter1 =
Expand Down Expand Up @@ -189,10 +189,10 @@ TEST(CompatibilityTest, TestBloomFilter) {
bloom_filter2.WriteTo(&sink);
std::shared_ptr<Buffer> buffer1 = sink.GetBuffer();

handle->Seek(0);
handle->GetSize(&size);
PARQUET_THROW_NOT_OK(handle->Seek(0));
PARQUET_THROW_NOT_OK(handle->GetSize(&size));
std::shared_ptr<Buffer> buffer2;
handle->Read(size, &buffer2);
PARQUET_THROW_NOT_OK(handle->Read(size, &buffer2));

EXPECT_TRUE((*buffer1).Equals(*buffer2));
}
Expand Down

0 comments on commit 90c37de

Please sign in to comment.