AI 预测：基于流计算 Oceanus(Flink) 实现病症的实时预测
作者：于乐，腾讯 CSIG 工程师 一、方案描述 1.1 概述 近年来，人工智能的风潮为医疗行业带来一场全新革命，AI 在辅助诊断、疾病预测、疗法选择等方面发挥着重要作用。机器学习领域的特征选 ...
原文：指标统计：基于流计算 Oceanus(Flink) 实现实时 UVPV 统计
作者：吴云涛，腾讯 CSIG 高级工程师导语 最近梳理了一下如何用 Flink 来实现实时的 UV PV 指标的统计，并和公司内微视部门的同事交流。然后针对该场景做了简化，并发现使用 Flink SQL 来 实现这些指标的统计会更加便捷。 一 解决方案描述 . 概述 本方案结合本地自建 Kafka 集群 腾讯云流计算 Oceanus Flink 云数据库 Redis 对博客 购物等网站 UV PV ...
2021-10-24 21:03 0 246 推荐指数：
相关推荐
通过Flink实现个推海量消息数据的实时统计
背景 消息报表主要用于统计消息任务的下发情况。比如，单条推送消息下发APP用户总量有多少，成功推送到手机的数量有多少，又有多少APP用户点击了弹窗通知并打开APP等。通过消息报表，我们可以很直观地看到消息推送的流转情况、消息下发到达成功率、用户对消息的点击情况等。 个推在提供消息推送服务时 ...
Spark2.0基于广播变量broadcast实现实时数据按天统计
package com.gm.hive.SparkHive; import java.text.SimpleDateFormat; import java.util.Arrays; import j ...
基于流计算 Oceanus 和 Elasticsearch Service 构建百亿级实时监控系统
作者：龙逸尘，腾讯 CSIG 高级工程师 为什么要构建监控系统 在后移动互联网时代，良好的用户体验是增长的基础，稳定的使用体验就是用户体验的基础。大型的互联网公司，特别是面向 C 端客 ...
Flink模拟项目： 实时流量统计
3.1 模块创建和数据准备 在UserBehaviorAnalysis下新建一个 maven module作为子项目，命名为NetworkTrafficAnalysis。在这个子模块中，我们同样并没 ...
Flink实战教程：实时热门统计
实战案例介绍 本案例将实现一个“实时热门商品”的需求，我们可以将“实时热门商品”翻译成程序员更好理解的需求：每隔5分钟输出最近一小时内点击量最多的前 N 个商品。 将这个需求进行分解我们大概要做这么几件事情： 抽取出业务时间戳，告诉 Flink 框架基于业务时间 ...
Flink 实时统计历史 pv、uv
Flink 实时统计 pv、uv 的博客，我已经写了三篇，最近这段时间又做了个尝试，用 sql 来计算全量数据的 pv、uv。 Stream Api 写实时、离线的 pv、uv ，除了要写代码没什么其他的障碍 SQL api 来写就有很多障碍，比如窗口没有 trigger，不能操作 状态 ...
Spark Streaming实现实时流处理
一、Streaming与Flume的联调 Spark 2.2.0 对应于 Flume 1.6.0 两种模式： 1. Flume-style push-ba ...