没有合适的资源?快使用搜索试试~ 我知道了~
metrics-service:用于汇总流数据的Metrix服务
共42个文件
class:11个
java:11个
xml:6个
需积分: 9 0 下载量 81 浏览量
2021-02-17
23:28:54
上传
评论
收藏 56KB ZIP 举报
温馨提示
指标服务 Metrix服务,用于汇总流数据 关于 该应用程序从端点聚合数据,按时间(sec)计算条目,并按所有其他属性进行分组。 结果是计算结果的json数据流。 实施细节 使用Java 8标准库实现项目。 这个想法是将输入数据缓冲几秒钟,以防其他数据延迟出现,或者输入数据流未正确排序。 一旦填充了初始缓冲区,就会从对条目进行缓冲和分组/计数的数据结构中产生结果流。 当前,一个线程填充了缓冲区,另一个线程从缓冲区中读取数据,并立即从结构中删除了读取的聚合数据。 该结构是使用TreeMap实现的,TreeMap可确保输出的数据流按时间递增排序。 关于可伸缩性,当前的实现可能需要进行一些修改以应对这一挑战。 这个想法是,存储的数据的缓冲区相对较大并且在时间上是一致的,目前还不是这种情况-当计算的数据流选择结果时,数据将被覆盖。 但是,如果缓冲区结构足够大且可以使用更长的时间,则一个线程可以
资源推荐
资源详情
资源评论
收起资源包目录
metrics-service-main.zip (42个子文件)
metrics-service-main
pom.xml 2KB
agregate.iml 81B
target
test-classes
input1.txt 1KB
input2.txt 5KB
input.txt 712B
spsapp
SpsAggregatorTest.class 3KB
maven-status
maven-compiler-plugin
compile
default-compile
inputFiles.lst 830B
createdFiles.lst 300B
testCompile
default-testCompile
inputFiles.lst 84B
createdFiles.lst 31B
agregate-1.0-SNAPSHOT.jar 16KB
classes
spsaggregate
SpsJaksonMapper.class 1KB
SpsAggregator.class 5KB
ByTimeAggregator.class 3KB
SpsAggregate.class 2KB
Timeable.class 134B
Sps.class 3KB
restout
RestApi.class 3KB
OutputController.class 5KB
spsapp
ConsoleOutputter.class 1KB
SpsAggregatorApp.class 3KB
maven-archiver
pom.properties 64B
surefire-reports
spsapp.SpsAggregatorTest.txt 301B
TEST-spsapp.SpsAggregatorTest.xml 29KB
src
test
resources
input.txt 712B
java
spsapp
SpsAggregatorTest.java 2KB
main
java
spsaggregate
SpsAggregator.java 3KB
Sps.java 2KB
SpsJaksonMapper.java 619B
ByTimeAggregator.java 1KB
Timeable.java 82B
SpsAggregate.java 1KB
restout
OutputController.java 3KB
RestApi.java 1KB
spsapp
SpsAggregatorApp.java 2KB
ConsoleOutputter.java 779B
.idea
uiDesigner.xml 9KB
misc.xml 542B
encodings.xml 191B
compiler.xml 713B
.gitignore 41B
README.md 2KB
共 42 条
- 1
资源评论
RonaldWang
- 粉丝: 22
- 资源: 4586
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功