海边一粒沙

自定义source只需要传入一个SourceFunction即可val stream4 = env.addSource( new MySensorSource() ) 举例说明：随机生成传感器数据无非...