diff --git a/src/processor/operator/persistent/writer/parquet/basic_column_writer.cpp b/src/processor/operator/persistent/writer/parquet/basic_column_writer.cpp index 8adcef71dc7..b7231738f4f 100644 --- a/src/processor/operator/persistent/writer/parquet/basic_column_writer.cpp +++ b/src/processor/operator/persistent/writer/parquet/basic_column_writer.cpp @@ -23,8 +23,7 @@ void BasicColumnWriter::prepare(ColumnWriterState& stateToPrepare, ColumnWriterS auto& col_chunk = state.row_group.columns[state.col_idx]; uint64_t start = 0; - auto vcount = - parent ? parent->definitionLevels.size() - state.definitionLevels.size() : count; + auto vcount = parent ? parent->definitionLevels.size() - state.definitionLevels.size() : count; auto parent_index = state.definitionLevels.size(); handleRepeatLevels(state, parent, count, maxRepeat); handleDefineLevels(state, parent, vector, count, maxDefine, maxDefine - 1); @@ -90,7 +89,8 @@ void BasicColumnWriter::beginWrite(ColumnWriterState& writerState) { NextPage(state); } -void BasicColumnWriter::write(ColumnWriterState& writerState, common::ValueVector* vector, uint64_t count) { +void BasicColumnWriter::write( + ColumnWriterState& writerState, common::ValueVector* vector, uint64_t count) { auto& state = reinterpret_cast(writerState); uint64_t remaining = count; @@ -300,8 +300,7 @@ void BasicColumnWriter::SetParquetStatistics( column_chunk.meta_data.__isset.statistics = true; } for (const auto& write_info : state.write_info) { - column_chunk.meta_data.encodings.push_back( - write_info.pageHeader.data_page_header.encoding); + column_chunk.meta_data.encodings.push_back(write_info.pageHeader.data_page_header.encoding); } } diff --git a/src/processor/operator/persistent/writer/parquet/boolean_column_writer.cpp b/src/processor/operator/persistent/writer/parquet/boolean_column_writer.cpp index a3090f17b14..a2d64af6f30 100644 --- a/src/processor/operator/persistent/writer/parquet/boolean_column_writer.cpp +++ b/src/processor/operator/persistent/writer/parquet/boolean_column_writer.cpp @@ -1,7 +1,5 @@ #include "processor/operator/persistent/writer/parquet/boolean_column_writer.h" namespace kuzu { -namespace processor { - -} -} +namespace processor {} +} // namespace kuzu diff --git a/src/processor/operator/persistent/writer/parquet/column_writer.cpp b/src/processor/operator/persistent/writer/parquet/column_writer.cpp index 4069839aa3d..eb7e727da55 100644 --- a/src/processor/operator/persistent/writer/parquet/column_writer.cpp +++ b/src/processor/operator/persistent/writer/parquet/column_writer.cpp @@ -14,8 +14,6 @@ namespace kuzu { namespace processor { -#define PARQUET_DEFINE_VALID 65535 - using namespace kuzu_parquet::format; using namespace kuzu::common; @@ -179,7 +177,7 @@ void ColumnWriter::handleDefineLevels(ColumnWriterState& state, ColumnWriterStat uint64_t vector_index = 0; while (state.definitionLevels.size() < parent->definitionLevels.size()) { auto current_index = state.definitionLevels.size(); - if (parent->definitionLevels[current_index] != PARQUET_DEFINE_VALID) { + if (parent->definitionLevels[current_index] != ParquetConstants::PARQUET_DEFINE_VALID) { state.definitionLevels.push_back(parent->definitionLevels[current_index]); } else if (!vector->isNull(vector->state->selVector->selectedPositions[vector_index])) { state.definitionLevels.push_back(defineValue); diff --git a/src/processor/operator/persistent/writer/parquet/standard_column_writer.cpp b/src/processor/operator/persistent/writer/parquet/standard_column_writer.cpp index 5584f205800..1bb87333745 100644 --- a/src/processor/operator/persistent/writer/parquet/standard_column_writer.cpp +++ b/src/processor/operator/persistent/writer/parquet/standard_column_writer.cpp @@ -1,9 +1,5 @@ #include "processor/operator/persistent/writer/parquet/standard_column_writer.h" namespace kuzu { -namespace processor { - - - -} -} +namespace processor {} +} // namespace kuzu