You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2019/02/20 01:06:19 UTC
[incubator-skywalking] branch blocking-queue updated (b2ea12a ->
f272046)
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a change to branch blocking-queue
in repository https://gitbox.apache.org/repos/asf/incubator-skywalking.git.
from b2ea12a Make wait time flexible.
new 92e41d5 Make FlexibleTime factor dynamic
new b9fa6a3 fix gRPCHost (#2194)
new c704ee0 for issue#2196 (#2197)
new 2e0104e Register lock refactor (#2195)
new 4399299 Optimize the agent grpc channel management. (#2198)
new 4e1862d Sync UI (#2201)
new b5b6900 Sync UI (#2205)
new 5914a2b add thread-name. (#2209)
new 3b0a1d3 Update How-to-release.md (#2210)
new a36394d Support lettuce plugin (#2152)
new f7ca267 Database metrics provided. (#2025)
new 5003d6d fixed CPU UsagePercent Error (#2222)
new 79c1f1e Add echplus.com as new user (#2225)
new f88ac3d Set dist bin tar with -bin in the final name. (#2221)
new d60ce3f Update Screenshots.md (#2226)
new d5deb6f Update: update database ui (#2227)
new 7c72618 Update powered-by.md (#2228)
new 4657ce7 Fixed an error that took a non-protocol uri string as a java.net.URL … (#2231)
new 496bde9 Update users and user cases (#2235)
new 4b15c71 Make sure all document images ref from our Apache website. (#2236)
new 4babd6f Support Top sql (#2239)
new 450eb2a Images ref from our Apache website (#2238)
new 73f49ce Improves stability. (#2241)
new a17a780 Docker issues (#2243)
new 4c64290 Support to register different host/port at cluster coordinator (#2244)
new b86426c Add consumer pool to Datacarrier (#2245)
new 0929ff3 Support Zookeeper plugin (#2211)
new 19614a1 Feature: add database tracelist (#2249)
new 2f3ccf3 Backend streaming thread model improvement (#2247)
new 486a98a Add https://www.cxist.com/ to powered-by page (#2251)
new 333bcd4 Provide slow database rule document. (#2253)
new 479ee33 Correct trace id in slow db statement (#2254)
new b4eb06e Improve document (#2259)
new 2a14097 fix issue #2258 (#2260)
new c019535 Fix mesh telemetry performance issue and adjust default thread number (#2261)
new f272046 Merge branch 'master' into blocking-queue
The 4586 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:
.mvn/wrapper/MavenWrapperDownloader.java | 0
.mvn/wrapper/maven-wrapper.properties | 0
.travis.yml | 6 +-
README.md | 18 +--
apm-checkstyle/pom.xml | 36 +-----
.../apm/commons/datacarrier/DataCarrier.java | 64 ++++++----
.../apm/commons/datacarrier/buffer/Buffer.java | 6 +-
.../apm/commons/datacarrier/buffer/Channels.java | 6 +
.../commons/datacarrier/common/FlexibleTime.java | 5 +-
.../datacarrier/consumer/BulkConsumePool.java | 121 ++++++++++++++++++
.../{ConsumerPool.java => ConsumeDriver.java} | 20 +--
.../commons/datacarrier/consumer/ConsumerPool.java | 130 ++-----------------
.../datacarrier/consumer/ConsumerPoolFactory.java | 89 +++++++++++++
.../consumer/{IConsumer.java => IDriver.java} | 19 ++-
.../consumer/MultipleChannelsConsumer.java | 123 ++++++++++++++++++
.../datacarrier/common/FlexibleTimeTest.java | 2 +-
.../datacarrier/consumer/BulkConsumePoolTest.java | 91 ++++++++++++++
...onsumerPoolTest.java => ConsumeDriverTest.java} | 20 +--
.../commons/datacarrier/consumer/ConsumerTest.java | 4 +-
apm-dist/pom.xml | 6 +-
.../network/trace/component/ComponentsDefine.java | 8 +-
.../skywalking/apm/agent/core/conf/Config.java | 2 +-
.../apm/agent/core/jvm/cpu/CPUMetricAccessor.java | 2 +-
.../apm/agent/core/logging/core/EasyLogger.java | 1 +
.../apm/agent/core/remote/GRPCChannelManager.java | 29 +++--
.../agent/core/remote/GRPCChannelManagerTest.java | 79 ++++++++++++
.../v4/HttpClientExecuteInterceptor.java | 46 +++++--
.../v4/HttpClientExecuteInterceptorTest.java | 29 +++++
.../mysql/wrapper/PreparedStatementWrapper.java | 2 +-
.../lettuce-5.x-plugin}/pom.xml | 18 +--
.../lettuce/v5/AsyncCommandMethodInterceptor.java} | 34 +++--
.../v5/ClientOptionsConstructorInterceptor.java} | 9 +-
.../lettuce/v5/RedisChannelWriterInterceptor.java} | 62 +++------
.../v5}/RedisClientConstructorInterceptor.java | 11 +-
.../RedisClusterClientConstructorInterceptor.java} | 23 ++--
.../apm/plugin/lettuce/v5/SWConsumer.java | 56 +++++++++
.../v5/define/AsyncCommandInstrumentation.java} | 14 +--
.../v5/define/ClientOptionsInstrumentation.java} | 12 +-
.../define/RedisChannelWriterInstrumentation.java} | 18 +--
.../v5}/define/RedisClientInstrumentation.java | 14 +--
.../define/RedisClusterClientInstrumentation.java} | 16 +--
.../src/main/resources/skywalking-plugin.def | 7 +-
.../v5/RedisChannelWriterInterceptorTest.java} | 92 +++++++-------
apm-sniffer/optional-plugins/pom.xml | 2 +
.../zookeeper-3.4.x-plugin}/pom.xml | 15 ++-
.../plugin/zookeeper/ClientCnxnInterceptor.java} | 81 +++++-------
.../zookeeper/EventThreadMethodInterceptor.java} | 49 ++++----
.../skywalking/apm/plugin/zookeeper/ZooOpt.java | 140 +++++++++++++++++++++
.../define/ClientCnxnInstrumentation.java} | 19 +--
.../define/EventThreadInstrumentation.java} | 13 +-
.../src/main}/resources/skywalking-plugin.def | 3 +-
.../zookeeper/ClientCnxnInterceptorTest.java} | 96 +++++++-------
docker/Makefile | 6 +-
docker/config/application.yml | 1 +
docker/config/component-libraries.yml | 8 ++
docker/docker-compose.yml | 2 +-
docker/oap/Dockerfile | 4 +-
docker/oap/docker-entrypoint.sh | 4 +-
docker/ui/Dockerfile | 4 +-
docker/ui/docker-entrypoint.sh | 3 +-
docs/Screenshots.md | 30 ++---
docs/en/concepts-and-designs/overview.md | 8 +-
docs/en/guides/Component-library-settings.md | 2 +
docs/en/guides/How-to-release.md | 26 ++--
docs/en/guides/Java-Plugin-Development-Guide.md | 2 -
docs/en/setup/README.md | 12 +-
docs/en/setup/backend/backend-cluster.md | 22 ++++
docs/en/setup/backend/backend-setting-override.md | 18 +--
docs/en/setup/backend/backend-setup.md | 2 +
docs/en/setup/backend/backend-ui-setup.md | 2 +-
docs/en/setup/backend/slow-db-statement.md | 14 +++
docs/en/setup/service-agent/java-agent/README.md | 6 +-
.../service-agent/java-agent/Supported-list.md | 5 +-
docs/others/cn/concepts-and-designs/overview-cn.md | 2 +-
.../others/cn/guides/Component-library-settings.md | 3 +
.../cn/guides/Java-Plugin-Development-Guide.md | 6 +-
docs/powered-by.md | 23 +++-
.../apache/skywalking/oal/tool/grammar/OALLexer.g4 | 1 +
.../skywalking/oal/tool/grammar/OALParser.g4 | 2 +-
.../oal/tool/output/DispatcherContext.java | 1 +
.../skywalking/oal/tool/output/FileGenerator.java | 11 ++
.../oal/tool/parser/SourceColumnsFactory.java | 6 +
.../DatabaseAccessDispatcherTemplate.ftl | 66 ++++++++++
.../src/main/resources/official_analysis.oal | 11 +-
.../plugin/consul/ClusterModuleConsulConfig.java | 2 +
.../plugin/consul/ClusterModuleConsulProvider.java | 2 +-
.../cluster/plugin/consul/ConsulCoordinator.java | 14 ++-
.../zookeeper/ClusterModuleZookeeperConfig.java | 2 +
.../zookeeper/ClusterModuleZookeeperProvider.java | 2 +-
.../plugin/zookeeper/ZookeeperCoordinator.java | 12 +-
.../skywalking/oap/server/core/CoreModule.java | 1 +
.../oap/server/core/CoreModuleConfig.java | 1 +
.../oap/server/core/CoreModuleProvider.java | 5 +-
.../oap/server/core/UnexpectedException.java | 4 +
.../server/core/analysis/DispatcherManager.java | 4 +
...rgeDataCache.java => LimitedSizeDataCache.java} | 27 ++--
.../analysis/data/LimitedSizeDataCollection.java | 115 +++++++++++++++++
.../core/analysis/data/NonMergeDataCollection.java | 4 +-
.../oap/server/core/analysis/data/Window.java | 10 ++
.../database/DatabaseStatementDispatcher.java | 40 ++++++
.../manual/database/TopNDatabaseStatement.java | 82 ++++++++++++
.../oap/server/core/analysis/topn/TopN.java | 46 +++++++
.../topn/annotation/TopNType.java} | 7 +-
.../annotation/TopNTypeListener.java} | 14 +--
.../analysis/worker/IndicatorAggregateWorker.java | 16 ++-
.../analysis/worker/IndicatorPersistentWorker.java | 20 ++-
.../analysis/worker/RecordPersistentWorker.java | 14 ++-
.../{RecordProcess.java => TopNProcess.java} | 34 ++---
.../server/core/analysis/worker/TopNWorker.java | 134 ++++++++++++++++++++
.../server/core/query/MetadataQueryService.java | 4 +
...ryService.java => TopNRecordsQueryService.java} | 33 +++--
.../core/query/entity/{Node.java => Database.java} | 10 +-
.../query/entity/{Service.java => TopNRecord.java} | 11 +-
.../oap/server/core/register/ServiceInventory.java | 5 +
.../register/worker/RegisterDistinctWorker.java | 18 ++-
.../register/worker/RegisterPersistentWorker.java | 25 ++--
.../core/source/{All.java => DatabaseAccess.java} | 25 ++--
...tanceJVMCPU.java => DatabaseSlowStatement.java} | 20 +--
.../skywalking/oap/server/core/source/Scope.java | 2 +-
...StorageData.java => ComparableStorageData.java} | 7 +-
.../oap/server/core/storage/IRegisterLockDAO.java | 18 ++-
.../oap/server/core/storage/PersistenceTimer.java | 1 +
.../oap/server/core/storage/StorageModule.java | 3 +-
.../core/storage/query/IMetadataQueryDAO.java | 2 +
...larmQueryDAO.java => ITopNRecordsQueryDAO.java} | 14 +--
.../data/LimitedSizeDataCollectionTest.java | 72 +++++++++++
.../src/test/resources/component-libraries.yml | 8 ++
.../server/library/server/jetty/JettyServer.java | 6 +
.../oap/query/graphql/GraphQLQueryProvider.java | 2 +
.../oap/query/graphql/resolver/MetadataQuery.java | 4 +
.../{AlarmQuery.java => TopNRecordsQuery.java} | 37 +++---
...ricCondition.java => TopNRecordsCondition.java} | 10 +-
.../src/main/resources/query-protocol | 2 +-
.../receiver/mesh/TelemetryDataDispatcher.java | 37 +++---
.../handler/v6/grpc/RegisterServiceHandler.java | 1 +
...erServiceImpl.java => DBLatencyThresholds.java} | 33 +++--
.../trace/provider/TraceModuleProvider.java | 21 ++--
.../trace/provider/TraceServiceModuleConfig.java | 9 +-
.../trace/provider/parser/SegmentParse.java | 17 ++-
.../trace/provider/parser/SegmentParseV2.java | 15 ++-
.../parser/{SegmentSource.java => SpanTags.java} | 9 +-
.../parser/listener/SpanListenerFactory.java | 3 +-
.../listener/endpoint/MultiScopesSpanListener.java | 97 ++++++++++----
.../parser/listener/endpoint/SourceBuilder.java | 14 +++
.../listener/segment/SegmentSpanListener.java | 3 +-
.../service/ServiceMappingSpanListener.java | 3 +-
.../SegmentStandardizationWorker.java | 4 +-
.../server/receiver/trace/mock/ServiceBMock.java | 4 +-
.../src/main/assembly/application.yml | 1 +
.../src/main/resources/application.yml | 1 +
.../src/main/resources/component-libraries.yml | 8 ++
.../StorageModuleElasticsearchProvider.java | 3 +-
.../elasticsearch/lock/RegisterLockDAOImpl.java | 36 +-----
.../elasticsearch/lock/RegisterLockIndex.java | 2 -
.../elasticsearch/lock/RegisterLockInstaller.java | 8 --
.../elasticsearch/query/MetadataQueryEsDAO.java | 34 +++++
.../elasticsearch/query/TopNRecordsQueryEsDAO.java | 66 ++++++++++
.../storage/plugin/jdbc/h2/H2StorageProvider.java | 1 +
.../plugin/jdbc/h2/dao/H2MetadataQueryDAO.java | 70 ++++++++---
.../plugin/jdbc/h2/dao/H2RegisterLockDAO.java | 53 +++-----
.../jdbc/h2/dao/H2RegisterLockInstaller.java | 1 -
.../plugin/jdbc/h2/dao/H2TopNRecordsQueryDAO.java | 78 ++++++++++++
.../plugin/jdbc/mysql/MySQLStorageProvider.java | 1 +
pom.xml | 9 +-
skywalking-ui | 2 +-
165 files changed, 2675 insertions(+), 1001 deletions(-)
mode change 100755 => 100644 .mvn/wrapper/MavenWrapperDownloader.java
mode change 100755 => 100644 .mvn/wrapper/maven-wrapper.properties
create mode 100644 apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/consumer/BulkConsumePool.java
copy apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/consumer/{ConsumerPool.java => ConsumeDriver.java} (89%)
create mode 100644 apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/consumer/ConsumerPoolFactory.java
copy apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/consumer/{IConsumer.java => IDriver.java} (77%)
create mode 100644 apm-commons/apm-datacarrier/src/main/java/org/apache/skywalking/apm/commons/datacarrier/consumer/MultipleChannelsConsumer.java
create mode 100644 apm-commons/apm-datacarrier/src/test/java/org/apache/skywalking/apm/commons/datacarrier/consumer/BulkConsumePoolTest.java
rename apm-commons/apm-datacarrier/src/test/java/org/apache/skywalking/apm/commons/datacarrier/consumer/{ConsumerPoolTest.java => ConsumeDriverTest.java} (77%)
create mode 100644 apm-sniffer/apm-agent-core/src/test/java/org/apache/skywalking/apm/agent/core/remote/GRPCChannelManagerTest.java
copy apm-sniffer/{apm-sdk-plugin/jedis-2.x-plugin => optional-plugins/lettuce-5.x-plugin}/pom.xml (77%)
copy apm-sniffer/optional-plugins/{gson-2.8.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/gson/GsonFromJsonInterceptor.java => lettuce-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/lettuce/v5/AsyncCommandMethodInterceptor.java} (69%)
copy apm-sniffer/{apm-sdk-plugin/redisson-3.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/redisson/v3/RedisClientConstructorInterceptor.java => optional-plugins/lettuce-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/lettuce/v5/ClientOptionsConstructorInterceptor.java} (76%)
copy apm-sniffer/{apm-sdk-plugin/redisson-3.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/redisson/v3/RedisConnectionMethodInterceptor.java => optional-plugins/lettuce-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/lettuce/v5/RedisChannelWriterInterceptor.java} (57%)
copy apm-sniffer/{apm-sdk-plugin/redisson-3.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/redisson/v3 => optional-plugins/lettuce-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/lettuce/v5}/RedisClientConstructorInterceptor.java (74%)
copy apm-sniffer/{apm-sdk-plugin/jedis-2.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/jedis/v2/JedisConstructorWithStringArgInterceptor.java => optional-plugins/lettuce-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/lettuce/v5/RedisClusterClientConstructorInterceptor.java} (59%)
create mode 100644 apm-sniffer/optional-plugins/lettuce-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/lettuce/v5/SWConsumer.java
copy apm-sniffer/{apm-sdk-plugin/redisson-3.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/redisson/v3/define/ConnectionManagerInstrumentation.java => optional-plugins/lettuce-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/lettuce/v5/define/AsyncCommandInstrumentation.java} (80%)
copy apm-sniffer/{apm-sdk-plugin/redisson-3.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/redisson/v3/define/RedisClientInstrumentation.java => optional-plugins/lettuce-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/lettuce/v5/define/ClientOptionsInstrumentation.java} (80%)
copy apm-sniffer/{apm-sdk-plugin/redisson-3.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/redisson/v3/define/RedisConnectionInstrumentation.java => optional-plugins/lettuce-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/lettuce/v5/define/RedisChannelWriterInstrumentation.java} (77%)
copy apm-sniffer/{apm-sdk-plugin/redisson-3.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/redisson/v3 => optional-plugins/lettuce-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/lettuce/v5}/define/RedisClientInstrumentation.java (80%)
copy apm-sniffer/{apm-sdk-plugin/redisson-3.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/redisson/v3/define/RedisClientInstrumentation.java => optional-plugins/lettuce-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/lettuce/v5/define/RedisClusterClientInstrumentation.java} (73%)
copy apm-sniffer/{apm-sdk-plugin/canal-1.x-plugin => optional-plugins/lettuce-5.x-plugin}/src/main/resources/skywalking-plugin.def (62%)
copy apm-sniffer/{apm-toolkit-activation/apm-toolkit-trace-activation/src/test/java/org/apache/skywalking/apm/toolkit/activation/trace/CallableOrRunnableInterceptorTest.java => optional-plugins/lettuce-5.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/lettuce/v5/RedisChannelWriterInterceptorTest.java} (50%)
copy apm-sniffer/{apm-sdk-plugin/redisson-3.x-plugin => optional-plugins/zookeeper-3.4.x-plugin}/pom.xml (79%)
copy apm-sniffer/{apm-sdk-plugin/redisson-3.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/redisson/v3/RedisConnectionMethodInterceptor.java => optional-plugins/zookeeper-3.4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/zookeeper/ClientCnxnInterceptor.java} (53%)
copy apm-sniffer/{apm-sdk-plugin/elasticsearch-5.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/elasticsearch/v5/PlainListenableActionFutureInterceptor.java => optional-plugins/zookeeper-3.4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/zookeeper/EventThreadMethodInterceptor.java} (57%)
create mode 100644 apm-sniffer/optional-plugins/zookeeper-3.4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/zookeeper/ZooOpt.java
copy apm-sniffer/{apm-sdk-plugin/redisson-3.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/redisson/v3/define/RedisConnectionInstrumentation.java => optional-plugins/zookeeper-3.4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/zookeeper/define/ClientCnxnInstrumentation.java} (76%)
copy apm-sniffer/{apm-sdk-plugin/redisson-3.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/redisson/v3/define/ConnectionManagerInstrumentation.java => optional-plugins/zookeeper-3.4.x-plugin/src/main/java/org/apache/skywalking/apm/plugin/zookeeper/define/EventThreadInstrumentation.java} (77%)
copy apm-sniffer/{apm-agent-core/src/test => optional-plugins/zookeeper-3.4.x-plugin/src/main}/resources/skywalking-plugin.def (81%)
copy apm-sniffer/{apm-toolkit-activation/apm-toolkit-trace-activation/src/test/java/org/apache/skywalking/apm/toolkit/activation/trace/CallableOrRunnableInterceptorTest.java => optional-plugins/zookeeper-3.4.x-plugin/src/test/java/org/apache/skywalking/apm/plugin/zookeeper/ClientCnxnInterceptorTest.java} (50%)
create mode 100644 docs/en/setup/backend/slow-db-statement.md
create mode 100644 oap-server/generate-tool/src/main/resources/code-templates/DatabaseAccessDispatcherTemplate.ftl
copy oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/data/{NonMergeDataCache.java => LimitedSizeDataCache.java} (62%)
create mode 100644 oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/data/LimitedSizeDataCollection.java
create mode 100644 oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/database/DatabaseStatementDispatcher.java
create mode 100644 oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/manual/database/TopNDatabaseStatement.java
create mode 100644 oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/topn/TopN.java
copy oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/{remote/annotation/StreamData.java => analysis/topn/annotation/TopNType.java} (87%)
copy oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/{record/annotation/RecordTypeListener.java => topn/annotation/TopNTypeListener.java} (75%)
copy oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/{RecordProcess.java => TopNProcess.java} (69%)
create mode 100644 oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/analysis/worker/TopNWorker.java
copy oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/query/{AlarmQueryService.java => TopNRecordsQueryService.java} (54%)
copy oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/query/entity/{Node.java => Database.java} (90%)
copy oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/query/entity/{Service.java => TopNRecord.java} (87%)
copy oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/source/{All.java => DatabaseAccess.java} (70%)
copy oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/source/{ServiceInstanceJVMCPU.java => DatabaseSlowStatement.java} (71%)
copy oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/storage/{StorageData.java => ComparableStorageData.java} (86%)
copy oap-server/server-core/src/main/java/org/apache/skywalking/oap/server/core/storage/query/{IAlarmQueryDAO.java => ITopNRecordsQueryDAO.java} (72%)
create mode 100644 oap-server/server-core/src/test/java/org/apache/skywalking/oap/server/core/analysis/data/LimitedSizeDataCollectionTest.java
copy oap-server/server-query-plugin/query-graphql-plugin/src/main/java/org/apache/skywalking/oap/query/graphql/resolver/{AlarmQuery.java => TopNRecordsQuery.java} (50%)
copy oap-server/server-query-plugin/query-graphql-plugin/src/main/java/org/apache/skywalking/oap/query/graphql/type/{MetricCondition.java => TopNRecordsCondition.java} (79%)
copy oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/{parser/SegmentParserServiceImpl.java => DBLatencyThresholds.java} (52%)
copy oap-server/server-receiver-plugin/skywalking-trace-receiver-plugin/src/main/java/org/apache/skywalking/oap/server/receiver/trace/provider/parser/{SegmentSource.java => SpanTags.java} (86%)
create mode 100644 oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/query/TopNRecordsQueryEsDAO.java
create mode 100644 oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TopNRecordsQueryDAO.java