- 这里主要是根据config.queueEnqueueTimeoutMs参数选择不同的入队列方式，该参数的值含义如下：# Timeout for event enqueue:# 0: events will be enqueued immediately or dropped if the queue is full# -ve: enqueue will block indefinitely if 这里主要是根据config.queueEnqueueTimeoutMs参数选择不同的入队列方式，该参数的值含义如下：# Timeout for event enqueue:# 0: events will be enqueued immediately or dropped if the queue is full# -ve: enqueue will block indefinitely if
- 上期链接：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...
上滑加载中
推荐直播
-
华为云码道-玩转OpenClaw，在线养虾2026/03/11 周三 19:00-21:00
刘昱，华为云高级工程师/谈心，华为云技术专家/李海仑，上海圭卓智能科技有限公司CEO
OpenClaw 火爆开发者圈，华为云码道最新推出 Skill ——开发者只需输入一句口令，即可部署一个功能完整的「小龙虾」智能体。直播带你玩转华为云码道，玩转OpenClaw
回顾中 -
华为云码道-AI时代应用开发利器2026/03/18 周三 19:00-20:00
童得力，华为云开发者生态运营总监/姚圣伟，华为云HCDE开发者专家
本次直播由华为专家带你实战应用开发，看华为云码道(CodeArts)代码智能体如何在AI时代让你的创意应用快速落地。更有华为云HCDE开发者专家带你用码道玩转JiuwenClaw，让小艺成为你的AI助理。
回顾中 -
Skill 构建 × 智能创作：基于华为云码道的 AI 内容生产提效方案2026/03/25 周三 19:00-20:00
余伟，华为云软件研发工程师/万邵业（万少），华为云HCDE开发者专家
本次直播带来两大实战：华为云码道 Skill-Creator 手把手搭建专属知识库 Skill；如何用码道提效 OpenClaw 小说文本，打造从大纲到成稿的 AI 原创小说全链路。技术干货 + OPC创作思路，一次讲透！
回顾中
热门标签