clean

kuzudb · Jun 13, 2023 · b18b786 · b18b786
1 parent 152df36
commit b18b786
Show file tree

Hide file tree

Showing 4 changed files with 3 additions and 4 deletions.
diff --git a/src/include/common/constants.h b/src/include/common/constants.h
@@ -20,7 +20,7 @@ constexpr uint64_t THREAD_SLEEP_TIME_WHEN_WAITING_IN_MICROS = 500;
 constexpr uint64_t DEFAULT_CHECKPOINT_WAIT_TIMEOUT_FOR_TRANSACTIONS_TO_LEAVE_IN_MICROS = 5000000;
 
 struct InternalKeyword {
-    static constexpr char ID[] =  "_id";
+    static constexpr char ID[] = "_id";
     static constexpr char LENGTH[] = "_length";
     static constexpr char NODES[] = "_nodes";
     static constexpr char RELS[] = "_rels";

diff --git a/src/include/processor/operator/recursive_extend/frontier_scanner.h b/src/include/processor/operator/recursive_extend/frontier_scanner.h
@@ -88,8 +88,7 @@ class PathScanner : public BaseFrontierScanner {
     // Initialize stacks for given offset.
     void initDfs(const frontier::node_rel_id_t& nodeAndRelID, size_t currentDepth);
 
-    void writePathToVector(RecursiveJoinVectors* vectors,
-        common::sel_t& vectorPos,
+    void writePathToVector(RecursiveJoinVectors* vectors, common::sel_t& vectorPos,
         common::sel_t& nodeIDDataVectorPos, common::sel_t& relIDDataVectorPos);
 
 private:

diff --git a/src/processor/processor_task.cpp b/src/processor/processor_task.cpp
@@ -12,7 +12,6 @@ void ProcessorTask::run() {
     auto currentSink = (Sink*)clonedPipelineRoot.get();
     auto resultSet = populateResultSet(currentSink, executionContext->memoryManager);
     currentSink->execute(resultSet.get(), executionContext);
-    auto a = 1;
 }
 
 void ProcessorTask::finalizeIfNecessary() {

diff --git a/src/processor/result/factorized_table.cpp b/src/processor/result/factorized_table.cpp
@@ -145,6 +145,7 @@ void FactorizedTable::lookup(std::vector<ValueVector*>& vectors,
     assert(vectors.size() == colIdxesToScan.size());
     for (auto i = 0u; i < colIdxesToScan.size(); i++) {
         auto vector = vectors[i];
+        // TODO(Xiyang/Ziyi): we should set up a rule about when to reset. Should it be in operator?
         vector->resetAuxiliaryBuffer();
         ft_col_idx_t colIdx = colIdxesToScan[i];
         if (tableSchema->getColumn(colIdx)->isFlat()) {