AI 助理
备案控制台
开发者社区 问答 正文

Flink里基于内存 Collections、Iterators 的Source是什么？

Flink里基于内存 Collections、Iterators 的Source是什么？

展开
收起
游客qzzytmszf3zhq 2021-12-07 20:13:51 359 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 游客yzrzs5mf6j7yy

    基于内存 Collections、Iterators 的Source可以直接基于内存中的集合或者迭代器，调用StreamExecutionEnvironment fromCollection、fromElements构建相应的source。结果数据也可以直接print、printToError的方式写出到标准输出或标准错误

    2021-12-07 20:14:06
    赞同 展开评论
问答分类：
流计算 实时计算 Flink版
问答标签：
实时计算 Flink版Source 实时计算 Flink版内存 内存flink 内存source
问答地址：
开发者社区 > 大数据 > 问答
相关问答
flink cdc sql将一个source，sink到pg和kafka，这种场景支持吗?
147
0
0
flink mongodb cdc source多个并行度时是不是有一个额外的职责？
134
1
0
Flink CDC怎么获取source的schema?
251
2
0
flink作为source jar作业代码里面消费位点的订阅方式 和控制台的有无状态启动有冲突吗？
85
1
0
flink sql mysql cdc 2.4现在支持source合并吗？就像这样？
183
1
0
在Flink CDC中，如果可以从mysql source 拿到，是否可以定制传下去？
70
1
0
对于Flink CDC，是否可以贡献tidb的source代码？
100
1
0
为什么Flink source节点显示为finished
158
1
0
Flink报错Unable to create a source for reading ta...
211
0
0
请教一下，emr-flink 的flinkSQL如何只针对source表单独设置并行度呢？
326
7
0