需要的配置只有一个sql文件 代码整体的结构参考开源项目 代码中SQL文件解析的部分参考开源项目 1.实现socket输入console输出 配置： CREATE TABLE SocketTable( word String, valuecount int )WITH( type= ' socket ' , host= ' hadoop-sh1-core1 ' , port= ' 9998 ' , delimiter= ' ' ) ; crea