基于Flink的视频直播案例（上）
目录 数据产生 Logstash部分 Kafka部分 Flink部分 配置/准备代码 视频核心指标监控 本案例参考自阿里云的视频直播解决方案之视频核心指标监控和视频直播解决方案之直播数字化运营。 基于Kafka ...
原文：Flink 案例分析
Flink程序的执行过程 no desc 说明 详情 env 获取flink的执行环境 批处理：ExecutionEnvironment env ExecutionEnvironment.getExecutionEnvironment 流处理：StreamExecutionEnvironment env StreamExecutionEnvironment.getExecutionEnvironm ...
2020-09-23 12:48 0 1173 推荐指数：
相关推荐
Flink 案例整合
1.概述 Flink 1.1.0 版本已经在官方发布了，官方博客于 2016-08-08 更新了 Flink 1.1.0 的变动。在这 Flink 版本的发布，添加了 SQL 语法这一特性。这对于业务场景复杂，依赖于 SQL 来分析统计数据，算得上是一个不错的福利。加上之前有同学和朋友邮件 ...
Flink学习（八） Flink SQL & Table 编程和案例
Flink Table & SQL 概述背景我们在前面的课时中讲过 Flink 的分层模型，Flink 自身提供了不同级别的抽象来支持我们开发流式或者批量处理程序，下图描述了 Flink 支持的 4 种不同级别的抽象。 Table API 和 SQL 处于最顶端，是 Flink ...
flink内存模型详解与案例
任务提交时的一些yarn设置（通用客户端模式） 指定并行度 -p 5 \ 指定yarn队列 -Dyarn.a ...
Flink流处理之迭代案例
当前Flink将迭代的重心集中在批处理上，之前我们谈及了批量迭代和增量迭代主要是针对批处理（DataSet）API而言的，而且Flink为批处理中的迭代提供了针对性的优化。 可是对于流处理（DataStream），Flink相同提供了对迭代的支持。这一节我们主要来分析流处理中的迭代 ...
Flink| 实时需要分析
用户行为分析 统计分析 点击、浏览； 热门商品、近期热门商品、分类热门商品，流量统计； 偏好统计 收藏、喜欢、评分、打标签； 用户画像、推荐列表（结合特征工程和机器学习算法） 风险控制 下订单、支付、登录 刷单监控，订单实效监控 ...
flink checkpoint 源码分析 （一）
转发请注明原创地址http://www.cnblogs.com/dongxiao-yang/p/8029356.html checkpoint是Flink Fault Tolerance机制的重要构成部分，flink checkpoint的核心类名为 ...
Flink特点分析
是Stratosphere系统的核心开发人员，2014年12月，Flink一跃成为Apache软件基金会的顶级项目。 ...