Apache Flink -Streaming(DataStream API)
综述： 在Flink中DataStream程序是在数据流上实现了转换的常规程序。 1.示范程序 2.数据源 程序从源读取输入。可以通过StreamExecutionEnvironment.addSource(sourceFunction)给程序 ...
原文：Apache Flink - 基本API概念
Flink程序是实现分布式集合转换的常规程序。集合最初是从源创建的。通过接收器 slink 返回结果，接收器可以将数据写到某个文件或stdout。Flink可以在各种环境 context 中运行，本地JVM或集群。 .数据集和数据流 Flink用特殊的类DataSetandDataStream来表示程序中的数据。可以认为他们是可以包含重复数据的不可变数据集合。在DataSet中数据是有限的，而在 ...
2018-08-05 17:14 4 1927 推荐指数：
相关推荐
Flink学习笔记：Flink API 通用基本概念
本文为《Flink大数据项目实战》学习笔记，想通过视频系统学习Flink这个最火爆的大数据计算框架的同学，推荐学习课程： Flink大数据项目实战：http://t.cn/EJtKhaz 1. 继续侃Flink编程基本套路 1.1 DataSet and DataStream ...
【翻译】Flink Table Api & SQL —— 概念与通用API
本文翻译自官网：https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/common.html Flink Table Api & SQL 翻译目录 Table API和SQL集成在共同API中 ...
【翻译】Flink Table Api & SQL —Streaming 概念 ——时间属性
本文翻译自官网： Time Attributes https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/streaming/time_attributes.html Flink Table Api & ...
【翻译】Flink Table Api & SQL —Streaming 概念 ——动态表
本文翻译自官网：Flink Table Api & SQL 动态表 https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/streaming/dynamic_tables.html Flink ...
【翻译】Flink Table Api & SQL —Streaming 概念 —— 时态表
本文翻译自官网： Temporal Tables https://ci.apache.org/projects/flink/flink-docs-release-1.9/dev/table/streaming/temporal_tables.html Flink Table Api & ...
Apache Flink
Flink 剖析 1.概述 在如今数据爆炸的时代，企业的数据量与日俱增，大数据产品层出不穷。今天给大家分享一款产品—— Apache Flink，目前，已是 Apache 顶级项目之一。那么，接下来，笔者为大家介绍Flink 的相关内容。 2.内容 2.1 What's ...
Flink基础（十八）：Table API 和 Flink SQL（三）流处理中的特殊概念
Table API和SQL，本质上还是基于关系型表的操作方式；而关系型表、关系代数，以及SQL本身，一般是有界的，更适合批处理的场景。这就导致在进行流处理的过程中，理解会稍微复杂一些，需要引入一些特殊概念。 1 流处理和关系代数（表，及SQL）的区别 ...