Press "Enter" to skip to content

分类: Flink

Flink的一些实践示例

用例介绍: 从Kafka消费的一些接口日志,先对数据进行了过滤,然后将数据进行了3个维度的分析,分别是: 1.按照接口的维度统计调用量 2.按照应用的维度统计调用量和平均延迟 3.按照自然日来统计调用量

Leave a Comment

Flink消费kafka,对同一个数据源进行多维度的实时分析处理

我的诉求是,我现在kafka上面有个实时是数据流,他是一个接口的请求日志。 我现在想要实时分析出来每个接口的访问频次和延迟,我还想按照系统的维度统计访问频次和延迟。 就是说我想对同一个数据源进行初始过滤,然后对数据流进行分支,然后分别计算我…

Leave a Comment