This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch object_type in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 059f3d91d42d27cf57f2a65a2667c78ab328a5a9 Author: HTHou <[email protected]> AuthorDate: Thu Jul 3 18:57:56 2025 +0800 merge read part --- .../dag/column/unary/scalar/ReadObjectColumnTransformer.java | 2 +- .../storageengine/dataregion/memtable/TsFileProcessor.java | 12 ++++++------ 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ReadObjectColumnTransformer.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ReadObjectColumnTransformer.java index 51095e725a3..53de974e895 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ReadObjectColumnTransformer.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ReadObjectColumnTransformer.java @@ -109,6 +109,6 @@ public class ReadObjectColumnTransformer extends UnaryColumnTransformer { } private String getObjectPathFromBinary(Binary binary) { - return "/Users/shuww/Downloads/test_0703/aaa"; + return binary.toString().split(",")[0]; } } diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java index e311e65df7b..af49c77f110 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/TsFileProcessor.java @@ -572,18 +572,18 @@ public class TsFileProcessor { String objectFileName = insertTabletNode.getTimes()[i] + "-" + config.getDataNodeId() + "-" + 1 + ".bin"; File objectFile = new File(writer.getFile().getParent(), objectFileName); - if (fileNode.isEOF()) { - relationalInsertTabletNode.getObjectColumn()[i] = - new Binary( - (objectFile.getPath() + "," + objectFile.length()) - .getBytes(StandardCharsets.UTF_8)); - } try (ObjectWriter writer = new ObjectWriter(objectFile)) { writer.write(fileNode.getContent()); } catch (Exception e) { throw new WriteProcessException(e); } // TODO:[OBJECT] write file node wal + if (fileNode.isEOF()) { + relationalInsertTabletNode.getObjectColumn()[i] = + new Binary( + (objectFile.getPath() + "," + objectFile.length()) + .getBytes(StandardCharsets.UTF_8)); + } } } }
