/**
 * @title c
 * @author li.pan
 * @Date 2021/11/8
 * 1.测试启动类 {@link com.lp.java.demo.StreamingRunApp}
 * 2.wordCont程序{@link com.lp.java.demo.datastream.transformation.DataStreamWordCountApp}
 * 3.接入数据源{@link com.lp.java.demo.datastream.source}
 * 4.WaterMark水位线理解{@link com.lp.java.demo.datastream.watermark}
 * 5.Windows窗口聚合函数{@link com.lp.java.demo.datastream.windows}
 * 6.AsyncIo异步IO{@link com.lp.java.demo.datastream.asyncio}
 * 7.process 低阶函数{@link com.lp.java.demo.datastream.process}
 * 8.SideOutPut 侧输出(延迟数据处理和分流){@link com.lp.java.demo.datastream.sideoutputs}
 * 9.window窗口双流Join(延迟数据处理和分流){@link com.lp.java.demo.datastream.join}
 * 10.Sink 输出到外部系统 {@link com.lp.java.demo.datastream.sink}
 */
package com.lp.java.demo.datastream;
