Skip to content

Commit

Permalink
Run clang-format
Browse files Browse the repository at this point in the history
  • Loading branch information
benjaminwinger committed Apr 16, 2024
1 parent a40fd36 commit beaf397
Show file tree
Hide file tree
Showing 7 changed files with 20 additions and 20 deletions.
4 changes: 2 additions & 2 deletions src/include/storage/local_storage/local_node_table.h
Original file line number Diff line number Diff line change
Expand Up @@ -23,8 +23,8 @@ class LocalNodeNG final : public LocalNodeGroup {

bool insert(std::vector<common::ValueVector*> nodeIDVectors,
std::vector<common::ValueVector*> 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<common::ValueVector*> nodeIDVectors, common::column_id_t columnID,
common::ValueVector* propertyVector) override;
bool delete_(common::ValueVector* nodeIDVector,
Expand Down
4 changes: 2 additions & 2 deletions src/include/storage/store/chunked_node_group.h
Original file line number Diff line number Diff line change
Expand Up @@ -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<std::unique_ptr<ColumnChunk>>& data, common::column_id_t offsetColumnID);
void write(const std::vector<std::unique_ptr<ColumnChunk>>& data,
common::column_id_t offsetColumnID);
void write(const ChunkedNodeGroup& data, common::column_id_t offsetColumnID);

void finalize(uint64_t nodeGroupIdx_);
Expand Down
4 changes: 2 additions & 2 deletions src/include/storage/store/node_table.h
Original file line number Diff line number Diff line change
Expand Up @@ -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);
}

Expand Down
8 changes: 4 additions & 4 deletions src/include/storage/store/node_table_data.h
Original file line number Diff line number Diff line change
Expand Up @@ -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;
}
Expand Down
8 changes: 4 additions & 4 deletions src/storage/local_storage/local_table.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -105,8 +105,8 @@ row_idx_t LocalChunkedGroupCollection::append(std::vector<ValueVector*> 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 {
Expand All @@ -126,8 +126,8 @@ void LocalChunkedGroupCollection::append(
} while (appended < numValues);
}

bool LocalTableData::insert(
std::vector<ValueVector*> nodeIDVectors, std::vector<ValueVector*> propertyVectors) {
bool LocalTableData::insert(std::vector<ValueVector*> nodeIDVectors,
std::vector<ValueVector*> propertyVectors) {
KU_ASSERT(nodeIDVectors.size() >= 1);
auto localNodeGroup = getOrCreateLocalNodeGroup(nodeIDVectors[0]);
return localNodeGroup->insert(nodeIDVectors, propertyVectors);
Expand Down
4 changes: 2 additions & 2 deletions src/storage/store/chunked_node_group.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -117,8 +117,8 @@ uint64_t ChunkedNodeGroup::append(const std::vector<ValueVector*>& 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);
Expand Down
8 changes: 4 additions & 4 deletions src/storage/store/node_table_data.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -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);
Expand All @@ -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*, LocalNodeNG*>(localNodeGroup.get()));
Expand Down

0 comments on commit beaf397

Please sign in to comment.