【flink】之如何快速搭建一个flink项目
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.测试结果
成功！
原文地址：https://blog.csdn.net/it_erge/article/details/140533183
免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！