请问：
现在比如python已经写好了一个程序，实现的功能为：能将输入的数据中的阿拉伯数字筛选出来。
请问这个程序怎么运用在Storm/Flink/SparkStreaming的框架中，对实时数据进行处理呢？
具体的实现过程是怎么样的？
关于python与大数据处理框架Storm/Flink/Sparkstreaming的使用问题
- 写回答
- 好问题 0 提建议
- 追加酬金
- 关注问题
分享- 邀请回答
-
0条回答 默认 最新
- 2022-05-27 11:19回答 1 已采纳 当10:14:51的数据来之前，流中最大的事件时间 >= 10:24:50(窗口结束时间) + watermark延迟时间 + 允许延迟时间 ，导致当前waterMark 的值更新为 这个最大的
- 2021-08-18 11:07回答 2 已采纳 你的包是不是导错了。删除你导入的包，把下面的包复制放你程序中。 import org.apache.flink.api.common.typeinfo.TypeInformation; import
- 2021-08-16 15:59回答 1 已采纳 应该可以，不过通常使用scala语言进行编写
- 2019-06-19 09:53Kaka架构的博客 Flink也提供 API来像Spark一样进行批处理，但两者处理的基础是完全不同的。Flink把批处理当作流处理中的一种特殊情况。在Flink中，所有 的数据都看作流，是一种很好的抽象，因为这更接近于现实世界。 1.1 基本架构 ...
- 2021-07-16 14:22回答 1 已采纳 OutputTag获取迟到数据，二次消费
- 2022-04-24 10:13回答 1 已采纳 多个节点，同时获取到了数据，几个节点就有几次
- 2023-03-05 21:39回答 1 已采纳 你把全部报错复制到记事本发给我
- 2020-09-22 12:00zhisheng_blog的博客 在 1.2 节中已经跟大家详细介绍了 Flink，那么在本节就主要 Blink、Spark Streaming、Structured Streaming 和 Storm 的区别。 Flink Flink 是一个针对流数据和批数据分布式处理的引擎，在某些对实时性要求非常高的...
- 2022-12-19 11:35回答 1 已采纳 Python是一种跨平台的计算机程序设计语言，属于面向对象的动态类型语言，python是 人工智能首选的编程语言。而Hadoop，Spark、Flink是目前重要的三大分布式计算系统，Hadoop用于
- 2023-03-07 15:49回答 4 已采纳 Flink 在启动任务的时候，创建输入分片时发生了错误，导致无法启动任务。你需要检查一下程序中读取文件的代码是否正确，文件路径是否正确，文件是否存在，并且当前用户是否有访问该文件的权限。如果需要，可以
- 2022-01-28 09:47回答 1 已采纳 那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
- 2020-12-05 11:15IAmAngry.的博客 我们知道，大数据的计算模式主要分为批量计算(batch computing)、流式计算(stream computing)、交互计算(interactive computing)、图计算...目前主流的流式计算框架有Storm、Spark Streaming、Flink三种，其基本原...
- 2021-07-20 16:10回答 1 已采纳 放到kafka缓存 或者切成一个个小文件
- 2019-10-09 14:58戰士的博客 2）仅流处理框架：Samza与YARN和Kafka紧密集成的流处理，Storm常用于在线的实时的大数据处理。 3）混合框架：Spark常用于离线的快速的大数据处理（基于内存），Flink可扩展的批处理和流式数据处理的数据处理平台。 ...
- 2020-12-08 13:48AcceptedLin的博客 大数据处理引擎Spark与Flink对比 大数据技术正飞速地发展着，催生出一代又一代快速便捷的大数据处理引擎，无论是Hadoop、Storm，还是后来的Spark、Flink。然而，毕竟没有哪一个框架可以完全支持所有的应用场景，也...
- 没有解决我的问题, 去提问
悬赏问题
- ¥15 HFSS 中的 H 场图与 MATLAB 中绘制的 B1 场 部分对应不上
- ¥15 如何在scanpy上做差异基因和通路富集？
- ¥20 关于#硬件工程#的问题，请各位专家解答！
- ¥15 关于#matlab#的问题：期望的系统闭环传递函数为G(s)=wn^2/s^2+2¢wn+wn^2阻尼系数¢=0.707，使系统具有较小的超调量
- ¥15 FLUENT如何实现在堆积颗粒的上表面加载高斯热源
- ¥30 截图中的mathematics程序转换成matlab
- ¥15 动力学代码报错，维度不匹配
- ¥15 Power query添加列问题
- ¥50 Kubernetes&Fission&Eleasticsearch
- ¥15 報錯：Person is not mapped，如何解決？