首页 > 其他分享 >Flink 训练项目教程

Flink 训练项目教程

时间:2024-12-25 10:44:45浏览次数:5  
标签:src training java Flink 教程 训练项目 exercises com

Flink 训练项目教程

Flink 训练项目教程

flink-training-exercises项目地址:https://gitcode.com/gh_mirrors/fli/flink-training-exercises

项目的目录结构及介绍

Flink 训练项目的目录结构如下:

  1. flink-training-exercises/
  2. ├── build.gradle
  3. ├── gradlew
  4. ├── gradlew.bat
  5. ├── settings.gradle
  6. ├── src
  7. │ ├── main
  8. │ │ ├── java
  9. │ │ │ └── com
  10. │ │ │ └── dataartisans
  11. │ │ │ └── training
  12. │ │ │ ├── exercises
  13. │ │ │ │ ├── RideCleansingExercise.java
  14. │ │ │ │ ├── RidesAndFaresExercise.java
  15. │ │ │ │ └── TaxiCountExercise.java
  16. │ │ │ └── solutions
  17. │ │ │ ├── RideCleansingSolution.java
  18. │ │ │ ├── RidesAndFaresSolution.java
  19. │ │ │ └── TaxiCountSolution.java
  20. │ │ └── resources
  21. │ │ └── log4j.properties
  22. │ └── test
  23. │ ├── java
  24. │ │ └── com
  25. │ │ └── dataartisans
  26. │ │ └── training
  27. │ │ ├── exercises
  28. │ │ │ ├── RideCleansingExerciseTest.java
  29. │ │ │ ├── RidesAndFaresExerciseTest.java
  30. │ │ │ └── TaxiCountExerciseTest.java
  31. │ │ └── solutions
  32. │ │ ├── RideCleansingSolutionTest.java
  33. │ │ ├── RidesAndFaresSolutionTest.java
  34. │ │ └── TaxiCountSolutionTest.java
  35. │ └── resources
  36. │ └── log4j.properties
  37. └── README.md

目录结构介绍

  • build.gradle:Gradle 构建文件,用于配置项目的构建过程。
  • gradlewgradlew.bat:Gradle 包装器脚本,用于在不同平台上执行 Gradle 任务。
  • settings.gradle:Gradle 设置文件,用于配置多项目构建。
  • src/main/java:包含项目的主要 Java 源代码。
    • com/dataartisans/training/exercises:包含练习的 Java 文件。
    • com/dataartisans/training/solutions:包含练习的参考解决方案。
  • src/main/resources:包含项目的资源文件,如 log4j.properties
  • src/test/java:包含项目的测试代码。
    • com/dataartisans/training/exercises:包含练习的测试文件。
    • com/dataartisans/training/solutions:包含练习的参考解决方案的测试文件。
  • src/test/resources:包含测试的资源文件,如 log4j.properties
  • README.md:项目的说明文档。

项目的启动文件介绍

项目的启动文件主要位于 src/main/java/com/dataartisans/training/exercises 目录下,每个练习都有一个对应的启动文件。以下是一些示例:

  • RideCleansingExercise.java:用于清洗出租车行程数据的练习。
  • RidesAndFaresExercise.java:用于处理出租车行程和费用数据的练习。
  • TaxiCountExercise.java:用于统计出租车行程数量的练习。

这些启动文件通常包含 main 方法,用于启动 Flink 程序。

项目的配置文件介绍

项目的配置文件主要位于 src/main/resourcessrc/test/resources 目录下。以下是一些示例:

  • log4j.properties:用于配置日志记录的属性文件。

这些配置文件用于设置项目的运行时环境和日志记录等。


以上是 Flink 训练项目的目录结构、启动文件和配置文件的介绍。希望这些信息能帮助你更好地理解和使用该项目。

flink-training-exercises项目地址:https://gitcode.com/gh_mirrors/fli/flink-training-exercises

原文链接:https://blog.csdn.net/gitblog_00970/article/details/141512965

标签:src,training,java,Flink,教程,训练项目,exercises,com
From: https://www.cnblogs.com/sunny3158/p/18629805

