diff --git a/src/include/storage/local_storage/local_node_table.h b/src/include/storage/local_storage/local_node_table.h index 4e972fb187b..d95555aaab5 100644 --- a/src/include/storage/local_storage/local_node_table.h +++ b/src/include/storage/local_storage/local_node_table.h @@ -23,8 +23,8 @@ class LocalNodeNG final : public LocalNodeGroup { bool insert(std::vector nodeIDVectors, std::vector propertyVectors) override; - bool insert( - common::offset_t startNodeOffset, ChunkedNodeGroup* nodeGroup, common::offset_t numValues); + bool insert(common::offset_t startNodeOffset, ChunkedNodeGroup* nodeGroup, + common::offset_t numValues); bool update(std::vector nodeIDVectors, common::column_id_t columnID, common::ValueVector* propertyVector) override; bool delete_(common::ValueVector* nodeIDVector, diff --git a/src/include/storage/store/chunked_node_group.h b/src/include/storage/store/chunked_node_group.h index f15d571bb56..b168bf272e3 100644 --- a/src/include/storage/store/chunked_node_group.h +++ b/src/include/storage/store/chunked_node_group.h @@ -45,8 +45,8 @@ class ChunkedNodeGroup { // number of values appended common::offset_t append(ChunkedNodeGroup* other, common::offset_t offsetInOtherNodeGroup, common::offset_t numValuesToAppend = common::StorageConstants::NODE_GROUP_SIZE); - void write( - const std::vector>& data, common::column_id_t offsetColumnID); + void write(const std::vector>& data, + common::column_id_t offsetColumnID); void write(const ChunkedNodeGroup& data, common::column_id_t offsetColumnID); void finalize(uint64_t nodeGroupIdx_); diff --git a/src/include/storage/store/node_table.h b/src/include/storage/store/node_table.h index 2f940ca3b15..737d742fb23 100644 --- a/src/include/storage/store/node_table.h +++ b/src/include/storage/store/node_table.h @@ -118,8 +118,8 @@ class NodeTable final : public Table { return tableData->getNumNodeGroups(transaction); } - inline common::offset_t getNumTuplesInNodeGroup( - transaction::Transaction* transaction, common::node_group_idx_t nodeGroupIdx) { + inline common::offset_t getNumTuplesInNodeGroup(transaction::Transaction* transaction, + common::node_group_idx_t nodeGroupIdx) { return tableData->getNumTuplesInNodeGroup(transaction, nodeGroupIdx); } diff --git a/src/include/storage/store/node_table_data.h b/src/include/storage/store/node_table_data.h index d11a32080b1..6317d47f03c 100644 --- a/src/include/storage/store/node_table_data.h +++ b/src/include/storage/store/node_table_data.h @@ -40,16 +40,16 @@ class NodeTableData final : public TableData { void prepareLocalNodeGroupToCommit(common::node_group_idx_t nodeGroupIdx, transaction::Transaction* transaction, LocalNodeNG* localNodeGroup); - void prepareLocalTableToCommit( - transaction::Transaction* transaction, LocalTableData* localTable) override; + void prepareLocalTableToCommit(transaction::Transaction* transaction, + LocalTableData* localTable) override; inline common::node_group_idx_t getNumNodeGroups( transaction::Transaction* transaction) const override { return columns[0]->getNumNodeGroups(transaction); } - inline common::offset_t getNumTuplesInNodeGroup( - transaction::Transaction* transaction, common::node_group_idx_t nodeGroupIdx) const { + inline common::offset_t getNumTuplesInNodeGroup(transaction::Transaction* transaction, + common::node_group_idx_t nodeGroupIdx) const { KU_ASSERT(nodeGroupIdx < getNumNodeGroups(transaction)); return columns[0]->getMetadata(nodeGroupIdx, transaction->getType()).numValues; } diff --git a/src/storage/local_storage/local_table.cpp b/src/storage/local_storage/local_table.cpp index ed7ebee8107..4a6e498295b 100644 --- a/src/storage/local_storage/local_table.cpp +++ b/src/storage/local_storage/local_table.cpp @@ -105,8 +105,8 @@ row_idx_t LocalChunkedGroupCollection::append(std::vector vectors) return numRows++; } -void LocalChunkedGroupCollection::append( - offset_t offset, ChunkedNodeGroup* nodeGroup, offset_t numValues) { +void LocalChunkedGroupCollection::append(offset_t offset, ChunkedNodeGroup* nodeGroup, + offset_t numValues) { KU_ASSERT(nodeGroup->getNumColumns() == dataTypes.size()); offset_t appended = 0; do { @@ -126,8 +126,8 @@ void LocalChunkedGroupCollection::append( } while (appended < numValues); } -bool LocalTableData::insert( - std::vector nodeIDVectors, std::vector propertyVectors) { +bool LocalTableData::insert(std::vector nodeIDVectors, + std::vector propertyVectors) { KU_ASSERT(nodeIDVectors.size() >= 1); auto localNodeGroup = getOrCreateLocalNodeGroup(nodeIDVectors[0]); return localNodeGroup->insert(nodeIDVectors, propertyVectors); diff --git a/src/storage/store/chunked_node_group.cpp b/src/storage/store/chunked_node_group.cpp index b0b6e87c90b..a5b2ec52614 100644 --- a/src/storage/store/chunked_node_group.cpp +++ b/src/storage/store/chunked_node_group.cpp @@ -117,8 +117,8 @@ uint64_t ChunkedNodeGroup::append(const std::vector& columnVectors return numValuesToAppendInChunk; } -offset_t ChunkedNodeGroup::append( - ChunkedNodeGroup* other, offset_t offsetInOtherNodeGroup, offset_t numValues) { +offset_t ChunkedNodeGroup::append(ChunkedNodeGroup* other, offset_t offsetInOtherNodeGroup, + offset_t numValues) { KU_ASSERT(other->chunks.size() == chunks.size()); auto numNodesToAppend = std::min(std::min(numValues, other->numRows - offsetInOtherNodeGroup), chunks[0]->getCapacity() - numRows); diff --git a/src/storage/store/node_table_data.cpp b/src/storage/store/node_table_data.cpp index 0701ef6cf21..04c05fd0b1d 100644 --- a/src/storage/store/node_table_data.cpp +++ b/src/storage/store/node_table_data.cpp @@ -79,8 +79,8 @@ void NodeTableData::write(common::node_group_idx_t nodeGroupIdx, common::offset_ } } -void NodeTableData::prepareLocalNodeGroupToCommit( - node_group_idx_t nodeGroupIdx, Transaction* transaction, LocalNodeNG* localNodeGroup) { +void NodeTableData::prepareLocalNodeGroupToCommit(node_group_idx_t nodeGroupIdx, + Transaction* transaction, LocalNodeNG* localNodeGroup) { for (auto columnID = 0u; columnID < columns.size(); columnID++) { auto column = columns[columnID].get(); auto localInsertChunk = localNodeGroup->getInsertChunks().getLocalChunk(columnID); @@ -94,8 +94,8 @@ void NodeTableData::prepareLocalNodeGroupToCommit( } } -void NodeTableData::prepareLocalTableToCommit( - Transaction* transaction, LocalTableData* localTable) { +void NodeTableData::prepareLocalTableToCommit(Transaction* transaction, + LocalTableData* localTable) { for (auto& [nodeGroupIdx, localNodeGroup] : localTable->nodeGroups) { prepareLocalNodeGroupToCommit(nodeGroupIdx, transaction, ku_dynamic_cast(localNodeGroup.get()));