logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

实例解析常用的java随机数生成办法

随机数是任何一种编程语言最基本的特征之一,在技术开发中应用很广泛,因为有时我们需要随机生成一个固定长度的数字、字符串亦或者是需要随机生成一个不定长度的数字、或者进行一个模拟的随机选择等。Java就为我们提供了最基本的工具,可以帮助开发者生成不同条件下需要的随机数。java中产生随机数和c的差不多,一般有两种随机数,一个是Math中random()方法,一个是Random类。不过不管是c还是java

文章图片
#java#python#开发语言
Doris基础介绍(一)

Apache Doris由百度大数据部研发(之前叫百度 Palo,2018年贡献到 Apache 社区后,更名为 Doris),在百度内部,有超过200个产品线在使用,部署机器超过1000台,单一业务最大可达到上百 TB。Apache Doris是一个现代化的MPP (Massively Parallel Processing,即大规模并行处理)分析型数据库产品。仅需亚秒级响应时间即可获得查询结果

文章图片
#大数据#mysql#sql +1
15款优秀的mysql管理工具与应用程序推荐

对于开发人员来说,mysql管理工具可以说是必不可缺的,它能帮助开发人员在许多方面支持包括PostgreSQL、MySQL、Redis、MongoDB等在内的多种数据库;同时还能提供包括触发器、事件、视图、数据备份、对象结构等多种功能。本文帮大家整理了15款优秀的MySQL管理工具和应用软件,大家可以从中选择一个,从而帮助你轻松快速完成工作

文章图片
#mysql#数据库
MaxWell实时监控Mysql并把数据写入到Kafka主题中

MaxWell实时监控Mysql把数据写入到Kafka主题中

文章图片
#mysql#kafka#zookeeper +4
解决:Flink向kafka写数据使用Producer精准一次(EXACTLY_ONCE)异常

Caused by: org.apache.kafka.common.KafkaException: Unexpected error in InitProducerIdResponse; The transaction timeout is larger than the maximum value allowed by the broker (as configured by transact

文章图片
#flink#kafka#大数据
Kafka架构深入(进阶介绍 三)

Kafka中消息是以topic进行分类的,生产者生产消息,消费者消费消息,都是面向topic的。topic是逻辑上的概念,而partition是物理上的概念,,该log文件中存储的就是producer生产的数据。Producer生产的数据会被不断追加到该log文件末端,且每条数据都有自己的offset。消费者组中的每个消费者,都会实时记录自己消费到了哪个offset,以便出错恢复时,从上次的位置继

文章图片
#kafka#架构#分布式
Kafka概述(基础介绍 一)

Kafka是一个分布式的基于发布/订阅模式的消息队列(Message Queue),主要应用于大数据实时处理领域。Kafka是一个分布式的数据流式传输平台。在流式计算中,Kafka一般用来缓存数据,Spark通过消费Kafka的数据进行计算。1.Apache Kafka是一个开源消息系统,由Scala写成。是由Apache软件基金会开发的一个开源消息系统项目。2.Kafka最初是由LinkedIn

文章图片
#kafka#分布式
当在使用flinksql的left join出现撤回流该如何解决?

在 Flink SQL 中,INNER JOIN、RIGHT JOIN 和 FULL OUTER JOIN 操作会因为数据变化而产生撤回流。这是为了确保流处理的结果一致性和准确性。在设计流处理应用时,需要考虑这些撤回流的影响,选择合适的 sink connector,例如 upsert-kafka,以正确处理这些操作

文章图片
#flink#kafka#大数据
scala-idea环境搭建及使用

scala在idea中环境部署,介绍架构以及使用

文章图片
#scala#idea#spark
到底了