分享

strom trident 统计问题

kanwei163 发表于 2017-11-26 11:52:02 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 1 6947
TridentTopology tridentTopology = new TridentTopology();
                Stream stream = tridentTopology.newStream("event", kafkaSpout).parallelismHint(5);

                Stream logStream = stream.each(new Fields("bytes"), new LogExtractorFunction(), new Fields("eventlog"))
                                .filter(new LogFilelter("startGame"))
                                .each(new Fields("eventlog"), new LogGroupFunction(), new Fields("eventTimeStr"));

                Options<OpaqueValue> opts = new Options<OpaqueValue>();
                opts.dataTypeDescription = new RedisDataTypeDescription(RedisDataTypeDescription.RedisDataType.STRING);

                logStream.groupBy(new Fields("eventTimeStr"))
                                .persistentAggregate(RedisMapState.opaque(poolConfig, opts), new Count(), new Fields("count"))
                                .parallelismHint(5);

                return tridentTopology.build();


为什么统计的结果不对呢。就是一个简单的事件名称拼上时间,统计发生多少次。每次count结果都不对

已有(1)人评论

跳转到指定楼层
xuanxufeng 发表于 2017-11-26 13:05:31
本帖最后由 xuanxufeng 于 2017-11-26 13:06 编辑

程序错误好判断,结果出错,跟你的业务和实现有关系。你需要把你认为的错误说下,错在什么地方。这样别人才能帮助你
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条