- 上期链接：kafka源码解析之一：源代码工程目录介绍1. 初始化代码分析：首先Demo里封装了一个Producer类， 这个类提供了同步和异步两种方式来发送消息。 异步发送消息是基于同步发送消息的接口来实现的。异步发送消息的实现很简单，客户端消息发送过来以后，先放入到一个队列中然后就返回了。Producer再开启一个线程（ProducerSendThread）不断从队列中取出消息，然后调用同步 上期链接：kafka源码解析之一：源代码工程目录介绍1. 初始化代码分析：首先Demo里封装了一个Producer类， 这个类提供了同步和异步两种方式来发送消息。 异步发送消息是基于同步发送消息的接口来实现的。异步发送消息的实现很简单，客户端消息发送过来以后，先放入到一个队列中然后就返回了。Producer再开启一个线程（ProducerSendThread）不断从队列中取出消息，然后调用同步
- 基于JVM的开源数据处理语言主要有Kotlin、Scala、SPL，下面对三者进行多方面的横向比较，从中找出开发效率最高的数据处理语言。本文的适用场景设定为项目开发中常见的数据处理和业务逻辑，以结构化数据... 基于JVM的开源数据处理语言主要有Kotlin、Scala、SPL，下面对三者进行多方面的横向比较，从中找出开发效率最高的数据处理语言。本文的适用场景设定为项目开发中常见的数据处理和业务逻辑，以结构化数据...
- 文章目录 零、IDEA的scala环境配置一、scala特点1.1 面向对象特性1.2 函数式编程1.3 静态类型 二、代码简单测试栗子三、scala trait（特征）四、常见问题4.1 I... 文章目录 零、IDEA的scala环境配置一、scala特点1.1 面向对象特性1.2 函数式编程1.3 静态类型 二、代码简单测试栗子三、scala trait（特征）四、常见问题4.1 I...
- 注意：下面的例子均在scala shell中演示的 一、数据结构介绍 对于Scala来说，同时支持可变集合和不可变集合，不可变集合一直都不会发生变化，可以安全的并发访问。 Scala优先采用不可变集合... 注意：下面的例子均在scala shell中演示的 一、数据结构介绍 对于Scala来说，同时支持可变集合和不可变集合，不可变集合一直都不会发生变化，可以安全的并发访问。 Scala优先采用不可变集合...
- 文章目录 简介1、 scala中声明变量2、惰性变量3、基本数据类型4、scala类型层次结构5、scala中的条件表达式6、scala方法的重载7、scala中的块表达式8、循环1、for循环2... 文章目录 简介1、 scala中声明变量2、惰性变量3、基本数据类型4、scala类型层次结构5、scala中的条件表达式6、scala方法的重载7、scala中的块表达式8、循环1、for循环2...
- 简介 特质就像是java的implement，是scala中代码复用的基础单元，它可以将方法和字段定义封装起来，然后添加到类中与类继承不一样的是，类继承要求每个类都只能继承一个超类，而一个类可以添加任意... 简介 特质就像是java的implement，是scala中代码复用的基础单元，它可以将方法和字段定义封装起来，然后添加到类中与类继承不一样的是，类继承要求每个类都只能继承一个超类，而一个类可以添加任意...
- 文章目录 一、类1、类的定义2、类的构造器 二、对象1、scala中的object2、scala中的伴生对象3、scala中object的apply方法4、scala中object的ma... 文章目录 一、类1、类的定义2、类的构造器 二、对象1、scala中的object2、scala中的伴生对象3、scala中object的apply方法4、scala中object的ma...
- 文章目录 1、继承extends2、override和super3、isInstanceOf和asInstanceOf4、getClass和classOf5、访问修饰符1、private[this... 文章目录 1、继承extends2、override和super3、isInstanceOf和asInstanceOf4、getClass和classOf5、访问修饰符1、private[this...
- 文章目录 一、提出任务 二、用Scala语言实现 （一）采用双重循环 （二）不用循环用算子 三、用Python语言实现 四、用Jav... 文章目录 一、提出任务 二、用Scala语言实现 （一）采用双重循环 （二）不用循环用算子 三、用Python语言实现 四、用Jav...
- 文章目录 一、创建Maven项目 - ScalaWordCount 三、利用mvn命令打包Maven项目 三、上传项目jar包到Flink集群主节点 四、启动Flink S... 文章目录 一、创建Maven项目 - ScalaWordCount 三、利用mvn命令打包Maven项目 三、上传项目jar包到Flink集群主节点 四、启动Flink S...
- 文章目录 一、提出任务二、准备工作（一）启动HDFS服务（二）启动Spark服务 三、实现步骤（一）在Spark Shell里完成任务（二）编写Scala程序完成任务1、创建Maven项目 -... 文章目录 一、提出任务二、准备工作（一）启动HDFS服务（二）启动Spark服务 三、实现步骤（一）在Spark Shell里完成任务（二）编写Scala程序完成任务1、创建Maven项目 -...
- 文章目录 零、本讲学习目标一、运算符等价于方法（一）运算符即方法（二）方法即运算符1、单参方法2、多参方法3、无参方法 二、Scala运算符（一）运算符分类表（二）Scala与Java运... 文章目录 零、本讲学习目标一、运算符等价于方法（一）运算符即方法（二）方法即运算符1、单参方法2、多参方法3、无参方法 二、Scala运算符（一）运算符分类表（二）Scala与Java运...
- 文章目录 零、本讲学习目标一、变量声明（一）简单说明（二）利用val声明变量1、声明方式2、案例演示 （三）利用var声明变量1、声明方式2、案例演示 （四）换行输入语句（五）同时声明... 文章目录 零、本讲学习目标一、变量声明（一）简单说明（二）利用val声明变量1、声明方式2、案例演示 （三）利用var声明变量1、声明方式2、案例演示 （四）换行输入语句（五）同时声明...
- 📋前言📋 💝博客主页：红目香薰_CSDN博客-大数据,计算机理论,MySQL领域博主💝 ✍本文由在下【红目香薰】原创，首发于CSDN✍ 🤗2022年最大愿望：【服务百万技术人次】🤗 💝初始环境地址：【spark环境搭建(idea版本)_红目香薰-CSDN博客】💝 环境需求 环境：win... 📋前言📋 💝博客主页：红目香薰_CSDN博客-大数据,计算机理论,MySQL领域博主💝 ✍本文由在下【红目香薰】原创，首发于CSDN✍ 🤗2022年最大愿望：【服务百万技术人次】🤗 💝初始环境地址：【spark环境搭建(idea版本)_红目香薰-CSDN博客】💝 环境需求 环境：win...
- 📋前言📋 💝博客主页：红目香薰_CSDN博客-大数据,计算机理论,MySQL领域博主💝 ✍本文由在下【红目香薰】原创，首发于CSDN✍ 🤗2022年最大愿望：【服务百万技术人次】🤗 💝初始环境地址：【spark环境搭建(idea版本)_红目香薰-CSDN博客】💝 环境需求 环境：win... 📋前言📋 💝博客主页：红目香薰_CSDN博客-大数据,计算机理论,MySQL领域博主💝 ✍本文由在下【红目香薰】原创，首发于CSDN✍ 🤗2022年最大愿望：【服务百万技术人次】🤗 💝初始环境地址：【spark环境搭建(idea版本)_红目香薰-CSDN博客】💝 环境需求 环境：win...
上滑加载中
推荐直播
-
GaussDB数据库介绍2025/01/07 周二 16:00-18:00
Steven 华为云学堂技术讲师
本期直播将介绍GaussDB数据库的发展历程、优势、架构、关键特性和部署模式等，旨在帮助开发者了解GaussDB数据库，并通过手把手实验教大家如何在华为云部署GaussDB数据库和使用gsql连接GaussDB数据库。
去报名 -
DTT年度收官盛典：华为开发者空间大咖汇，共探云端开发创新2025/01/08 周三 16:30-18:00
Yawei 华为云开发工具和效率首席专家 Edwin 华为开发者空间产品总监
数字化转型进程持续加速，驱动着技术革新发展，华为开发者空间如何巧妙整合鸿蒙、昇腾、鲲鹏等核心资源，打破平台间的壁垒，实现跨平台协同？在科技迅猛发展的今天，开发者们如何迅速把握机遇，实现高效、创新的技术突破？DTT 年度收官盛典，将与大家共同探索华为开发者空间的创新奥秘。
去报名 -
GaussDB应用实战：手把手带你写SQL2025/01/09 周四 16:00-18:00
Steven 华为云学堂技术讲师
本期直播将围绕数据库中常用的数据类型、数据库对象、系统函数及操作符等内容展开介绍，帮助初学者掌握SQL入门级的基础语法。同时在线手把手教你写好SQL。
去报名
热门标签