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?
Flink从入门到实战八[State]-17-Flink状态 RocksDBStateBackend使用
EmbeddedRocksDBStateBackend 将正在运行中的状态数据保存在 RocksDB 数据库中… 继续阅读 Flink从入门到实战八[State]-17-Flink状态 RocksDBStateBackend使用
Flink从入门到实战八[State]-16-Flink State Backend 状态后端
Checkpoint的作用是将状态持久化，State Backend（状态后端）则是真正管理状态、存储状态、基… 继续阅读 Flink从入门到实战八[State]-16-Flink State Backend 状态后端
Flink从入门到实战八[State]-15-Flink状态 SavePoint使用
什么是 SavepointSavepoint 是依据 Flink checkpointing 机制所创建的流作… 继续阅读 Flink从入门到实战八[State]-15-Flink状态 SavePoint使用
Flink从入门到实战八[State]-14-Flink状态 Checkpoint使用
上一节了解了Checkpoint的执行流程和内部原理，那么Checkpoint是如何使用的呢，我们先来看一下A… 继续阅读 Flink从入门到实战八[State]-14-Flink状态 Checkpoint使用
Flink从入门到实战八[State]-13-Flink状态容错
前面几节内容已经演示了如何使用Flink状态进行计算，如何对状态进行保存、恢复。要实现状态的应用计算和保存恢复… 继续阅读 Flink从入门到实战八[State]-13-Flink状态容错
Linux安装新版本内核
1、安装gcc和kernel-devel编译工具链[itzhimei@localhost ~]#yum ins… 继续阅读 Linux安装新版本内核
Flink从入门到实战八[State]-12-Flink Key State 与 Operator State 区别
前面的章节已经讲解了Flink状态的分类和代码示例，我们来对比一下Key State 与 Operator S… 继续阅读 Flink从入门到实战八[State]-12-Flink Key State 与 Operator State 区别
Flink从入门到实战八[State]-11-Flink Broadcast State 广播状态使用示例
基于前一节我们已经对Broadcast State和其API有了一定了解，本节我们一起来编写代码，实现一个de… 继续阅读 Flink从入门到实战八[State]-11-Flink Broadcast State 广播状态使用示例
Flink从入门到实战八[State]-10-Flink Broadcast State 广播状态
Broadcast State （广播状态）：广播状态是一种特殊的算子状态。引入它的目的在于支持一个流中的元素… 继续阅读 Flink从入门到实战八[State]-10-Flink Broadcast State 广播状态
Flink从入门到实战八[State]-9-Flink Operator State的ListCheckpointed使用方法
通过实现 ListCheckpointed 接口来使用 operator state。ListCheckpoi… 继续阅读 Flink从入门到实战八[State]-9-Flink Operator State的ListCheckpointed使用方法
Flink从入门到实战八[State]-8-Flink Operator State的CheckpointedFunction使用方法
通过实现 CheckpointedFunction 接口来使用 operator state。Checkpoi… 继续阅读 Flink从入门到实战八[State]-8-Flink Operator State的CheckpointedFunction使用方法
Flink从入门到实战八[State]-7-Flink Operator State 算子状态
Operator State（算子状态）：在同一个算子上的状态，对当前算子的所有数据是共享的。需要注意的是St… 继续阅读 Flink从入门到实战八[State]-7-Flink Operator State 算子状态
Flink从入门到实战八[State]-6-Flink State 状态过期与清理
Flink里任何类型的keyed state都可以有 有效期 (TTL)。如果配置了 TTL 且状态值已过期，… 继续阅读 Flink从入门到实战八[State]-6-Flink State 状态过期与清理