"# flink-test"

wc

WordCount

从文件读取数据，批处理计算单词个数，数据结构DataSet

StreamWordCount

从文件读取数据，转成DataStream流

socketWrodCount

从scket读取流数据，计算单词个数

pojo

pojo类，测试使用，flink 流能够处理pojo类和元组类

window

开窗测试

source

数据源测试

sink

sink测试

tableapi

table api 、sql及udf测试

function

函数测试