Merge branch 'main' of https://github.com/tinyAdapter/COOL into main

COOL-cohort · Aug 13, 2024 · 68d3ff3 · 68d3ff3
2 parents edfe393 + 1d45e31
commit 68d3ff3
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/cool-core/src/main/java/com/nus/cool/core/io/readstore/CubletRS.java b/cool-core/src/main/java/com/nus/cool/core/io/readstore/CubletRS.java
@@ -33,6 +33,8 @@
 import com.nus.cool.core.schema.TableSchema;
 import lombok.Getter;
 import lombok.Setter;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * Read cublet store

diff --git a/cool-core/src/main/java/com/nus/cool/core/util/writer/NativeDataWriter.java b/cool-core/src/main/java/com/nus/cool/core/util/writer/NativeDataWriter.java
@@ -182,7 +182,8 @@ public boolean add(FieldValue[] tuple) throws IOException {
     if (maybeSwitchChunk(curUser)) {
       if (maybeSwitchCublet()) {
         // create a new data chunk with offset 0
-        this.dataChunk = DataChunkWS.newDataChunk(this.tableSchema, this.metaChunk.getMetaFields(), 0);
+        this.dataChunk = DataChunkWS.newDataChunk(
+          this.tableSchema, this.metaChunk.getMetaFields(), 0);
       }
     }
     lastUser = curUser;