开发者社区 问答 正文

pyflink中将datastream作为文件输出的代码是什么?

pyflink中将datastream作为文件输出的代码是什么?

展开
收起
游客qzzytmszf3zhq 2021-12-07 15:29:13 319 分享 版权
1 条回答
写回答
取消 提交回答
  • ds.sink_to(FileSink.for_row_format("out", Encoder.simple_string_encoder()).build())
    
    
    2021-12-07 15:29:25
    赞同 展开评论
问答分类:
问答地址: