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