Skip to content

Commit 54103ca

Browse files
committed
Restore TsFileManager compatibility overloads
1 parent fe29907 commit 54103ca

1 file changed

Lines changed: 31 additions & 0 deletions

File tree

  • iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/TsFileManager.java

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,10 +65,23 @@ public TsFileManager(String storageGroupName, String dataRegionId, String dataRe
6565
this.dataRegionId = dataRegionId;
6666
}
6767

68+
public List<TsFileResource> getTsFileList(boolean sequence) {
69+
return getTsFileList(sequence, storageGroupName);
70+
}
71+
6872
public List<TsFileResource> getTsFileList(boolean sequence, String database) {
6973
return getTsFileList(sequence, null, null, database);
7074
}
7175

76+
/**
77+
* @param sequence {@code true} for sequence, {@code false} for unsequence
78+
* @param timePartitions {@code null} for all time partitions, empty for zero time partitions
79+
*/
80+
public List<TsFileResource> getTsFileList(
81+
boolean sequence, List<Long> timePartitions, Filter timeFilter) {
82+
return getTsFileList(sequence, timePartitions, timeFilter, storageGroupName);
83+
}
84+
7285
/**
7386
* @param sequence {@code true} for sequence, {@code false} for unsequence
7487
* @param timePartitions {@code null} for all time partitions, empty for zero time partitions
@@ -101,6 +114,16 @@ public List<TsFileResource> getTsFileList(
101114
}
102115
}
103116

117+
/**
118+
* don't need to acquire lock again, caller should guarantee the lock has been acquired
119+
*
120+
* @return left is seq resource list, right is unSeq resource list
121+
*/
122+
public Pair<List<TsFileResource>, List<TsFileResource>> getAllTsFileListForQuery(
123+
List<Long> timePartitions, Filter timeFilter) {
124+
return getAllTsFileListForQuery(timePartitions, timeFilter, storageGroupName);
125+
}
126+
104127
/**
105128
* don't need to acquire lock again, caller should guarantee the lock has been acquired
106129
*
@@ -158,6 +181,10 @@ public Pair<List<TsFileResource>, List<TsFileResource>> getTsFileListSnapshot(
158181
}
159182
}
160183

184+
public List<TsFileResource> getTsFileList(boolean sequence, long startTime, long endTime) {
185+
return getTsFileList(sequence, startTime, endTime, storageGroupName);
186+
}
187+
161188
public List<TsFileResource> getTsFileList(
162189
boolean sequence, long startTime, long endTime, String database) {
163190
// the iteration of ConcurrentSkipListMap is not concurrent secure
@@ -195,6 +222,10 @@ public TsFileResourceList getOrCreateUnsequenceListByTimePartition(long timePart
195222
}
196223
}
197224

225+
public Iterator<TsFileResource> getIterator(boolean sequence) {
226+
return getIterator(sequence, storageGroupName);
227+
}
228+
198229
public Iterator<TsFileResource> getIterator(boolean sequence, String database) {
199230
readLock();
200231
try {

0 commit comments

Comments
 (0)