在生产环境下，通常使用Flume采集日志数据，并将采集到的日志数据发送到Kafka上。这里Flume充当了Kafka生产者角色。而对于Kafka来说，关键是如何接收来自Flume的数据。我们需要在Kafka中创建一...

前端框架vue.js系列教程：安装配置node.js和npmvue.js工程项目创建vue.js框架应用开发vue.js单页面应用开发vue.js中实现echarts绘图vue.js远程访问RESTful API接口示例vue.js使用Fetch API访问R...

实验环境实验准备实验内容一、下载安装vue cli二、创建vue.js项目三、编辑App.vue添加MyCharts组件四、写出MyCharts数据可视化组件模板代码五、在模板里添加处理数据的逻辑代码  实验环境Ubun...

Scala同样提供了对程序流程控制的语法。Scala中的程序流程控制结构虽然与Java类似，但也有自己的一些独特的方法。循环结构经常地，我们需要遍历集合中的元素，或者对集合中的每个元素进行操作，...

Scala是一种非常适合开发大数据应用程序的语言，是使用Apache Spark的首选语言。使用Scala语言来学习Spark，具有以下优点：首先，开发人员可以通过使用Scala实现显著的生产力提升。其次，它帮助...

Scala的异常处理和其它语言比如Java类似，一个方法可以通过抛出异常的方法而不返回值的方式终止相关代码的运行。调用函数可以捕获这个异常作出相应的处理或者直接退出，在这种情况下，异常会传...

本任务共有两个子任务组成：实时数据采集子任务1实时数据采集子任务2子任务1子任务1描述1、在主节点使用Flume 采集实时数据生成器25001 端口的socket 数据（实时数据生成器脚本为主节点/data_lo...

实验环境实验准备实验内容一、初始化hadoop集群二、安装配置MySQL 5.7元数据库三、下载所需安装包四、安装配置Hive运行环境  实验环境Ubuntu 18.04Oracle JDK 1.8Hadoop 3.2.4Hive 3.1.3实验...

在Scala的for表达式中，可以使用yield关键字来生成新的集合：val nieces = Array('java', 'python', 'scala', 'php')for (n <- nieces) yield n.capitalize​// 使用 for/yield 创建新数组va...

Scala可以安装在Windows和Linux操作系统下。下面我们分别介绍在这两个操作系统下安装Scala的步骤。 （注：在安装Scala前，请确保已经安装好了JDK 8，并配置好了环境变量。）本节包括如下内容：...

RangeRange定义一个范围，指定开始、结束和步长，通常用于填充数据结构和遍历for循环。object RangeDemo { def main(args: Array[String]): Unit = {   // 使用方法to来创建Range(包含上限)  ...

数据存储在变量中，要对数据进行运算，就需要使用运算符。Scala语言中提供了这几种运算符：算术运算符、关系运算符、逻辑运算符、位运算符、赋值运算符等。注：实际上，Scala没有传统意义上的运...

任务要求11.1实现流程概要1.2任务分解任务要求22.1创建表2.2按id更新数据2.3按id插入数据2.4查询数据任务要求33.1创建表3.2按Id更新数据3.3按ld插入数据3.4查询数据任务要求44.1创建表4.2按Id更...

在本节中，我们将学习如何创建尾递归（tail recursive）函数，以及如何使用@annotation.tailrec注解，这将指示编译器应用任何进一步的优化。如何定义尾递归函数？在下面的示例中，我们定义一个...

Scala 有一个丰富的集合库，包含很多不同类型的集合。此外，所有的集合都暴露出相同的接口。因此，一旦熟悉了一个Scala 集合，就可以很容易地使用其它集合类型。Scala中的集合体系主要包括：Ite...

通过结合使用IntelliJ IDEA集成开发工具和Maven项目构建工具，我们可以方便快速地开发Flink项目。在IntelliJ IDEA中创建Flink项目第一步：启动IntelliJ IDEA，创建一个新的项目，如下图所示：第...