flink系列-8、Flink Table API & Flink Sql API
一、概述 上图是flink的分层模型，Table API 和 SQL 处于最顶端，是 Flink 提供的高级 API 操作。Flink SQL 是 Flink 实时计算为简化计算模型，降低用户使用实时计算门槛而设计的一套符合标准 SQL 语义的开发语言。 Flink 在编程模型 ...
原文：Flink SQL 系列 | 5 个 TableEnvironment 我该用哪个？
本文为 Flink SQL 系列文章的第二篇，前面对 Flink . Table 新架构及 Planner 的使用进行了详细说明，本文详细讲解 个 TableEnvironment 及其适用场景，并介绍 Flink 社区对 TableEnvironment 的未来规划。主要内容如下： TableEnvironment 简介 个 TableEnvironment 梳理 如何使用 TableEnvir ...
2019-10-11 16:01 1 291 推荐指数：
相关推荐
Flink系列之1.10版流式SQL应用
随着Flink 1.10的发布，对SQL的支持也非常强大。Flink 还提供了 MySql, Hive，ES, Kafka等连接器Connector，所以使用起来非常方便。 接下来咱们针对构建流式SQL应用文章的梗概如下： 1. 搭建流式SQL应用所需要的环境准备。 2. ...
flink sql
StreamTableEnvironment 该类包含sql解析、验证、优化、执行等各环节需要的元数据管理器CatalogManager,模块管理器(模块包含函数集、类型集、规则集)moduleManager，用户自定义函数管理器FunctionCatalog,线程池、sql解析器Planner ...
SQL表名，应该用复数还是单数
用单数形式更佳，理由如下： 1、概念直观。 你有一个袋子，里面有好多个苹果，你会说这是个苹果袋。但无论里面有0，1，百万个苹果，它依然是个袋子。表也是如此，表明需要描述清楚，表里面包含的对象，而非有多 ...
flink系列-9、flink的状态与容错
1、理解 State（状态） 1.1、State 对象的状态 Flink 中的状态：一般指一个具体的 task/operator 某时刻在内存中的状态（例如某属性的值）。 注意：State 和 Checkpointing 不要搞混。 checkpoint ...
Flink系列之Time和WaterMark
当数据进入Flink的时候，数据需要带入相应的时间，根据相应的时间进行处理。 让咱们想象一个场景，有一个队列，分别带着指定的时间，那么处理的时候，需要根据相应的时间进行处理，比如：统计最近五分钟的访问量，那么就需要知道数据到来的时间。五分钟以内的数据将会被计入，超过五分钟的将会计入下一个 ...
前端们，gulp该用起来了，简单的demo入门——gulp系列（一）
gulp、grunt前端自动化工具，只有用过才知道多么重要。 它们问世这么久了？你真的用过吗？ 写个简单的less、watch任务的demo分享———— 1.准备： 安装全局node、n ...
flink系列-1、flink介绍，反压原理
一、flink介绍 Apache Flink是一个分布式大数据处理引擎，可对 有界数据流和 无界数据流进行 有状态计算。 可部署在各种集群环境，对各种大小的数据规模进行快速计算。 1.1、有界数据流和无界数据流 1、 无界流有一个开始但没有定义的结束。它们不会在 ...