前端如何做能切换语言的网站,有赞商城网页版,40平小商铺装修,抖音关键词推广1#xff09;概览
1.开始
要开始使用 Flink 应用程序#xff0c;请使用以下命令、脚本和模板来创建 Flink 项目。
可以使用如下的 Maven 命令或快速启动脚本#xff0c;基于原型创建一个项目。
a#xff09;Maven 命令
mvn archetype:generate \-Darch…1概览
1.开始
要开始使用 Flink 应用程序请使用以下命令、脚本和模板来创建 Flink 项目。
可以使用如下的 Maven 命令或快速启动脚本基于原型创建一个项目。
aMaven 命令
mvn archetype:generate \-DarchetypeGroupIdorg.apache.flink \-DarchetypeArtifactIdflink-quickstart-java \-DarchetypeVersion1.19.0b快速启动脚本
curl https://flink.apache.org/q/quickstart.sh | bash -s 1.19.02.需要哪些依赖
要开始一个 Flink 作业通常需要如下依赖项
Flink API用来开发你的作业连接器和格式以将你的作业与外部系统集成测试实用程序以测试你的作业
除此之外若要开发自定义功能还要添加必要的第三方依赖项。
3.Flink API
Flink 提供了两大 APIDatastream API 和 Table API SQL它们可以单独使用也可以混合使用具体取决于你的使用场景
你要使用的 API你需要添加的依赖项DataStreamflink-streaming-javaDataStream Scala 版flink-streaming-scala_2.12Table APIflink-table-api-javaTable API Scala 版flink-table-api-scala_2.12Table API DataStreamflink-table-api-java-bridgeTable API DataStream Scala 版flink-table-api-scala-bridge_2.12
4.运行和打包
如果想通过简单地执行主类来运行作业需要 classpath 里包含 flink-clients。对于 Table API 程序还需要在 classpath 中包含 flink-table-runtime 和 flink-table-planner-loader。
根据经验建议将应用程序代码及其所有必需的依赖项打包进一个 fat/uber JAR [包含所有依赖项和代码的 JAR]中。这包括打包作业用到的连接器、格式和第三方依赖项此规则不适用于 Java API、DataStream Scala API 以及前面提到的运行时模块它们已经由 Flink 本身提供不应包含在作业的 uber JAR 中。
可以把该作业 JAR 提交到已经运行的 Flink 集群也可以轻松将其添加到 Flink 应用程序容器镜像中而无需修改发行版。
