Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
35 commits
Select commit Hold shift + click to select a range
91c50e1
change parameter 'timeLowerBound' to 'expiredTime' in FileTimeIndex.java
yyt86 Jul 6, 2021
cbc8b3f
change the position of the 'getProcessor' method
yyt86 Jul 6, 2021
61f8b08
modify TsFileResource
Jul 11, 2021
09fb62b
don't change timeLowerBound in TsFileResource
Jul 12, 2021
4ff71a9
Merge branch 'TsFileResource' into remove_device_in_time_index
Jul 12, 2021
2b991f3
remove comment
Jul 12, 2021
93adc8d
remove deviceNumInLastClosedTsFile
Jul 13, 2021
39d39c7
Merge branch 'remove_device_in_time_index' into remove_device_set
Jul 13, 2021
f767d62
add checkDeviceIdExist in ITimeIndex
Jul 14, 2021
7fd57b1
modify checkDeviceIdExist method
Jul 14, 2021
aac1419
remove set timezone as GMT+8
Jul 14, 2021
accb76d
Merge branch 'master' into remove_device_set
Jul 14, 2021
209f054
merge master
Jul 14, 2021
af5a49e
modify canSkipDelete in StorageGroupProcessor
Jul 14, 2021
a7db4d2
merger master
Jul 15, 2021
c32fc83
revise isDeciveInRes method name
Jul 16, 2021
62207d9
Merge branch 'master' into remove_device_set
Jul 19, 2021
ad36434
delete TimeIndexLevel related method in all classes
Jul 20, 2021
9ee2392
remove comment
Jul 20, 2021
79d38d6
delete TimeIndexLevel class
Jul 21, 2021
fc14341
add TimeIndexLevel class
Jul 21, 2021
e21590d
recover TimeIndexLevel and modify getDevices method in FileTimeIndex
Jul 23, 2021
d77555c
delete getDevices in IMemTable
Jul 23, 2021
847b947
remove devices field in FileTimeIndex class
Jul 27, 2021
6b52437
modify the comments
Jul 28, 2021
c01bae5
Merge branch 'master' into remove_device_set
Aug 5, 2021
c928c18
add throw RunTimeException
Aug 5, 2021
c9227cd
add throw RunTimeException
Aug 5, 2021
032601c
spotless:apply
Aug 6, 2021
c37cfe5
add throwing IOException for getDevices of FileTimeIndex
Aug 6, 2021
1507083
format change
Aug 6, 2021
59c9a76
delete part of IOException throw
Aug 9, 2021
c3a602d
merge remove_device_set branch
Aug 9, 2021
aa88441
revise format
Aug 9, 2021
4deab87
merge master
Aug 9, 2021
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -468,7 +468,7 @@ public long getEndTime(String deviceId) {
return timeIndex.getEndTime(deviceId);
}

public Set<String> getDevices() {
public Set<String> getDevices() throws IOException {
return timeIndex.getDevices(file.getPath());
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -80,14 +80,9 @@ public void close() {
}

@Override
public Set<String> getDevices(String tsFilePath) {
try {
TsFileSequenceReader fileReader = FileReaderManager.getInstance().get(tsFilePath, true);
return new HashSet<>(fileReader.getAllDevices());
} catch (IOException e) {
logger.error("Can't read file {} from disk ", tsFilePath, e);
throw new RuntimeException("Can't read file " + tsFilePath + " from disk");
}
public Set<String> getDevices(String tsFilePath) throws IOException {
TsFileSequenceReader fileReader = FileReaderManager.getInstance().get(tsFilePath, true);
return new HashSet<>(fileReader.getAllDevices());
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,8 @@ public interface ITimeIndex {
*
* @return device names
*/
Set<String> getDevices(String tsFilePath);
Set<String> getDevices(String tsFilePath) throws IOException;


/** @return whether end time is empty (Long.MIN_VALUE) */
boolean endTimeEmpty();
Expand Down