- Apache Flink 文档
- 概念
- 数据流编程模型
- 分布式运行时环境
- 教程
- API 教程
- DataStream API 教程
- Setup 教程
- 本地安装教程
- 在 Windows 上运行 Flink
- 例子
- 批处理示例
- 应用开发
- 项目构建设置
- Java 项目模板
- Scala 的项目模板
- 配置依赖关系,连接器,库
- 基础 API 概念
- Scala API 扩展
- Java Lambda 表达式
- Flink DataStream API 编程指南
- 活动时间
- 事件时间/处理时间/摄取时间
- 活动时间和水印
- 状态与容错
- 算子
- DataStream 转换
- 物理分区
- 任务链和资源组
- 流连接器
- 旁路输出
- Python 编程指南(流)Beta
- 测试
- 实验特点
- Flink DataSet API 编程指南
- 数据集转换
- 容错
- 在数据集中压缩数据元
- 迭代
- Python 编程指南 Beta
- 连接器
- Hadoop 兼容性测试版
- 本地执行
- 群集执行
- Table API 和 SQL
- 概念和通用 API
- 流处理概念
- 连接到外部系统
- Table API
- SQL
- 内置函数
- 用户定义的源和接收器
- 用户定义的函数
- SQL 客户端测试版
- 数据类型和序列化
- 为 Flink 程序注册自定义序列化程序
- 管理执行
- 执行配置
- 程序打包和分布式执行
- 并行执行
- 执行计划
- 重启策略
- 类库
- FlinkCEP - Flink 的复杂事件处理
- 风暴兼容性 Beta
- 项目配置
- 执行 Storm 拓扑
- 在 Flink 流程序中嵌入 Storm 算子
- Flink Extensions
- Storm 兼容性示例
- Gelly:Flink Graph API
- 图 API
- FlinkML - Flink 的机器学习
- 最佳实践
- API 迁移指南
- 部署和运营
- 集群和部署
- 独立群集
- YARN 设置
- Mesos 设置
- Kubernetes 设置
- Docker 设置
- 亚马逊网络服务(AWS)
- Google Compute Engine 设置
- 先决条件
- 在 Google Compute Engine 上部署 Flink
- MapR 设置
- Hadoop 集成
- JobManager 高可用性(HA)
- 状态和容错
- 检查点
- 保存点
- 状态后台
- 调整检查点和大状态
- 配置
- 生产准备清单
- 命令行界面
- Scala REPL
- Kerberos 身份验证设置和配置
- SSL 设置
- 文件系统
- 升级应用程序和 Flink 版本
- 调试和监控
- 度量
- 如何使用日志记录
- 历史服务器
- 监控检查点
- 监测背压
- 监控 REST API
- 调试 Windows 和事件时间
- 调试类加载
- 应用程序分析
- 使用 Java Flight Recorder 进行性能分析
- 使用 JITWatch 进行分析
- Flink Development
- 将 Flink 导入 IDE
- 从 Source 建立 Flink
- 内幕
- 组件堆栈
- 数据流容错
- 工作和调度
- 任务生命周期
- 文件系统
- 实现
- 坚持保证
- 更新文件内容
- 覆盖文件
- 线程安全
将 Flink 导入 IDE
以下部分描述了如何将 Flink 项目导入 IDE 以开发 Flink 本身。有关编写 Flink 程序的信息,请参阅 Java API 和 Scala API 快速入门指南。
注意: 每当 IDE 中的某些内容无效时,请首先尝试使用 Maven 命令行, mvn clean package -DskipTests
因为它可能是您的 IDE 有错误或未正确设置。
制备
首先,请先从我们的某个 存储库中 查看 Flink 源代码 ,例如:
git clone https://github.com/apache/flink.git
IntelliJ IDEA
关于如何设置 IntelliJ IDEA IDE 以开发 Flink 核心的简要指南。由于已知 Eclipse 存在混合 Scala 和 Java 项目的问题,因此越来越多的贡献者正在迁移到 IntelliJ IDEA。
以下文档描述了使用 Flink 源设置 IntelliJ IDEA 2016.2.5( https://www.jetbrains.com/idea/download/ )的步骤。
安装 Scala 插件
IntelliJ 安装设置提供安装 Scala 插件。如果未安装,请在导入 Flink 之前按照这些说明启用对 Scala 项目和文件的支持:
- 转到 IntelliJ 插件设置(IntelliJ IDEA - >首选项 - >插件),然后单击“安装 Jetbrains 插件...”。
- 选择并安装“Scala”插件。
- 重启 IntelliJ
导入 Flink
- 启动 IntelliJ IDEA 并选择“导入项目”
- 选择 Flink 存储库的根文件夹
- 选择“从外部模型导入项目”并选择“Maven”
- 保存默认选项并单击“下一步”,直到您点击 SDK 部分。
- 如果没有 SDK,请创建一个左上角带有“+”符号的 SDK,然后单击“JDK”,选择您的 JDK 主目录并单击“确定”。否则只需选择您的 SDK。
- 继续再次单击“下一步”并完成导入。
- 右键单击导入的 Flink 项目 - > Maven - >生成源和更新文件夹。请注意,这将在您的本地 Maven 存储库中安装 Flink 库,即“/ home / -your-user- /.m2/repository/org/apache/flink/”。或者,
mvn clean package -DskipTests
还可以为 IDE 创建必要的文件,但不安装库。 - 构建项目(构建 - >制作项目)
Checkstyle For Java
IntelliJ 使用 Checkstyle-IDEA 插件支持 IDE 中的 checkstyle。
- 从 IntelliJ 插件存储库安装“Checkstyle-IDEA”插件。
- 通过转到设置 - >其他设置 - > Checkstyle 来配置插件。
- 将“扫描范围”设置为“仅 Java 源(包括测试)”。
- 在“Checkstyle Version”下拉列表中选择 8.9 ,然后单击“应用”。 这一步很重要,不要跳过它!
- 在“配置文件”窗格中,使用加号图标添加新配置:
- 将“描述”设置为“Flink”。
- 选择“使用本地 Checkstyle 文件”,并将其指向
"tools/maven/checkstyle.xml"
存储库中。 - 选中“相对于项目位置存储”框,然后单击“下一步”。
- 将“checkstyle.suppressions.file”属性值配置为
"suppressions.xml"
,然后单击“下一步”,然后单击“完成”。
- 选择“Flink”作为唯一的活动配置文件,然后单击“应用”和“确定”。
- Checkstyle 现在会在编辑器中针对任何 Checkstyle 违规行为发出警告。
安装插件后,您可以 "tools/maven/checkstyle.xml"
通过转到 Scheme 下拉框旁边的设置 - >编辑器 - >代码样式 - > Java - >齿轮图标直接导入。例如,这将自动调整导入布局。
您可以通过打开 Checkstyle 工具窗口并单击“检查模块”按钮来扫描整个模块。扫描应报告没有错误。
注意一些模块没有完全被 CheckStyle 的,其中包括覆盖 flink-core
, flink-optimizer
和 flink-runtime
。不过请确保您在这些模块中添加/修改的代码仍符合 checkstyle 规则。
Scala 的 Checkstyle
通过选择“设置” - >“编辑器” - >“检查”,然后搜索“Scala 样式检查”,在 Intellij 中启用 scalastyle。也 "tools/maven/scalastyle_config.xml"
放在 "<root>/.idea"
或 "<root>/project"
目录中。
Eclipse
注意: 根据我们的经验,由于 Scala IDE 3.0.3 捆绑的旧 Eclipse 版本的不足或者与 Scala IDE 4.4.1 中捆绑的 Scala 版本的版本不兼容,此设置不适用于 Flink。
我们建议改用 IntelliJ(见 上文 )
如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

绑定邮箱获取回复消息
由于您还没有绑定你的真实邮箱,如果其他用户或者作者回复了您的评论,将不能在第一时间通知您!
发布评论