相关文章

  • 【教程】第十二章 会议室预约管理
    相信如今的你,对于NocoBase已经非常熟悉了。在这一章中,我们来一同实现以一个特殊的场景:会议管理模块。该模块包含了会议室预定与通知等功能。在这个过程中,我们将逐步从零构建一个会议管理模块,从基础开始,逐渐实现更复杂的功能。我们先来设计这个模块的基础数据表结构。12.1设......
  • Flink State 状态原理解析
    作者:京东物流吴云涛一、FlinkState概念State用于记录Flink应用在运行过程中,算子的中间计算结果或者元数据信息。运行中的Flink应用如果需要上次计算结果进行处理的,则需要使用状态存储中间计算结果。如Join、窗口聚合场景。Flink应用运行中会保存状态信息到State对......
  • Ubuntu在VMware上安装及Winscp配置教程
    1、准备工作工具:(网上下载,也可以留言评论,我给你链接)VMware-workstation-full-12.5.7.20721.exe(虚拟机)ubuntu-16.04.5-desktop-amd64.iso(ubuntu镜像文件)winscp(图形用户界面)备注:也可以不用虚拟机,直接在window系统下安装,但是比较麻烦,要分出盘给linux系统,相当于电脑有双......
  • 【Java教程】Day4-14 面向对象编程(OOP): Classpath详解与Jar包使用指南
    在Java编程中,我们经常接触到classpath这一概念。虽然很多文章讨论了如何设置classpath,但其中大部分并不完全准确。在这篇文章中,我们将深入探讨classpath的作用、如何正确配置它、以及如何使用jar包来管理Java项目。  1.什么是Classpath?Classpath是JVM(Java虚拟机)用来查找......
  • 【Java教程】Day5-01 核心类:String 字符串全面解析
    在Java中,String 是一个非常常用的数据类型,它代表一个字符串。不同于其他类型,String 是一个引用类型,实际在内存中由一个字符数组(char[])来表示。Java的 String 类提供了很多功能强大的方法来操作字符串数据,本篇文章将深入解析 String 类型的相关知识,帮助你更好地理解和......
  • Flink优化----数据倾斜
    目录判断是否存在数据倾斜数据倾斜的解决keyBy后的聚合操作存在数据倾斜为什么不能直接用二次聚合来处理使用LocalKeyBy的思想DataStreamAPI自定义实现的案例keyBy之前发生数据倾斜keyBy后的窗口聚合操作存在数据倾斜实现思路提交原始案例提交两阶段聚合的案......
  • Alluxio 单机和集群部署教程
    目录Alluxio单机和集群部署教程第一部分:Alluxio概述Alluxio的关键特点:第二部分:Alluxio单机部署教程1.安装Alluxio1.1下载并解压Alluxio1.2配置Alluxio1.3启动Alluxio1.4测试功能2.单机案例代码实现(Python)2.1Python示例代码3.常见问题及解决方法3.1A......
  • Logstash 单机与集群部署教程
    目录Logstash单机与集群部署教程第一部分:Logstash概述第二部分:Logstash单机部署教程1.安装Logstash1.1安装依赖1.2配置Logstash1.3启动Logstash2.单机案例代码实现(Python)3.常见问题及解决方法3.1Logstash启动失败3.2无法连接到Elasticsearch第三部分:L......
  • SecureCRT 9.1 免费版下载及安装使用教程
    SecureCRT是一款专业的电脑终端仿真器,将坚如磐石的终端仿真与强大的加密功能结合在一起,严格保证用户的信息安全。SecureCRT具备安全传输,高度可配置的会话,SSH加密等等功能,支持SSH2、SSH1、Telnet、Telnet/SSH、Relogin、Serial、TAPI、RAW等协议。软件特色1、标签组现在在所有......
  • 【python量化教程】如何使用必盈股票API接口,获取最新实时交易数据
      一篇文章教会什么是股票量化分析   股票API接口作为一种应用程序编程接口,犹如在股票数据的提供者与使用者之间架起的一座沟通桥梁。股票市场环境错综复杂,其中蕴含着海量数据,例如股票实时价格、历史价格变动轨迹以及成交量等信息。借助股票API接口,有获取数据需......