Flink的流式处理和批处理主要有以下不同: 数据源不同。流式处理读取实时持续产生的数据流,批处理读取静态已完… 继续阅读 Flink的流式处理和批处理有什么不同?
分类: Flink
Flink的数据处理流程是怎样的?
Flink的数据处理流程主要分为以下几个步骤: Source – 读取数据源。这可以是文件、Kaf… 继续阅读 Flink的数据处理流程是怎样的?
Flink的处理语义是什么?
Flink 提供两种主要的处理语义: At-least-once:至少一次,保证每个记录至少被处理一次,可能会… 继续阅读 Flink的处理语义是什么?
Flink中的状态(State)是什么,有哪些类型?
Flink 中的状态(State)用于在计算过程中存储和查询数据。状态允许流式程序隐含地保存数据,并在之后的操… 继续阅读 Flink中的状态(State)是什么,有哪些类型?
Flink中的窗口是什么,有哪些类型?
Flink 中的窗口用于切割无界的数据流成有界的块,以便进行计算。窗口主要有以下几种类型: 滑动窗口(Slid… 继续阅读 Flink中的窗口是什么,有哪些类型?
Flink中如何实现数据源和数据接收器?
Flink 中的数据源用于从外部系统读取数据进入 Flink,数据接收器用于将 Flink 的计算结果输出到外… 继续阅读 Flink中如何实现数据源和数据接收器?
Flink的任务调度器是什么?
Flink 有两种主要的任务调度器: 单线程调度器(single threaded scheduler):在同… 继续阅读 Flink的任务调度器是什么?
Flink中的数据流(DataStream)和数据集(DataSet)有什么区别?
Flink 中的数据流(DataStream)和数据集(DataSet)的主要区别在于: 数据类型: Data… 继续阅读 Flink中的数据流(DataStream)和数据集(DataSet)有什么区别?
Flink的核心概念是什么?
Flink 的核心概念主要包括: 流(Stream):由数据集合组成的数据序列,支持根据时间或位置排序。 En… 继续阅读 Flink的核心概念是什么?
Flink中如何进行数据流的加密和解密?
在Flink中进行数据流加密和解密,通常可以通过使用加密算法库或加密框架来实现。例如,在DataStream … 继续阅读 Flink中如何进行数据流的加密和解密?
Flink与Hadoop和Spark有何不同?
Flink 与 Hadoop 和 Spark 的主要不同点在于: 数据处理方式: Flink 流式计算,基于数… 继续阅读 Flink与Hadoop和Spark有何不同?
什么是Apache Flink?
Apache Flink 是一个开源的分布式大数据计算框架。主要用于高吞吐量、低延迟的数据处理应用,如: 流式… 继续阅读 什么是Apache Flink?
Flink从入门到实战九[Table API&SQL]-8-基于FileSystem 创建 TABLE 通过 connector SQL DDL
Connector 描述了存储表数据的外部系统。存储系统例如 Apache Kafka 或者常规的文件系统都可… 继续阅读 Flink从入门到实战九[Table API&SQL]-8-基于FileSystem 创建 TABLE 通过 connector SQL DDL
Flink从入门到实战九[Table API&SQL]-7-基于FileSystem 创建 TABLE 通过 connector 声明
Connector 描述了存储表数据的外部系统。存储系统例如 Apache Kafka 或者常规的文件系统都可… 继续阅读 Flink从入门到实战九[Table API&SQL]-7-基于FileSystem 创建 TABLE 通过 connector 声明
Flink从入门到实战九[Table API&SQL]-6-什么是Catalogs
我们要建表,就要定义内部和外部表的结构,此时就是在定义Catalog。Catalog 提供了元数据信息,例如数… 继续阅读 Flink从入门到实战九[Table API&SQL]-6-什么是Catalogs
Flink从入门到实战九[Table API&SQL]-5-DataStream和DataSet与Table相互转换
将 DataStream 或 DataSet 转换成表//前面章节已经完整演示了代码Table table1 … 继续阅读 Flink从入门到实战九[Table API&SQL]-5-DataStream和DataSet与Table相互转换
Flink从入门到实战九[Table API&SQL]-4-使用StreamExecutionEnvironment创建 TableEnvironment
创建 TableEnvironment的第二种方法,可以通过StreamExecutionEnvironmen… 继续阅读 Flink从入门到实战九[Table API&SQL]-4-使用StreamExecutionEnvironment创建 TableEnvironment
Flink从入门到实战九[Table API&SQL]-3-使用EnvironmentSettings创建 TableEnvironment
上一节知道了TableEnvironment的作用,并且也知道了创建TableEnvironment有两种方法… 继续阅读 Flink从入门到实战九[Table API&SQL]-3-使用EnvironmentSettings创建 TableEnvironment
Flink从入门到实战九[Table API&SQL]-2-什么是 TableEnvironment
TableEnvironment 是 Table API 和 SQL 的核心概念。它负责: • 在内部的 ca… 继续阅读 Flink从入门到实战九[Table API&SQL]-2-什么是 TableEnvironment
Flink从入门到实战九[Table API&SQL]-1-什么是 Table API&SQL?
Flink本身是批流统一的处理框架,所以Table API和SQL,就是批流统一的上层处理API。目前功能尚未… 继续阅读 Flink从入门到实战九[Table API&SQL]-1-什么是 Table API&SQL?