大数据开发-Flink-数据流DataStream和DataSet
Flink主要用来处理数据流，所以从抽象上来看就是对数据流的处理，正如前面大数据开发-Flink-体系结构 && 运行架构提到写Flink程序实际上就是在写DataSource、Transformation、Sink. DataSource是程序的数据源输入 ...
原文：大数据开发-Flink-窗口全解析
Flink窗口背景 Flink认为Batch是Streaming的一个特例，因此Flink底层引擎是一个流式引擎，在上面实现了流处理和批处理。而Window就是从Streaming到Batch的桥梁。通俗讲，Window是用来对一个无限的流设置一个有限的集合，从而在有界的数据集上进行操作的一种机制。流上的集合由Window来划定范围，比如 计算过去 分钟 或者 最后 个元素的和 。Window可以 ...
2021-05-31 00:35 0 407 推荐指数：
相关推荐
大数据基础---Flink开发环境搭建
一、安装 Scala 插件 Flink 分别提供了基于 Java 语言和 Scala 语言的 API ，如果想要使用 Scala 语言来开发 Flink 程序，可以通过在 IDEA 中安装 Scala 插件来提供语法提示，代码高亮等功能。打开 IDEA , 依次点击 File => ...
大数据开发-Flink-1.13新特性
介绍 大概4月，Flink1.13就发布了，参加 了Flink1.13 的Meetup，收获还是挺多，从大的方面讲就是FlingSql的改进和优化，资源调度管理方面的优化，以及流批一体Flink在运行时与DataStream API的优化，另外就是State backend 模块的优化，本篇 ...
大数据学习日志——解析sparkstreaming滑动窗口源码
基本没看到。于是便想着自己动手丰衣足食，从源码粗略看起来，这个滑动窗口到底怎么用！spark2.4版本 本 ...
为什么说Python 是大数据全栈式开发语言
欢迎大家访问我的个人网站《刘江的博客和教程》：www.liujiangblog.com 主要分享Python 及Django教程以及相关的博客 原文链接 http://www.envicloud. ...
大数据基础---Flink学习总括
第一节 初识 Flink 在数据激增的时代，催生出了一批计算框架。最早期比较流行的有MapReduce，然后有Spark，直到现在越来越多的公司采用Flink处理。Flink相对前两个框架真正做到了高吞吐，低延迟，高性能。 1. Flink 是什么？ 1) Flink 的发展历史 ...
大数据IDEA调试flink程序
Flink在IDEA中开发是一件比较困难的事情，网上没有参考资料，就算就业说的太过笼统，不知道是会了不说还是不会瞎说，为了解决flink这个问题，本人特别做了一遍开发的简单说明。主要考虑两个问题，1、语言环境的搭建。2、flink代码编译通过并运行 获取更多大数据视频资料请加QQ群 ...
大数据课程之Flink
大数据课程之Flink 第一章 Flink简介 1、初识Flink Apache Flink是一个框架和分布式处理引擎，用于对无界和有界数据流进行有状态计算。Flink被设计在所有常见的集群环境中运行，以内存执行速度和任意规模来执行计算。 Flink起源于 ...