Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
SkyWalking
提交
11b31056
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,发现更多精彩内容 >>
提交
11b31056
编写于
12月 04, 2017
作者:
wu-sheng
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
Fix worker ids.
上级
baf40004
变更
31
隐藏空白更改
内联
并排
Showing
31 changed file
with
31 addition
and
31 deletion
+31
-31
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/parser/standardization/SegmentStandardizationWorker.java
.../parser/standardization/SegmentStandardizationWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/jvm/CpuMetricPersistenceWorker.java
...r/agent/stream/worker/jvm/CpuMetricPersistenceWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/jvm/GCMetricPersistenceWorker.java
...or/agent/stream/worker/jvm/GCMetricPersistenceWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/jvm/InstHeartBeatPersistenceWorker.java
...ent/stream/worker/jvm/InstHeartBeatPersistenceWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/jvm/MemoryMetricPersistenceWorker.java
...gent/stream/worker/jvm/MemoryMetricPersistenceWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/jvm/MemoryPoolMetricPersistenceWorker.java
.../stream/worker/jvm/MemoryPoolMetricPersistenceWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/register/ApplicationRegisterRemoteWorker.java
...ream/worker/register/ApplicationRegisterRemoteWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/register/ApplicationRegisterSerialWorker.java
...ream/worker/register/ApplicationRegisterSerialWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/register/InstanceRegisterRemoteWorker.java
.../stream/worker/register/InstanceRegisterRemoteWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/register/InstanceRegisterSerialWorker.java
.../stream/worker/register/InstanceRegisterSerialWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/register/ServiceNameRegisterRemoteWorker.java
...ream/worker/register/ServiceNameRegisterRemoteWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/register/ServiceNameRegisterSerialWorker.java
...ream/worker/register/ServiceNameRegisterSerialWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/global/GlobalTracePersistenceWorker.java
...eam/worker/trace/global/GlobalTracePersistenceWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/instance/InstPerformancePersistenceWorker.java
...rker/trace/instance/InstPerformancePersistenceWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/node/NodeComponentAggregationWorker.java
...eam/worker/trace/node/NodeComponentAggregationWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/node/NodeComponentPersistenceWorker.java
...eam/worker/trace/node/NodeComponentPersistenceWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/node/NodeComponentRemoteWorker.java
...t/stream/worker/trace/node/NodeComponentRemoteWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/node/NodeMappingAggregationWorker.java
...tream/worker/trace/node/NodeMappingAggregationWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/node/NodeMappingPersistenceWorker.java
...tream/worker/trace/node/NodeMappingPersistenceWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/node/NodeMappingRemoteWorker.java
...ent/stream/worker/trace/node/NodeMappingRemoteWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/noderef/NodeReferenceAggregationWorker.java
.../worker/trace/noderef/NodeReferenceAggregationWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/noderef/NodeReferencePersistenceWorker.java
.../worker/trace/noderef/NodeReferencePersistenceWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/noderef/NodeReferenceRemoteWorker.java
...tream/worker/trace/noderef/NodeReferenceRemoteWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/segment/SegmentCostPersistenceWorker.java
...am/worker/trace/segment/SegmentCostPersistenceWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/segment/SegmentPersistenceWorker.java
...stream/worker/trace/segment/SegmentPersistenceWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/service/ServiceEntryAggregationWorker.java
...m/worker/trace/service/ServiceEntryAggregationWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/service/ServiceEntryPersistenceWorker.java
...m/worker/trace/service/ServiceEntryPersistenceWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/service/ServiceEntryRemoteWorker.java
...stream/worker/trace/service/ServiceEntryRemoteWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/serviceref/ServiceReferenceAggregationWorker.java
...r/trace/serviceref/ServiceReferenceAggregationWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/serviceref/ServiceReferencePersistenceWorker.java
...r/trace/serviceref/ServiceReferencePersistenceWorker.java
+1
-1
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/serviceref/ServiceReferenceRemoteWorker.java
...worker/trace/serviceref/ServiceReferenceRemoteWorker.java
+1
-1
未找到文件。
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/parser/standardization/SegmentStandardizationWorker.java
浏览文件 @
11b31056
...
@@ -42,7 +42,7 @@ public class SegmentStandardizationWorker extends AbstractLocalAsyncWorker<Segme
...
@@ -42,7 +42,7 @@ public class SegmentStandardizationWorker extends AbstractLocalAsyncWorker<Segme
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
SegmentStandardizationWorker
.
class
.
hashCode
()
;
return
108
;
}
}
@Override
protected
void
onWork
(
SegmentStandardization
segmentStandardization
)
throws
WorkerException
{
@Override
protected
void
onWork
(
SegmentStandardization
segmentStandardization
)
throws
WorkerException
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/jvm/CpuMetricPersistenceWorker.java
浏览文件 @
11b31056
...
@@ -37,7 +37,7 @@ public class CpuMetricPersistenceWorker extends PersistenceWorker<CpuMetric, Cpu
...
@@ -37,7 +37,7 @@ public class CpuMetricPersistenceWorker extends PersistenceWorker<CpuMetric, Cpu
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
0
;
return
115
;
}
}
@Override
protected
boolean
needMergeDBData
()
{
@Override
protected
boolean
needMergeDBData
()
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/jvm/GCMetricPersistenceWorker.java
浏览文件 @
11b31056
...
@@ -37,7 +37,7 @@ public class GCMetricPersistenceWorker extends PersistenceWorker<GCMetric, GCMet
...
@@ -37,7 +37,7 @@ public class GCMetricPersistenceWorker extends PersistenceWorker<GCMetric, GCMet
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
0
;
return
112
;
}
}
@Override
protected
boolean
needMergeDBData
()
{
@Override
protected
boolean
needMergeDBData
()
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/jvm/InstHeartBeatPersistenceWorker.java
浏览文件 @
11b31056
...
@@ -37,7 +37,7 @@ public class InstHeartBeatPersistenceWorker extends PersistenceWorker<Instance,
...
@@ -37,7 +37,7 @@ public class InstHeartBeatPersistenceWorker extends PersistenceWorker<Instance,
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
InstHeartBeatPersistenceWorker
.
class
.
hashCode
()
;
return
113
;
}
}
@Override
protected
boolean
needMergeDBData
()
{
@Override
protected
boolean
needMergeDBData
()
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/jvm/MemoryMetricPersistenceWorker.java
浏览文件 @
11b31056
...
@@ -37,7 +37,7 @@ public class MemoryMetricPersistenceWorker extends PersistenceWorker<MemoryMetri
...
@@ -37,7 +37,7 @@ public class MemoryMetricPersistenceWorker extends PersistenceWorker<MemoryMetri
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
0
;
return
119
;
}
}
@Override
protected
boolean
needMergeDBData
()
{
@Override
protected
boolean
needMergeDBData
()
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/jvm/MemoryPoolMetricPersistenceWorker.java
浏览文件 @
11b31056
...
@@ -33,7 +33,7 @@ import org.skywalking.apm.collector.stream.worker.impl.PersistenceWorker;
...
@@ -33,7 +33,7 @@ import org.skywalking.apm.collector.stream.worker.impl.PersistenceWorker;
public
class
MemoryPoolMetricPersistenceWorker
extends
PersistenceWorker
<
MemoryPoolMetric
,
MemoryPoolMetric
>
{
public
class
MemoryPoolMetricPersistenceWorker
extends
PersistenceWorker
<
MemoryPoolMetric
,
MemoryPoolMetric
>
{
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
0
;
return
122
;
}
}
public
MemoryPoolMetricPersistenceWorker
(
ModuleManager
moduleManager
)
{
public
MemoryPoolMetricPersistenceWorker
(
ModuleManager
moduleManager
)
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/register/ApplicationRegisterRemoteWorker.java
浏览文件 @
11b31056
...
@@ -40,7 +40,7 @@ public class ApplicationRegisterRemoteWorker extends AbstractRemoteWorker<Applic
...
@@ -40,7 +40,7 @@ public class ApplicationRegisterRemoteWorker extends AbstractRemoteWorker<Applic
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
ApplicationRegisterRemoteWorker
.
class
.
hashCode
()
;
return
10006
;
}
}
@Override
protected
void
onWork
(
Application
message
)
throws
WorkerException
{
@Override
protected
void
onWork
(
Application
message
)
throws
WorkerException
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/register/ApplicationRegisterSerialWorker.java
浏览文件 @
11b31056
...
@@ -50,7 +50,7 @@ public class ApplicationRegisterSerialWorker extends AbstractLocalAsyncWorker<Ap
...
@@ -50,7 +50,7 @@ public class ApplicationRegisterSerialWorker extends AbstractLocalAsyncWorker<Ap
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
ApplicationRegisterSerialWorker
.
class
.
hashCode
()
;
return
101
;
}
}
@Override
protected
void
onWork
(
Application
application
)
throws
WorkerException
{
@Override
protected
void
onWork
(
Application
application
)
throws
WorkerException
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/register/InstanceRegisterRemoteWorker.java
浏览文件 @
11b31056
...
@@ -36,7 +36,7 @@ public class InstanceRegisterRemoteWorker extends AbstractRemoteWorker<Instance,
...
@@ -36,7 +36,7 @@ public class InstanceRegisterRemoteWorker extends AbstractRemoteWorker<Instance,
private
final
Logger
logger
=
LoggerFactory
.
getLogger
(
InstanceRegisterRemoteWorker
.
class
);
private
final
Logger
logger
=
LoggerFactory
.
getLogger
(
InstanceRegisterRemoteWorker
.
class
);
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
InstanceRegisterRemoteWorker
.
class
.
hashCode
()
;
return
10001
;
}
}
InstanceRegisterRemoteWorker
(
ModuleManager
moduleManager
)
{
InstanceRegisterRemoteWorker
(
ModuleManager
moduleManager
)
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/register/InstanceRegisterSerialWorker.java
浏览文件 @
11b31056
...
@@ -48,7 +48,7 @@ public class InstanceRegisterSerialWorker extends AbstractLocalAsyncWorker<Insta
...
@@ -48,7 +48,7 @@ public class InstanceRegisterSerialWorker extends AbstractLocalAsyncWorker<Insta
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
InstanceRegisterSerialWorker
.
class
.
hashCode
()
;
return
102
;
}
}
@Override
protected
void
onWork
(
Instance
instance
)
throws
WorkerException
{
@Override
protected
void
onWork
(
Instance
instance
)
throws
WorkerException
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/register/ServiceNameRegisterRemoteWorker.java
浏览文件 @
11b31056
...
@@ -40,7 +40,7 @@ public class ServiceNameRegisterRemoteWorker extends AbstractRemoteWorker<Servic
...
@@ -40,7 +40,7 @@ public class ServiceNameRegisterRemoteWorker extends AbstractRemoteWorker<Servic
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
ServiceNameRegisterRemoteWorker
.
class
.
hashCode
()
;
return
10000
;
}
}
@Override
protected
void
onWork
(
ServiceName
serviceName
)
throws
WorkerException
{
@Override
protected
void
onWork
(
ServiceName
serviceName
)
throws
WorkerException
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/register/ServiceNameRegisterSerialWorker.java
浏览文件 @
11b31056
...
@@ -50,7 +50,7 @@ public class ServiceNameRegisterSerialWorker extends AbstractLocalAsyncWorker<Se
...
@@ -50,7 +50,7 @@ public class ServiceNameRegisterSerialWorker extends AbstractLocalAsyncWorker<Se
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
ServiceNameRegisterSerialWorker
.
class
.
hashCode
()
;
return
100
;
}
}
@Override
protected
void
onWork
(
ServiceName
serviceName
)
throws
WorkerException
{
@Override
protected
void
onWork
(
ServiceName
serviceName
)
throws
WorkerException
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/global/GlobalTracePersistenceWorker.java
浏览文件 @
11b31056
...
@@ -37,7 +37,7 @@ public class GlobalTracePersistenceWorker extends PersistenceWorker<GlobalTrace,
...
@@ -37,7 +37,7 @@ public class GlobalTracePersistenceWorker extends PersistenceWorker<GlobalTrace,
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
0
;
return
12
0
;
}
}
@Override
protected
boolean
needMergeDBData
()
{
@Override
protected
boolean
needMergeDBData
()
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/instance/InstPerformancePersistenceWorker.java
浏览文件 @
11b31056
...
@@ -37,7 +37,7 @@ public class InstPerformancePersistenceWorker extends PersistenceWorker<InstPerf
...
@@ -37,7 +37,7 @@ public class InstPerformancePersistenceWorker extends PersistenceWorker<InstPerf
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
InstPerformancePersistenceWorker
.
class
.
hashCode
()
;
return
118
;
}
}
@Override
protected
boolean
needMergeDBData
()
{
@Override
protected
boolean
needMergeDBData
()
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/node/NodeComponentAggregationWorker.java
浏览文件 @
11b31056
...
@@ -34,7 +34,7 @@ public class NodeComponentAggregationWorker extends AggregationWorker<NodeCompon
...
@@ -34,7 +34,7 @@ public class NodeComponentAggregationWorker extends AggregationWorker<NodeCompon
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
NodeComponentAggregationWorker
.
class
.
hashCode
()
;
return
104
;
}
}
public
static
class
Factory
extends
AbstractLocalAsyncWorkerProvider
<
NodeComponent
,
NodeComponent
,
NodeComponentAggregationWorker
>
{
public
static
class
Factory
extends
AbstractLocalAsyncWorkerProvider
<
NodeComponent
,
NodeComponent
,
NodeComponentAggregationWorker
>
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/node/NodeComponentPersistenceWorker.java
浏览文件 @
11b31056
...
@@ -37,7 +37,7 @@ public class NodeComponentPersistenceWorker extends PersistenceWorker<NodeCompon
...
@@ -37,7 +37,7 @@ public class NodeComponentPersistenceWorker extends PersistenceWorker<NodeCompon
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
NodeComponentPersistenceWorker
.
class
.
hashCode
()
;
return
111
;
}
}
@Override
protected
boolean
needMergeDBData
()
{
@Override
protected
boolean
needMergeDBData
()
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/node/NodeComponentRemoteWorker.java
浏览文件 @
11b31056
...
@@ -36,7 +36,7 @@ public class NodeComponentRemoteWorker extends AbstractRemoteWorker<NodeComponen
...
@@ -36,7 +36,7 @@ public class NodeComponentRemoteWorker extends AbstractRemoteWorker<NodeComponen
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
NodeComponentRemoteWorker
.
class
.
hashCode
()
;
return
10004
;
}
}
@Override
protected
void
onWork
(
NodeComponent
nodeComponent
)
throws
WorkerException
{
@Override
protected
void
onWork
(
NodeComponent
nodeComponent
)
throws
WorkerException
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/node/NodeMappingAggregationWorker.java
浏览文件 @
11b31056
...
@@ -34,7 +34,7 @@ public class NodeMappingAggregationWorker extends AggregationWorker<NodeMapping,
...
@@ -34,7 +34,7 @@ public class NodeMappingAggregationWorker extends AggregationWorker<NodeMapping,
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
NodeMappingAggregationWorker
.
class
.
hashCode
()
;
return
105
;
}
}
public
static
class
Factory
extends
AbstractLocalAsyncWorkerProvider
<
NodeMapping
,
NodeMapping
,
NodeMappingAggregationWorker
>
{
public
static
class
Factory
extends
AbstractLocalAsyncWorkerProvider
<
NodeMapping
,
NodeMapping
,
NodeMappingAggregationWorker
>
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/node/NodeMappingPersistenceWorker.java
浏览文件 @
11b31056
...
@@ -37,7 +37,7 @@ public class NodeMappingPersistenceWorker extends PersistenceWorker<NodeMapping,
...
@@ -37,7 +37,7 @@ public class NodeMappingPersistenceWorker extends PersistenceWorker<NodeMapping,
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
NodeMappingPersistenceWorker
.
class
.
hashCode
()
;
return
114
;
}
}
@Override
protected
boolean
needMergeDBData
()
{
@Override
protected
boolean
needMergeDBData
()
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/node/NodeMappingRemoteWorker.java
浏览文件 @
11b31056
...
@@ -36,7 +36,7 @@ public class NodeMappingRemoteWorker extends AbstractRemoteWorker<NodeMapping, N
...
@@ -36,7 +36,7 @@ public class NodeMappingRemoteWorker extends AbstractRemoteWorker<NodeMapping, N
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
NodeMappingRemoteWorker
.
class
.
hashCode
()
;
return
10007
;
}
}
@Override
protected
void
onWork
(
NodeMapping
nodeMapping
)
throws
WorkerException
{
@Override
protected
void
onWork
(
NodeMapping
nodeMapping
)
throws
WorkerException
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/noderef/NodeReferenceAggregationWorker.java
浏览文件 @
11b31056
...
@@ -34,7 +34,7 @@ public class NodeReferenceAggregationWorker extends AggregationWorker<NodeRefere
...
@@ -34,7 +34,7 @@ public class NodeReferenceAggregationWorker extends AggregationWorker<NodeRefere
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
NodeReferenceAggregationWorker
.
class
.
hashCode
()
;
return
106
;
}
}
public
static
class
Factory
extends
AbstractLocalAsyncWorkerProvider
<
NodeReference
,
NodeReference
,
NodeReferenceAggregationWorker
>
{
public
static
class
Factory
extends
AbstractLocalAsyncWorkerProvider
<
NodeReference
,
NodeReference
,
NodeReferenceAggregationWorker
>
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/noderef/NodeReferencePersistenceWorker.java
浏览文件 @
11b31056
...
@@ -37,7 +37,7 @@ public class NodeReferencePersistenceWorker extends PersistenceWorker<NodeRefere
...
@@ -37,7 +37,7 @@ public class NodeReferencePersistenceWorker extends PersistenceWorker<NodeRefere
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
0
;
return
116
;
}
}
@Override
protected
boolean
needMergeDBData
()
{
@Override
protected
boolean
needMergeDBData
()
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/noderef/NodeReferenceRemoteWorker.java
浏览文件 @
11b31056
...
@@ -36,7 +36,7 @@ public class NodeReferenceRemoteWorker extends AbstractRemoteWorker<NodeReferenc
...
@@ -36,7 +36,7 @@ public class NodeReferenceRemoteWorker extends AbstractRemoteWorker<NodeReferenc
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
NodeReferenceRemoteWorker
.
class
.
hashCode
()
;
return
10002
;
}
}
@Override
protected
void
onWork
(
NodeReference
nodeReference
)
throws
WorkerException
{
@Override
protected
void
onWork
(
NodeReference
nodeReference
)
throws
WorkerException
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/segment/SegmentCostPersistenceWorker.java
浏览文件 @
11b31056
...
@@ -37,7 +37,7 @@ public class SegmentCostPersistenceWorker extends PersistenceWorker<SegmentCost,
...
@@ -37,7 +37,7 @@ public class SegmentCostPersistenceWorker extends PersistenceWorker<SegmentCost,
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
SegmentCostPersistenceWorker
.
class
.
hashCode
()
;
return
110
;
}
}
@Override
protected
boolean
needMergeDBData
()
{
@Override
protected
boolean
needMergeDBData
()
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/segment/SegmentPersistenceWorker.java
浏览文件 @
11b31056
...
@@ -37,7 +37,7 @@ public class SegmentPersistenceWorker extends PersistenceWorker<Segment, Segment
...
@@ -37,7 +37,7 @@ public class SegmentPersistenceWorker extends PersistenceWorker<Segment, Segment
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
0
;
return
117
;
}
}
@Override
protected
boolean
needMergeDBData
()
{
@Override
protected
boolean
needMergeDBData
()
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/service/ServiceEntryAggregationWorker.java
浏览文件 @
11b31056
...
@@ -34,7 +34,7 @@ public class ServiceEntryAggregationWorker extends AggregationWorker<ServiceEntr
...
@@ -34,7 +34,7 @@ public class ServiceEntryAggregationWorker extends AggregationWorker<ServiceEntr
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
ServiceEntryAggregationWorker
.
class
.
hashCode
()
;
return
103
;
}
}
public
static
class
Factory
extends
AbstractLocalAsyncWorkerProvider
<
ServiceEntry
,
ServiceEntry
,
ServiceEntryAggregationWorker
>
{
public
static
class
Factory
extends
AbstractLocalAsyncWorkerProvider
<
ServiceEntry
,
ServiceEntry
,
ServiceEntryAggregationWorker
>
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/service/ServiceEntryPersistenceWorker.java
浏览文件 @
11b31056
...
@@ -37,7 +37,7 @@ public class ServiceEntryPersistenceWorker extends PersistenceWorker<ServiceEntr
...
@@ -37,7 +37,7 @@ public class ServiceEntryPersistenceWorker extends PersistenceWorker<ServiceEntr
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
0
;
return
121
;
}
}
@Override
protected
boolean
needMergeDBData
()
{
@Override
protected
boolean
needMergeDBData
()
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/service/ServiceEntryRemoteWorker.java
浏览文件 @
11b31056
...
@@ -36,7 +36,7 @@ public class ServiceEntryRemoteWorker extends AbstractRemoteWorker<ServiceEntry,
...
@@ -36,7 +36,7 @@ public class ServiceEntryRemoteWorker extends AbstractRemoteWorker<ServiceEntry,
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
ServiceEntryRemoteWorker
.
class
.
hashCode
()
;
return
10003
;
}
}
@Override
protected
void
onWork
(
ServiceEntry
serviceEntry
)
throws
WorkerException
{
@Override
protected
void
onWork
(
ServiceEntry
serviceEntry
)
throws
WorkerException
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/serviceref/ServiceReferenceAggregationWorker.java
浏览文件 @
11b31056
...
@@ -34,7 +34,7 @@ public class ServiceReferenceAggregationWorker extends AggregationWorker<Service
...
@@ -34,7 +34,7 @@ public class ServiceReferenceAggregationWorker extends AggregationWorker<Service
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
ServiceReferenceAggregationWorker
.
class
.
hashCode
()
;
return
107
;
}
}
public
static
class
Factory
extends
AbstractLocalAsyncWorkerProvider
<
ServiceReference
,
ServiceReference
,
ServiceReferenceAggregationWorker
>
{
public
static
class
Factory
extends
AbstractLocalAsyncWorkerProvider
<
ServiceReference
,
ServiceReference
,
ServiceReferenceAggregationWorker
>
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/serviceref/ServiceReferencePersistenceWorker.java
浏览文件 @
11b31056
...
@@ -37,7 +37,7 @@ public class ServiceReferencePersistenceWorker extends PersistenceWorker<Service
...
@@ -37,7 +37,7 @@ public class ServiceReferencePersistenceWorker extends PersistenceWorker<Service
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
0
;
return
109
;
}
}
@Override
protected
boolean
needMergeDBData
()
{
@Override
protected
boolean
needMergeDBData
()
{
...
...
apm-collector/apm-collector-agent-stream/collector-agent-stream-provider/src/main/java/org/skywalking/apm/collector/agent/stream/worker/trace/serviceref/ServiceReferenceRemoteWorker.java
浏览文件 @
11b31056
...
@@ -36,7 +36,7 @@ public class ServiceReferenceRemoteWorker extends AbstractRemoteWorker<ServiceRe
...
@@ -36,7 +36,7 @@ public class ServiceReferenceRemoteWorker extends AbstractRemoteWorker<ServiceRe
}
}
@Override
public
int
id
()
{
@Override
public
int
id
()
{
return
ServiceReferenceRemoteWorker
.
class
.
hashCode
()
;
return
10005
;
}
}
@Override
protected
void
onWork
(
ServiceReference
serviceReference
)
throws
WorkerException
{
@Override
protected
void
onWork
(
ServiceReference
serviceReference
)
throws
WorkerException
{
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录