1.通过命令快速生成一个flink项目
curl https://flink.apache.org/q/quickstart.sh | bash -s 1.19.1
生成文件目录:
其中pom文件包好我们所需要的基础flink相关依赖
2.测试
public class DataStreamJob {
public static void main(String[] args) throws Exception {
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
DataStreamSource<String> stringDataStreamSource = env.fromData(Arrays.asList("1", "2", "3"));
stringDataStreamSource.print();
env.execute("Flink Java API Skeleton");
}
}
3.测试结果
成功!
本站资源均来自互联网,仅供研究学习,禁止违法使用和商用,产生法律纠纷本站概不负责!如果侵犯了您的权益请与我们联系!
转载请注明出处: 免费源码网-免费的源码资源网站 » 【flink】之如何快速搭建一个flink项目
发表评论 取消回复