开发者社区> 问答> 正文

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

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

展开
收起
游客qzzytmszf3zhq 2021-12-07 15:29:13 287 0
1 条回答
写回答
取消 提交回答
  • ds.sink_to(FileSink.for_row_format("out", Encoder.simple_string_encoder()).build())
    
    
    2021-12-07 15:29:25
    赞同 展开评论 打赏
问答分类:
问答地址:
问答排行榜
最热
最新

相关电子书

更多
《Apache Flink-重新定义计算》PDF下载 立即下载
LEARNINGS USING SPARK STREAMING & DATAFRAMES FOR WALMART SEARCH 立即下载
低代码开发师(初级)实战教程 立即下载