(tsfile) branch tsFile_v4 updated: temp save

[jiangtian]

This is an automated email from the ASF dual-hosted git repository.

jiangtian pushed a commit to branch tsFile_v4
in repository https://gitbox.apache.org/repos/asf/tsfile.git


The following commit(s) were added to refs/heads/tsFile_v4 by this push:
     new fa870e25 temp save
fa870e25 is described below

commit fa870e256b0dcdee574cfbdf6c057802117770da
Author: Tian Jiang <jt2594...@163.com>
AuthorDate: Tue Apr 9 11:22:15 2024 +0800

    temp save
---
 .../tsfile/read/query/executor/TsFileExecutor.java     | 12 ++++++++++++
 .../org/apache/tsfile/read/reader/RecordReader.java    | 18 ++++++++++++++++++
 2 files changed, 30 insertions(+)

diff --git 
a/tsfile/src/main/java/org/apache/tsfile/read/query/executor/TsFileExecutor.java
 
b/tsfile/src/main/java/org/apache/tsfile/read/query/executor/TsFileExecutor.java
index d479b2a5..8a41452a 100644
--- 
a/tsfile/src/main/java/org/apache/tsfile/read/query/executor/TsFileExecutor.java
+++ 
b/tsfile/src/main/java/org/apache/tsfile/read/query/executor/TsFileExecutor.java
@@ -23,6 +23,8 @@ import org.apache.tsfile.enums.TSDataType;
 import org.apache.tsfile.exception.filter.QueryFilterOptimizationException;
 import org.apache.tsfile.exception.write.NoMeasurementException;
 import org.apache.tsfile.file.metadata.IChunkMetadata;
+import org.apache.tsfile.file.metadata.MetadataIndexNode;
+import org.apache.tsfile.file.metadata.TsFileMetadata;
 import org.apache.tsfile.read.common.Path;
 import org.apache.tsfile.read.common.TimeRange;
 import org.apache.tsfile.read.controller.IChunkLoader;
@@ -36,6 +38,7 @@ import 
org.apache.tsfile.read.expression.util.ExpressionOptimizer;
 import org.apache.tsfile.read.query.dataset.DataSetWithoutTimeGenerator;
 import org.apache.tsfile.read.query.dataset.QueryDataSet;
 import org.apache.tsfile.read.reader.RecordReader;
+import org.apache.tsfile.read.reader.RecordReader.EmptyRecordReader;
 import org.apache.tsfile.read.reader.series.AbstractFileSeriesReader;
 import org.apache.tsfile.read.reader.series.EmptyFileSeriesReader;
 import org.apache.tsfile.read.reader.series.FileSeriesReader;
@@ -59,6 +62,15 @@ public class TsFileExecutor implements QueryExecutor {
   @Override
   public RecordReader query(String tableName, List<String> columns, 
ExpressionTree timeFilter,
       ExpressionTree idFilter, ExpressionTree measurementFilter) {
+    TsFileMetadata fileMetadata = metadataQuerier.getWholeFileMetadata();
+    MetadataIndexNode tableIndexNode = 
fileMetadata.getTableMetadataIndexNodeMap()
+        .get(tableName);
+    if (tableIndexNode == null) {
+      return new EmptyRecordReader();
+    }
+
+    
+
     return null;
   }
 
diff --git 
a/tsfile/src/main/java/org/apache/tsfile/read/reader/RecordReader.java 
b/tsfile/src/main/java/org/apache/tsfile/read/reader/RecordReader.java
index b32a469a..782c9809 100644
--- a/tsfile/src/main/java/org/apache/tsfile/read/reader/RecordReader.java
+++ b/tsfile/src/main/java/org/apache/tsfile/read/reader/RecordReader.java
@@ -25,4 +25,22 @@ import org.apache.tsfile.read.common.block.TsBlock;
 public interface RecordReader extends AutoCloseable {
   boolean hasNext();
   TsBlock next() throws IOException;
+
+  class EmptyRecordReader implements RecordReader{
+
+    @Override
+    public boolean hasNext() {
+      return false;
+    }
+
+    @Override
+    public TsBlock next() throws IOException {
+      return null;
+    }
+
+    @Override
+    public void close() throws Exception {
+      // nothing to be done
+    }
+  }
 }