Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
Iotdb
提交
71b47110
I
Iotdb
项目概览
apache
/
Iotdb
大约 1 年 前同步成功
通知
25
Star
3344
Fork
916
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
DevOps
流水线
流水线任务
计划
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
I
Iotdb
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
DevOps
DevOps
流水线
流水线任务
计划
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
流水线任务
提交
Issue看板
体验新版 GitCode,发现更多精彩内容 >>
未验证
提交
71b47110
编写于
7月 08, 2020
作者:
H
HTHou
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
fix review
上级
c1472cb3
变更
2
隐藏空白更改
内联
并排
Showing
2 changed file
with
3 addition
and
20 deletion
+3
-20
server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
.../apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
+0
-9
server/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
...che/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
+3
-11
未找到文件。
server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
浏览文件 @
71b47110
...
...
@@ -574,15 +574,6 @@ public class TsFileProcessor {
}
}
/**
* Construct the a new or get an existing TsFileSequenceReader of a TsFile.
*
* @return a TsFileSequenceReader
*/
private
TsFileSequenceReader
getFileReader
(
TsFileResource
tsFileResource
)
throws
IOException
{
return
new
TsFileSequenceReader
(
tsFileResource
.
getPath
(),
true
);
}
public
static
File
createNewVMFile
(
TsFileResource
tsFileResource
)
{
File
parent
=
tsFileResource
.
getFile
().
getParentFile
();
return
FSFactoryProducer
.
getFSFactory
().
getFile
(
parent
,
...
...
server/src/main/java/org/apache/iotdb/db/writelog/recover/TsFileRecoverPerformer.java
浏览文件 @
71b47110
...
...
@@ -54,15 +54,6 @@ import org.apache.iotdb.tsfile.write.writer.RestorableTsFileIOWriter;
import
org.slf4j.Logger
;
import
org.slf4j.LoggerFactory
;
import
java.io.File
;
import
java.io.IOException
;
import
java.util.Collections
;
import
java.util.List
;
import
java.util.Map
;
import
java.util.Map.Entry
;
import
java.util.concurrent.ExecutionException
;
import
static
org
.
apache
.
iotdb
.
db
.
engine
.
storagegroup
.
TsFileResource
.
RESOURCE_SUFFIX
;
/**
* TsFileRecoverPerformer recovers a SeqTsFile to correct status, redoes the WALs since last crash
...
...
@@ -101,8 +92,9 @@ public class TsFileRecoverPerformer {
* 1. recover the TsFile by RestorableTsFileIOWriter and truncate the file to remaining corrected
* data 2. redo the WALs to recover unpersisted data 3. flush and close the file 4. clean WALs
*
* @return a RestorableTsFileIOWriter if the file is not closed before crush, so this writer can
* be used to continue writing
* @return a RestorableTsFileIOWriter and a list of RestorableTsFileIOWriter of vmfiles, if the
* file and the vmfiles are not closed before crush, so these writers can be used to continue
* writing
*/
public
Pair
<
RestorableTsFileIOWriter
,
List
<
RestorableTsFileIOWriter
>>
recover
()
throws
StorageGroupProcessorException
{
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录