8000 GitHub - flicck/flink-simpleapi: 由于笔者觉得flink的一些api太难记了,就写了这个工具包,将一些常用函数放在一块方便调用。
[go: up one dir, main page]
More Web Proxy on the site http://driver.im/
Skip to content

由于笔者觉得flink的一些api太难记了,就写了这个工具包,将一些常用函数放在一块方便调用。

License

Notifications You must be signed in to change notification settings

flicck/flink-simpleapi

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

22 Commits
 
 
 
 
 
 
 
 
 
 
 
 

Repository files navigation

flink-simpleapi

由于笔者觉得flink的一些api太难记了,就写了这个工具包,将一些函数放在一块方便大家调用。
使用方式:maven clean install
然后在其他项目中加入

<dependency>
<groupId>io.flicck.github</groupId>
<artifactId>flink-simpleapi</artifactId>
<version>1.0.0</version>
</dependency>

以下为api结构图
结构 上面这些的接口或类或方法,有些是需要new出来,有些是需要实现或继承,根据所处场景进行判断
.window(Win.Sliding.eventTime(Time.seconds(2L), Time.seconds(2L))) 结构

final StreamEnv streamEnv = new StreamEnv();
streamEnv.from.collection(xxxxx);
streamEnv.checkPoint.enable(xxxx);
streamEnv.config.setStreamTimeCharacteristic(xxxx);
streamEnv.exConfig.setAutoWatermarkInterval(xxxx); 等等

下一阶段 整合所有Connector到StreamEnv,提供统一的入口,目前已整合kafka

About

由于笔者觉得flink的一些api太难记了,就写了这个工具包,将一些常用函数放在一块方便调用。

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published

Languages

0