Function verifyCompressionBlockAlignment

c++/test/TestWriter.cc:91–133

  }

  void verifyCompressionBlockAlignment(std::unique_ptr<Reader>& reader, uint64_t columnCount) {
    auto stripeCount = reader->getNumberOfStripes();
    for (uint64_t stripeIndex = 0; stripeIndex < stripeCount; ++stripeIndex) {
      for (uint64_t i = 0; i < columnCount; ++i) {
        auto rowGroupIndexMap = reader->getRowGroupIndex(stripeIndex);
        EXPECT_TRUE(rowGroupIndexMap.size() > 0);
        auto rowGroupIndex = rowGroupIndexMap[columnCount];
        auto subType = reader->getType().getSubtype(i);
        EXPECT_TRUE(rowGroupIndex.positions.size() > 0);
        for (auto rowGroupPositions : rowGroupIndex.positions) {
          for (uint64_t posIndex = 0; posIndex < rowGroupPositions.size(); ++posIndex) {
            // After we call finishStream(), unusedBufferSize is set to 0,
            // so only the first position is valid in each recordPosition call.
            switch (subType->getKind()) {
              case DECIMAL:
              case STRING:
              case BINARY:
              case CHAR:
              case VARCHAR: {
                if (posIndex != 0 && posIndex != 2) {
                  EXPECT_EQ(rowGroupPositions[posIndex], 0);
                }
                break;
              }
              case TIMESTAMP_INSTANT:
              case TIMESTAMP: {
                if (posIndex != 0 && posIndex != 3) {
                  EXPECT_EQ(rowGroupPositions[posIndex], 0);
                }
                break;
              }
              default: {
                if (posIndex != 0) {
                  EXPECT_EQ(rowGroupPositions[posIndex], 0);
                }
                break;
              }
            }
          }
        }
      }
    }
  }

  struct TestParams {
    FileVersion fileVersion;