当前位置: 首页 > 知识库问答 >
问题:

在apache flink中获取JSON数据作为输入流

梁建德
2023-03-14

我想得到输入流作为JSON数组从一个网址。如何设置源代码,以便在apache flink中使用datastream连续获得输入。简而言之,我想从一个url连续获得json数据,而不会关闭flink作业。

共有1个答案

蔚和风
2023-03-14

您可以使用solketTextStream源代码连续获取JSON字符串化对象的流。

Flink插座示例:https://github.com/apache/flink/blob/master/flink-examples/flink-examples-streaming/src/main/java/org/apache/flink/streaming/examples/socket/SocketWindowWordCount.java

有关数据来源的更多信息:https://ci.apache.org/projects/flink/flink-docs-master/dev/datastream_api.html#data-来源

 类似资料:
  • 本文向大家介绍在JSON中输入JSON数据?,包括了在JSON中输入JSON数据?的使用技巧和注意事项,需要的朋友参考一下 使用JSON数据类型首先设置JSON数据,然后插入。让我们首先创建一个表- 使用插入命令在表中插入一些记录- 使用select语句显示表中的所有记录- 这将产生以下输出-

  • 我用下面的命令创建了一个数据流模板 数据流不为table_view2调用此函数,而是为该作业使用table_view。

  • 我在JSON中有以下数据: 并且我想使用jQuery获得它,这就是我正在做的: 我还尝试使用回调来实现它,这样做: 即使使用回调,我也无法恢复数据。返回函数。而返回未定义的me,并表示回调不是函数。

  • 我正在处理一个很大的json文件,该文件当前被编码为一个很长的行。 我的问题是-那显示了什么?我如何让它将json数据输出为PPRINT? 我编写的代码如下所示:

  • 问题内容: 我有一个文件,其中包含要在R中使用的1500个json对象。我已经能够将数据作为列表导入,但是在将其强制转换为有用的结构时遇到了麻烦。我想创建一个数据框,其中每个json对象包含一行,每个key:value对包含一列。 我用这个小的假数据集重新创建了我的处境: 数据的一些功能: 所有对象都包含相同数量的key:value对,尽管某些值是null 每个对象有两个非数字列(名称和组) 名称

  • 问题内容: 我正在尝试从php文件中获取json数据,以在Angular控制器中使用。我在php文件中回显,当我在角度控制器中时,它带回json数据,但是当我尝试做一个 controllers.js : content.php : index.php : 问题答案: 您实际上希望将数据作为JSON发送。为此,您只需要在语句之前添加即可。因此content.php变为: 顺便说一句,您可能需要对控制