scala—如何在ApacheFlink流应用程序输出中用编码的unicode字符解码json文本

kadbb459  于 2021-06-21  发布在  Flink
关注(0)|答案(0)|浏览(257)

我正在与flink合作,并正在编写一个scala程序,其中我使用flink的twitter连接器设置到twitter流api的连接,并根据规则获取/处理推文,最后:
在stdout中显示它们(我正在使用intellij idea进行开发)。
将它们保存到txt文件中。
包含希腊语或其他特殊字符的文本的tweet同时出现在stdout和txt文件中,例如:

"text":"test \u03c6\u03bb\u03af\u03bd\u03ba"

如何正确呈现转义的json文本(我正在使用windows服务器进行开发(如果这也起到了作用的话)。
相关代码如下:

val source = new TwitterSource(props)
source.setCustomEndpointInitializer(myCustomEndpoint)
val streamSource = env.addSource(source)

streamSource.print()
streamSource.writeAsText("file:\\\\C:\\test.txt", org.apache.flink.core.fs.FileSystem.WriteMode.OVERWRITE)

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题