You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@skywalking.apache.org by wu...@apache.org on 2018/06/25 14:32:27 UTC
[incubator-skywalking] branch ui/license updated (3cd6fa5 ->
e88750d)
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a change to branch ui/license
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git.
from 3cd6fa5 Update licenses of UI
add 5e03ec8 [Collector] Topology query tuning, Batch Process instead of bulk. (#1384)
add b35eaac [Collector] Tolerate and ignore unsupport segments (#1385)
new e88750d Merge branch 'master' into ui/license
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../handler/ApplicationRegisterServiceHandler.java | 4 +-
.../provider/handler/JVMMetricsServiceHandler.java | 21 ++--
.../NetworkAddressRegisterServiceHandler.java | 5 +-
.../handler/TraceSegmentServiceHandler.java | 5 +-
.../NetworkAddressRegisterServletHandler.java | 19 ++--
.../handler/TraceSegmentServletHandler.java | 20 ++--
.../jvm/provider/service/GCMetricService.java | 6 +-
.../provider/service/InstanceHeartBeatService.java | 4 +-
.../ApplicationComponentSpanListener.java | 2 +-
.../mapping/ApplicationMappingSpanListener.java | 15 ++-
.../worker/global/GlobalTraceSpanListener.java | 10 +-
.../mapping/InstanceMappingSpanListener.java | 15 ++-
.../segment/SegmentDurationSpanListener.java | 6 +-
.../heartbeat/ServiceNameAggregationWorker.java | 2 +-
.../ServiceNameHeartBeatPersistenceWorker.java | 2 +-
.../service/heartbeat/ServiceNameSpanListener.java | 2 +-
.../ServiceReferenceMetricSpanListener.java | 10 +-
.../register/ApplicationRegisterRemoteWorker.java | 17 ++-
.../register/ApplicationRegisterSerialWorker.java | 16 ++-
.../register/InstanceRegisterRemoteWorker.java | 16 ++-
.../register/InstanceRegisterSerialWorker.java | 16 ++-
.../NetworkAddressRegisterRemoteWorker.java | 17 ++-
.../NetworkAddressRegisterSerialWorker.java | 14 +--
.../register/ServiceNameRegisterSerialWorker.java | 5 +-
.../provider/service/InstanceIDService.java | 10 +-
.../provider/buffer/SegmentBufferManager.java | 5 +-
.../provider/buffer/SegmentBufferReader.java | 11 +-
.../parser/provider/parser/SegmentParse.java | 20 ++--
.../provider/parser/SegmentPersistenceWorker.java | 2 +-
.../parser/standardization/SpanIdExchanger.java | 12 ++-
.../provider/service/SegmentBase64Printer.java | 2 +-
.../base/AbstractLocalAsyncWorkerProvider.java | 2 +-
.../analysis/worker/model/base/AbstractWorker.java | 2 +-
.../worker/model/base/LocalAsyncWorkerRef.java | 8 +-
.../worker/model/base/RemoteWorkerRef.java | 2 +-
.../worker/model/impl/AggregationWorker.java | 21 ++--
.../worker/model/impl/MergePersistenceWorker.java | 14 ++-
.../model/impl/NonMergePersistenceWorker.java | 4 +-
.../worker/model/impl/PersistenceWorker.java | 2 +-
.../analysis/worker/timer/PersistenceTimer.java | 25 +++--
.../src/main/resources/application.yml | 8 +-
.../guava/service/ServiceIdCacheGuavaService.java | 2 +-
.../service/ServiceNameCacheGuavaService.java | 13 ++-
.../client/elasticsearch/ElasticSearchClient.java | 22 ++--
.../apm/collector/core/cache/Window.java | 2 +-
.../apm/collector/core/data/StreamData.java | 16 ++-
.../core/data/operator/NonMergeOperation.java | 1 +
.../apm/collector/instrument/MetricTree.java | 12 +--
.../collector/instrument/ServiceMetricTracing.java | 10 +-
.../instrument/tools/ReportFormatter.java | 27 ++---
.../service/selector/ForeverFirstSelector.java | 4 +-
.../storage/base/dao/IPersistenceDAO.java | 5 +-
.../storage/table/alarm/ApplicationAlarm.java | 5 +-
.../storage/table/alarm/ApplicationAlarmList.java | 5 +-
.../table/alarm/ApplicationReferenceAlarm.java | 5 +-
.../table/alarm/ApplicationReferenceAlarmList.java | 5 +-
.../storage/table/alarm/InstanceAlarm.java | 5 +-
.../storage/table/alarm/InstanceAlarmList.java | 5 +-
.../table/alarm/InstanceReferenceAlarm.java | 5 +-
.../table/alarm/InstanceReferenceAlarmList.java | 5 +-
.../storage/table/alarm/ServiceAlarm.java | 5 +-
.../storage/table/alarm/ServiceAlarmList.java | 5 +-
.../storage/table/alarm/ServiceReferenceAlarm.java | 5 +-
.../table/alarm/ServiceReferenceAlarmList.java | 5 +-
.../table/application/ApplicationComponent.java | 5 +-
.../table/application/ApplicationMapping.java | 5 +-
.../table/application/ApplicationMetric.java | 5 +-
.../application/ApplicationReferenceMetric.java | 5 +-
.../storage/table/global/GlobalTrace.java | 8 +-
.../table/global/ResponseTimeDistribution.java | 5 +-
.../storage/table/instance/InstanceMapping.java | 5 +-
.../storage/table/instance/InstanceMetric.java | 5 +-
.../table/instance/InstanceReferenceMetric.java | 5 +-
.../apm/collector/storage/table/jvm/GCMetric.java | 5 +-
.../collector/storage/table/jvm/MemoryMetric.java | 5 +-
.../storage/table/jvm/MemoryPoolMetric.java | 5 +-
.../storage/table/register/Application.java | 8 +-
.../collector/storage/table/register/Instance.java | 5 +-
.../storage/table/register/NetworkAddress.java | 9 +-
.../storage/table/register/ServiceName.java | 5 +-
.../collector/storage/table/segment/Segment.java | 8 +-
.../storage/table/service/ServiceMetric.java | 5 +-
.../table/service/ServiceReferenceMetric.java | 6 +-
.../collector/storage/es/MetricTransformUtil.java | 41 +++----
.../storage/es/StorageModuleEsConfig.java | 36 +++++++
.../storage/es/StorageModuleEsProvider.java | 4 +-
.../es/base/dao/AbstractPersistenceEsDAO.java | 12 ++-
.../collector/storage/es/base/dao/BatchEsDAO.java | 72 -------------
.../storage/es/base/dao/BatchProcessEsDAO.java | 120 +++++++++++++++++++++
.../es/dao/GlobalTraceEsPersistenceDAO.java | 17 +--
.../es/dao/InstanceHeartBeatEsPersistenceDAO.java | 12 ++-
.../es/dao/SegmentDurationEsPersistenceDAO.java | 30 +++---
.../storage/es/dao/SegmentEsPersistenceDAO.java | 12 ++-
.../dao/ServiceNameHeartBeatEsPersistenceDAO.java | 30 ++++--
...stractApplicationComponentEsPersistenceDAO.java | 21 ++--
...stractApplicationAlarmListEsPersistenceDAO.java | 24 ++---
.../alarm/ApplicationAlarmEsPersistenceDAO.java | 22 ++--
.../ApplicationReferenceAlarmEsPersistenceDAO.java | 24 ++---
...licationReferenceAlarmListEsPersistenceDAO.java | 25 ++---
.../dao/alarm/InstanceAlarmEsPersistenceDAO.java | 24 ++---
.../alarm/InstanceAlarmListEsPersistenceDAO.java | 24 ++---
.../InstanceReferenceAlarmEsPersistenceDAO.java | 28 ++---
...InstanceReferenceAlarmListEsPersistenceDAO.java | 28 ++---
.../es/dao/alarm/ServiceAlarmEsPersistenceDAO.java | 26 ++---
.../alarm/ServiceAlarmListEsPersistenceDAO.java | 26 ++---
.../ServiceReferenceAlarmEsPersistenceDAO.java | 32 +++---
.../ServiceReferenceAlarmListEsPersistenceDAO.java | 32 +++---
.../AbstractApplicationMetricEsPersistenceDAO.java | 25 ++---
...AbstractApplicationMappingEsPersistenceDAO.java | 21 ++--
...ApplicationReferenceMetricEsPersistenceDAO.java | 26 ++---
.../dao/cpu/AbstractCpuMetricEsPersistenceDAO.java | 23 ++--
.../dao/gc/AbstractGCMetricEsPersistenceDAO.java | 25 ++---
.../AbstractInstanceMetricEsPersistenceDAO.java | 17 +--
.../AbstractInstanceMappingEsPersistenceDAO.java | 23 ++--
...actInstanceReferenceMetricEsPersistenceDAO.java | 23 ++--
.../AbstractMemoryMetricEsPersistenceDAO.java | 31 +++---
.../AbstractMemoryPoolMetricEsPersistenceDAO.java | 32 +++---
...ctResponseTimeDistributionEsPersistenceDAO.java | 26 ++---
.../smp/AbstractServiceMetricEsPersistenceDAO.java | 19 ++--
...ractServiceReferenceMetricEsPersistenceDAO.java | 27 ++---
.../es/dao/ui/ApplicationComponentEsUIDAO.java | 2 +-
.../es/dao/ui/ApplicationMappingEsUIDAO.java | 2 +-
.../es/dao/ui/ApplicationMetricEsUIDAO.java | 2 +-
.../dao/ui/ApplicationReferenceMetricEsUIDAO.java | 2 +-
.../storage/es/dao/ui/InstanceEsUIDAO.java | 6 +-
.../collector/storage/h2/base/dao/BatchH2DAO.java | 12 ++-
.../collector/ui/jetty/handler/GraphQLHandler.java | 53 +++------
.../ui/service/ApplicationTopologyService.java | 2 +-
.../ui/service/ClusterTopologyService.java | 2 +-
.../apm/collector/ui/service/TopologyBuilder.java | 50 +++++----
.../collector/ui/service/TopologyBuilderTest.java | 3 +-
131 files changed, 1063 insertions(+), 795 deletions(-)
delete mode 100644 apm-collector/apm-collector-storage/collector-storage-es-provider/src/main/java/org/apache/skywalking/apm/collector/storage/es/base/dao/BatchEsDAO.java
create mode 100644 apm-collector/apm-collector-storage/collector-storage-es-provider/src/main/java/org/apache/skywalking/apm/collector/storage/es/base/dao/BatchProcessEsDAO.java
[incubator-skywalking] 01/01: Merge branch 'master' into ui/license
Posted by wu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a commit to branch ui/license
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git
commit e88750d7edb9fc780776052f5bb63fe1b84b9a78
Merge: 3cd6fa5 b35eaac
Author: 吴晟 Wu Sheng <wu...@foxmail.com>
AuthorDate: Mon Jun 25 22:32:25 2018 +0800
Merge branch 'master' into ui/license
.../handler/ApplicationRegisterServiceHandler.java | 4 +-
.../provider/handler/JVMMetricsServiceHandler.java | 21 ++--
.../NetworkAddressRegisterServiceHandler.java | 5 +-
.../handler/TraceSegmentServiceHandler.java | 5 +-
.../NetworkAddressRegisterServletHandler.java | 19 ++--
.../handler/TraceSegmentServletHandler.java | 20 ++--
.../jvm/provider/service/GCMetricService.java | 6 +-
.../provider/service/InstanceHeartBeatService.java | 4 +-
.../ApplicationComponentSpanListener.java | 2 +-
.../mapping/ApplicationMappingSpanListener.java | 15 ++-
.../worker/global/GlobalTraceSpanListener.java | 10 +-
.../mapping/InstanceMappingSpanListener.java | 15 ++-
.../segment/SegmentDurationSpanListener.java | 6 +-
.../heartbeat/ServiceNameAggregationWorker.java | 2 +-
.../ServiceNameHeartBeatPersistenceWorker.java | 2 +-
.../service/heartbeat/ServiceNameSpanListener.java | 2 +-
.../ServiceReferenceMetricSpanListener.java | 10 +-
.../register/ApplicationRegisterRemoteWorker.java | 17 ++-
.../register/ApplicationRegisterSerialWorker.java | 16 ++-
.../register/InstanceRegisterRemoteWorker.java | 16 ++-
.../register/InstanceRegisterSerialWorker.java | 16 ++-
.../NetworkAddressRegisterRemoteWorker.java | 17 ++-
.../NetworkAddressRegisterSerialWorker.java | 14 +--
.../register/ServiceNameRegisterSerialWorker.java | 5 +-
.../provider/service/InstanceIDService.java | 10 +-
.../provider/buffer/SegmentBufferManager.java | 5 +-
.../provider/buffer/SegmentBufferReader.java | 11 +-
.../parser/provider/parser/SegmentParse.java | 20 ++--
.../provider/parser/SegmentPersistenceWorker.java | 2 +-
.../parser/standardization/SpanIdExchanger.java | 12 ++-
.../provider/service/SegmentBase64Printer.java | 2 +-
.../base/AbstractLocalAsyncWorkerProvider.java | 2 +-
.../analysis/worker/model/base/AbstractWorker.java | 2 +-
.../worker/model/base/LocalAsyncWorkerRef.java | 8 +-
.../worker/model/base/RemoteWorkerRef.java | 2 +-
.../worker/model/impl/AggregationWorker.java | 21 ++--
.../worker/model/impl/MergePersistenceWorker.java | 14 ++-
.../model/impl/NonMergePersistenceWorker.java | 4 +-
.../worker/model/impl/PersistenceWorker.java | 2 +-
.../analysis/worker/timer/PersistenceTimer.java | 25 +++--
.../src/main/resources/application.yml | 8 +-
.../guava/service/ServiceIdCacheGuavaService.java | 2 +-
.../service/ServiceNameCacheGuavaService.java | 13 ++-
.../client/elasticsearch/ElasticSearchClient.java | 22 ++--
.../apm/collector/core/cache/Window.java | 2 +-
.../apm/collector/core/data/StreamData.java | 16 ++-
.../core/data/operator/NonMergeOperation.java | 1 +
.../apm/collector/instrument/MetricTree.java | 12 +--
.../collector/instrument/ServiceMetricTracing.java | 10 +-
.../instrument/tools/ReportFormatter.java | 27 ++---
.../service/selector/ForeverFirstSelector.java | 4 +-
.../storage/base/dao/IPersistenceDAO.java | 5 +-
.../storage/table/alarm/ApplicationAlarm.java | 5 +-
.../storage/table/alarm/ApplicationAlarmList.java | 5 +-
.../table/alarm/ApplicationReferenceAlarm.java | 5 +-
.../table/alarm/ApplicationReferenceAlarmList.java | 5 +-
.../storage/table/alarm/InstanceAlarm.java | 5 +-
.../storage/table/alarm/InstanceAlarmList.java | 5 +-
.../table/alarm/InstanceReferenceAlarm.java | 5 +-
.../table/alarm/InstanceReferenceAlarmList.java | 5 +-
.../storage/table/alarm/ServiceAlarm.java | 5 +-
.../storage/table/alarm/ServiceAlarmList.java | 5 +-
.../storage/table/alarm/ServiceReferenceAlarm.java | 5 +-
.../table/alarm/ServiceReferenceAlarmList.java | 5 +-
.../table/application/ApplicationComponent.java | 5 +-
.../table/application/ApplicationMapping.java | 5 +-
.../table/application/ApplicationMetric.java | 5 +-
.../application/ApplicationReferenceMetric.java | 5 +-
.../storage/table/global/GlobalTrace.java | 8 +-
.../table/global/ResponseTimeDistribution.java | 5 +-
.../storage/table/instance/InstanceMapping.java | 5 +-
.../storage/table/instance/InstanceMetric.java | 5 +-
.../table/instance/InstanceReferenceMetric.java | 5 +-
.../apm/collector/storage/table/jvm/GCMetric.java | 5 +-
.../collector/storage/table/jvm/MemoryMetric.java | 5 +-
.../storage/table/jvm/MemoryPoolMetric.java | 5 +-
.../storage/table/register/Application.java | 8 +-
.../collector/storage/table/register/Instance.java | 5 +-
.../storage/table/register/NetworkAddress.java | 9 +-
.../storage/table/register/ServiceName.java | 5 +-
.../collector/storage/table/segment/Segment.java | 8 +-
.../storage/table/service/ServiceMetric.java | 5 +-
.../table/service/ServiceReferenceMetric.java | 6 +-
.../collector/storage/es/MetricTransformUtil.java | 41 +++----
.../storage/es/StorageModuleEsConfig.java | 36 +++++++
.../storage/es/StorageModuleEsProvider.java | 4 +-
.../es/base/dao/AbstractPersistenceEsDAO.java | 12 ++-
.../collector/storage/es/base/dao/BatchEsDAO.java | 72 -------------
.../storage/es/base/dao/BatchProcessEsDAO.java | 120 +++++++++++++++++++++
.../es/dao/GlobalTraceEsPersistenceDAO.java | 17 +--
.../es/dao/InstanceHeartBeatEsPersistenceDAO.java | 12 ++-
.../es/dao/SegmentDurationEsPersistenceDAO.java | 30 +++---
.../storage/es/dao/SegmentEsPersistenceDAO.java | 12 ++-
.../dao/ServiceNameHeartBeatEsPersistenceDAO.java | 30 ++++--
...stractApplicationComponentEsPersistenceDAO.java | 21 ++--
...stractApplicationAlarmListEsPersistenceDAO.java | 24 ++---
.../alarm/ApplicationAlarmEsPersistenceDAO.java | 22 ++--
.../ApplicationReferenceAlarmEsPersistenceDAO.java | 24 ++---
...licationReferenceAlarmListEsPersistenceDAO.java | 25 ++---
.../dao/alarm/InstanceAlarmEsPersistenceDAO.java | 24 ++---
.../alarm/InstanceAlarmListEsPersistenceDAO.java | 24 ++---
.../InstanceReferenceAlarmEsPersistenceDAO.java | 28 ++---
...InstanceReferenceAlarmListEsPersistenceDAO.java | 28 ++---
.../es/dao/alarm/ServiceAlarmEsPersistenceDAO.java | 26 ++---
.../alarm/ServiceAlarmListEsPersistenceDAO.java | 26 ++---
.../ServiceReferenceAlarmEsPersistenceDAO.java | 32 +++---
.../ServiceReferenceAlarmListEsPersistenceDAO.java | 32 +++---
.../AbstractApplicationMetricEsPersistenceDAO.java | 25 ++---
...AbstractApplicationMappingEsPersistenceDAO.java | 21 ++--
...ApplicationReferenceMetricEsPersistenceDAO.java | 26 ++---
.../dao/cpu/AbstractCpuMetricEsPersistenceDAO.java | 23 ++--
.../dao/gc/AbstractGCMetricEsPersistenceDAO.java | 25 ++---
.../AbstractInstanceMetricEsPersistenceDAO.java | 17 +--
.../AbstractInstanceMappingEsPersistenceDAO.java | 23 ++--
...actInstanceReferenceMetricEsPersistenceDAO.java | 23 ++--
.../AbstractMemoryMetricEsPersistenceDAO.java | 31 +++---
.../AbstractMemoryPoolMetricEsPersistenceDAO.java | 32 +++---
...ctResponseTimeDistributionEsPersistenceDAO.java | 26 ++---
.../smp/AbstractServiceMetricEsPersistenceDAO.java | 19 ++--
...ractServiceReferenceMetricEsPersistenceDAO.java | 27 ++---
.../es/dao/ui/ApplicationComponentEsUIDAO.java | 2 +-
.../es/dao/ui/ApplicationMappingEsUIDAO.java | 2 +-
.../es/dao/ui/ApplicationMetricEsUIDAO.java | 2 +-
.../dao/ui/ApplicationReferenceMetricEsUIDAO.java | 2 +-
.../storage/es/dao/ui/InstanceEsUIDAO.java | 6 +-
.../collector/storage/h2/base/dao/BatchH2DAO.java | 12 ++-
.../collector/ui/jetty/handler/GraphQLHandler.java | 53 +++------
.../ui/service/ApplicationTopologyService.java | 2 +-
.../ui/service/ClusterTopologyService.java | 2 +-
.../apm/collector/ui/service/TopologyBuilder.java | 50 +++++----
.../collector/ui/service/TopologyBuilderTest.java | 3 +-
131 files changed, 1063 insertions(+), 795 deletions(-)