奋斗皮皮虾

文章
4
资源
0
加入时间
2年10月21天

Flink 流式计算 source与sink

获取各种源的DataStream1.获取nc数据源 /** * 获取端口9999的数据 需要先启动nc (执行命令 nc -l -p 9999),否则显示连接拒绝 * * @param env * @return */ private static DataStream<String> getDataNC(StreamExecutionEnvironment env) { DataStreamSourc