问答 2023-04-19 来自:开发者社区

请问flink中我写的这样一个sql split函数,返回array类型,这是有什么错么?

请问我写的这样一个sql split函数,返回array类型,这是有什么错么?

问答 2023-03-08 来自:开发者社区

请问谁知道flink的array类型字段内如何排序?

请问谁知道flink的array类型字段内如何排序?

问答 2022-12-04 来自:开发者社区

大佬们Flink CDC ,Flink-SQL能处理这种问题吗? ARRAY< ROW<> >, A

大佬们Flink CDC ,Flink-SQL能处理这种问题吗? ARRAY >, ARRAY里面封装了多行数据, 需要从kafka中解析成一行行的数据

问答 2022-10-02 来自:开发者社区

flink sql 怎么解析array 类型的schema 啊

flink sql 怎么解析array 类型的schema 啊

问答 2022-10-01 来自:开发者社区

flink cdc sql的 ARRAY<ROW<>> 类型可以循环入库吗?

因为要把ARRAY 按 ROW 拆成多行入库。但对Kafka来说是一条JSON消息 ,只是某个Json属性映射成了ARRAY> 类型。 类似于这种格式:

问答 2021-12-07 来自:开发者社区

使用Flink Array Field Type

Flink 1.10.0 问题描述:source表中有个test_array_string ARRAY 字段,在DML语句用test_array_string[0]获取数组中的值会报数组越界异常。另外测试过Array 也是相同错误,Array ,Array 等类型也会报数组越界问题。 请问这是Flink1.10的bug吗? ...

问答 2021-12-07 来自:开发者社区

Flink SQL处理Array型的JSON

[ { "id": 1}, { "id": 2} ] 读出来变成表的两行。Flink SQL层面最佳实践是什么? 如果没有办法是不是只能改JSON结构了。 *来自志愿者整理的flink邮件归档

问答 2021-12-06 来自:开发者社区

Flink SQL处理Array型的JSON

Kafka中的JSON结构是个Array例子如下。 [ { "id": 1}, { "id": 2} ] 读出来变成表的两行。Flink SQL层面最佳实践是什么? 如果没有办法是不是只能改JSON结构了。 *来自志愿者整理的flink邮件归档

问答 2021-12-06 来自:开发者社区

Flink SQL Row里嵌套Array<Row>该如何用DDL定义?

[image: image.png] 如题,尝试用以下方式定义时会遇到异常,求社区大佬指点正确的打开姿势。 *来自志愿者整理的flink邮件归档

问答 2021-12-03 来自:开发者社区

定义自己函数时候,会出现null,flink直接跳过解析array那个函数了吗?

1.定义ddl解析array字段时候,假如select 那个字段可以解析出。2.当我去定义自己函数时候,会出现null,flink直接跳过解析array那个函数了吗? CREATE TABLE sourceTable ( event_time_line arrayrule_name VARCHAR, count VARCHAR )&gt; ) WITH ( 'connector.type' = '...

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