flink SQL 的相关内容

问答 2022-06-20 来自：开发者社区

请问，flink sql写hive 可以支持在一个任务里面sink 多张hive表？

问答 2022-06-14 来自：开发者社区

请问一下，flink sql 能针对某个vertex或者算子单独设置平行度吗？

文章 2022-06-13 来自：开发者社区

【Flink】（十五）Flink SQL / Table 介绍与实战

文章目录一、前言二、背景三、SQL & Table API四、Demo实践一、前言参加Flink中文社区极客训练营，本文是对云邪大佬课程的总结，为什么大佬这么强，头发还这么多！二、背景Flink 非常灵活的三层API，三层API有不同的针对群体，越底层越灵活，但开发门槛也越高。很多BI 或者分析的同学可能更希望于专注于自己的业务逻辑，于是Flink SQL 和 Table API就应运而....

文章 2022-06-13 来自：开发者社区

【Flink】（十二）Flink Table API 和 Flink SQL 编程（更新中....）2

五、读取文件创建表TableEnvironment 可以调用.connect() 方法，连接外部系统，并调用.createTemporaryTable() 方法，在 Catalog 中注册表tableEnv .connect(...) // 定义表的数据来源，和外部系统建立连接 .withFormat(...) // 定义数据格式化方法 .withSchema(...) // ...

文章 2022-06-13 来自：开发者社区

【Flink】（十二）Flink Table API 和 Flink SQL 编程（更新中....）1

文章目录一、Table API 和 Flink SQL 是什么二、基本程序结构三、创建 TableEnvironment四、表（Table）五、读取文件创建表六、读取Kafka数据创建表七、表的查询 - Table API & SQL八、表和流的相互转换一、Table API 和 Flink SQL 是什么Flink 对批处理和流处理，提供了统一的上层APITable API 是一套内嵌....

文章 2022-06-13 来自：开发者社区

【Flink】（十）Flink Table API 和 Flink SQL 入门

文章目录一、需要引入的pom依赖二、简单了解 Table API2.1 动态表2.2 字段三、Table API 的窗口聚合操作3.1 通过一个例子了解Table API3.2 关于group by3.3 关于时间窗口四、SQL 如何编写Table API 是流处理和批处理通用的关系型 API，Table API 可以基于流输入或者批输入来运行而不需要进行任何修改。Table API 是 SQL....

问答 2022-06-10 来自：开发者社区

flink啥时候可以支持在sql-client模式下，往yarn上提交任务可以指定applicati

flink啥时候可以支持在sql-client模式下，往yarn上提交任务可以指定application_id？

问答 2022-06-10 来自：开发者社区

关于flink sql join，有时候数据会漏，这个有啥解决方案？

文章 2022-06-09 来自：开发者社区

Flink SQL JSON Format 源码解析

用 Flink SQL 解析 JSON 格式的数据是非常简单的,只需要在 DDL 语句中设置 Format 为 json 即可,像下面这样:CREATE TABLE kafka_source ( funcName STRING, data ROW<snapshots ARRAY<ROW<content_type STRING,url STRING>>...

文章 2022-06-09 来自：开发者社区

Flink SQL 自定义 redis connector

一般情况下,我们不需要创建新的 connector,因为 Flink SQL 已经内置了丰富的 connector 供我们使用,但是在实际生产环境中我们的存储是多种多样的,所以原生的 connector 并不能满足所有用户的需求,这个时候就需要我们自定义 connector,这篇文章的重点就是介绍一下如何实现自定义 Flink SQL connector ?先来看一下官网的一张 connecto....