文件名称：StructuredStreamingInSQL:sql实现结构化流
文件大小：69KB
文件格式：ZIP
更新时间：2024-04-07 07:40:14
Java
需要的配置只有一个sql文件 代码整体的结构参考开源项目 代码中SQL文件解析的部分参考开源项目 1.实现socket输入console输出 配置： CREATE TABLE SocketTable( word String, valuecount int )WITH( type= ' socket ' , host= ' hadoop-sh1-core1 ' , port= ' 9998 ' , delimiter= ' ' ) ; create SINK console( )WITH( type= ' console ' , outputmode= ' complete ' ) ; insert into console select word,count(*) from SocketTable group by wo
【文件预览】：
StructuredStreamingInSQL-master
----sqlstream.iml(80B)
----src()
--------main()
--------test()
----pom.xml(4KB)
----README.md(15KB)
----.idea()
--------misc.xml(513B)
--------vcs.xml(180B)
--------uiDesigner.xml(9KB)
--------hydra.xml(365B)
--------compiler.xml(569B)
----filepath()
--------people.csv(31B)
----conf()
--------csvsqlstream(291B)
--------socketprostream(500B)
--------socketsqlstream(412B)
--------sqlstream(560B)