Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
SkyWalking
提交
5a352bb0
S
SkyWalking
项目概览
apache
/
SkyWalking
上一次同步 大约 1 年
通知
302
Star
21345
Fork
6091
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
S
SkyWalking
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
5a352bb0
编写于
7月 13, 2021
作者:
wu-sheng
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Fix name.
上级
5f590954
变更
4
隐藏空白更改
内联
并排
Showing
4 changed file
with
7 addition
and
7 deletion
+7
-7
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/storage/IBatchDAO.java
.../apache/skywalking/oap/server/core/storage/IBatchDAO.java
+2
-2
oap-server/server-core/src/test/java/org/apache/skywalking/oap/server/core/storage/PersistenceTimerTest.java
...walking/oap/server/core/storage/PersistenceTimerTest.java
+1
-1
oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/base/BatchProcessEsDAO.java
.../storage/plugin/elasticsearch/base/BatchProcessEsDAO.java
+2
-2
oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2BatchDAO.java
...ing/oap/server/storage/plugin/jdbc/h2/dao/H2BatchDAO.java
+2
-2
未找到文件。
oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/storage/IBatchDAO.java
浏览文件 @
5a352bb0
...
...
@@ -31,9 +31,9 @@ public interface IBatchDAO extends DAO {
* Push data into the database in async mode. This method is driven by streaming process. This method doesn't
* request the data queryable immediately after the method finished.
*
* @param
prepare
Request data to insert.
* @param
insert
Request data to insert.
*/
void
insert
(
InsertRequest
prepare
Request
);
void
insert
(
InsertRequest
insert
Request
);
/**
* Push data collection into the database in async mode. This method is driven by streaming process. This method
...
...
oap-server/server-core/src/test/java/org/apache/skywalking/oap/server/core/storage/PersistenceTimerTest.java
浏览文件 @
5a352bb0
...
...
@@ -57,7 +57,7 @@ public class PersistenceTimerTest {
moduleConfig
.
setPersistentPeriod
(
Integer
.
MAX_VALUE
);
IBatchDAO
iBatchDAO
=
new
IBatchDAO
()
{
@Override
public
void
insert
(
InsertRequest
prepare
Request
)
{
public
void
insert
(
InsertRequest
insert
Request
)
{
}
...
...
oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/base/BatchProcessEsDAO.java
浏览文件 @
5a352bb0
...
...
@@ -47,12 +47,12 @@ public class BatchProcessEsDAO extends EsDAO implements IBatchDAO {
}
@Override
public
void
insert
(
InsertRequest
prepare
Request
)
{
public
void
insert
(
InsertRequest
insert
Request
)
{
if
(
bulkProcessor
==
null
)
{
this
.
bulkProcessor
=
getClient
().
createBulkProcessor
(
bulkActions
,
flushInterval
,
concurrentRequests
);
}
this
.
bulkProcessor
.
add
((
IndexRequest
)
prepare
Request
);
this
.
bulkProcessor
.
add
((
IndexRequest
)
insert
Request
);
}
@Override
...
...
oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2BatchDAO.java
浏览文件 @
5a352bb0
...
...
@@ -81,8 +81,8 @@ public class H2BatchDAO implements IBatchDAO {
}
@Override
public
void
insert
(
InsertRequest
prepare
Request
)
{
this
.
dataCarrier
.
produce
(
prepare
Request
);
public
void
insert
(
InsertRequest
insert
Request
)
{
this
.
dataCarrier
.
produce
(
insert
Request
);
}
private
class
H2BatchConsumer
implements
IConsumer
<
PrepareRequest
>
{
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录