logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

Flink2.0学习笔记:Flink服务器搭建与flink作业提交

Flink2.0学习笔记:Flink服务器搭建与flink作业提交

文章图片
#学习#flink#大数据
Flink2.0学习笔记:stream-api source源:jdbc 流式处理(自定义支持多数库的连接池)和批次处理(使用mysql-flax 预加载数据)

Flink2.0学习笔记:stream-api:jdbc 流式处理(自定义支持多数库的连接池)和批次处理(使用mysql-flax 预加载数据)

文章图片
#学习#mysql#大数据 +1
Flink2.0学习笔记:使用HikariCP 自定义sink实现数据库连接池化

Flink2.0学习笔记:使用HikariCP 自定义sink实现数据库连接池化

文章图片
#学习#数据库#大数据 +1
关于 Amazon Polly 语音合成

Amazon Polly 是一种将文本转化为逼真语音的服务,使您能够创建对话应用程序,并构建全新类别的语音功能产品

文章图片
#语音识别#神经网络#自然语言处理 +2
Flink数据倾斜根因与解法

场景特征推荐方案核心思想Key 分布严重不均,存在少数超大 KeyKey 加盐或广播热点 Key将大 Key 拆分为多个小 Key 或广播到所有节点处理。窗口聚合触发时倾斜启用 LocalAggregation(预聚合)在窗口内先进行本地合并,减少 shuffle 数据量。常规聚合操作(sum/count)倾斜两阶段聚合先局部聚合,再全局汇总,是通用且有效的模式。已知固定热点 Key自定义分区器针

文章图片
#flink
【关于JVM原理】

JVM(Java Virtual Machine,Java 虚拟机)是 Java 程序的运行环境。它最大的贡献是实现了 “一次编写,到处运行”(跨平台),因为 JVM 屏蔽了底层操作系统的差异,Java 代码被编译成字节码(.class 文件),由不同平台上的 JVM 解释执行。

#jvm
Java自定义线程池核心参数解析

以下示例展示了如何创建一个功能完整的自定义线程池,包括任务提交、状态监控和优雅关闭。// 1. 自定义线程工厂:设置线程名称、优先级、是否为守护线程等@Override// 设置为非守护线程// 2. 自定义拒绝策略:当线程池和队列都满时,由调用者线程直接执行任务@OverrideSystem.err.println("任务被拒绝,由调用者线程直接执行: " + r.toString());if

文章图片
#java
Java 25虚拟线程使用实例

在 Java 25 中,虚拟线程已作为一项成熟稳定的特性被正式引入,其核心目标在于简化高并发应用程序的编写,尤其擅长处理大量 I/O 密集型任务。相较于传统平台线程,虚拟线程的创建和上下文切换成本极低,允许开发者以“一个请求一个线程”的同步编程模型来构建高吞吐量的服务。

文章图片
#java
    共 13 条
  • 1
  • 2
  • 请选择