大数据知识_大数据学习笔记

datax运行job案例时报错“位置信息错误，您提供的配置文件[/opt/module/datax/plugin/reader/._hdfsreader/plugin.json]不存....

省时查报告-专业、及时、全面的行研报告库 省时查方案-专业、及时、全面的营销策划方案库 【免费下载】2022年1月份热门报告....

【异常】：org.apache.zookeeper.KeeperException$ConnectionLossException: KeeperErrorCode = ConnectionLoss for / 问题....

Union多个类型一样的DataStream合并到一起，使用同样的方式进行处理，当多个DataStream都做一个相同的操作时可以使用 ....

需求： 需要在字段：mje_fore_qty、mjy_fore_qty找出最大值和最小值 思考： hive中是有max()和min()函数的 但是，那是....

文章目录 1、Table is in readonly mode (zookeeper path: /clickhouse/tables/iov/t_fault/2)2、Replica /clickhouse/table....

一、简述 select max_pt('tableName')对于分区的表，此函数返回该分区表的一级分区的最大值，按字母排序，且该分....

近几年，因为航空票价的改革，越来越多的人享受到了乘坐飞机的便利。如果赶上什么冷门的时间与地点，机票甚至比火车票都要便....

文章目录 写在前面如何保证消息100%不丢失生产端可靠性投递事务消息机制confirm消息确认机制消息持久化消息入库 消费端可....

大家好，我是陈哈哈，北漂五年。相信大家和我一样，都有一个大厂梦，作为一名资深Java选手，深知面试重要性，接下来我准备用....

一、NACK发送端packet data和FEC的packet data push到packet队列函数调用栈 PacingController::ProcessPackets()->PacketRou....

文章目录 1.场景1 1.1 概述 1.2. 源码 1.2.1 loadClassWithoutExceptionHandling 1.2.2 f....

钢铁行业作为国家重要的基础工业之一，在营销管理方面有着明显不同于其他行业的特点，特别是相对于消费品业而言，其特性更为....

Flink CDC 系列文章： 《Flink CDC 系列（1）—— 什么是 Flink CDC》 《Flink CDC 系列（2）—— Flink CDC 源码编译》 《F....

Java笔试题 1、Hadoop几大核心组成别为？2、关于Hadoop，以下说法正确的是？3、Kafka消息队列中的broker的作用是？4、Kafka....

工业机器人的研发、制造和应用是衡量一个国家创新能力和高端制造业水平的重要标志。随着智能制造需求的不断提升，全球工业机....

代码 远程通过xshell连接服务器，打开对应的脚本文件(vim xxx.sh) 编写对应脚本，我们是通过presto连接hive数据源，然后....

一直以来，由于生鲜食材具有其特殊性，价格体系管理难，损耗大是生鲜配送行业难以攻克的难题，面对当下“数字化浪潮”的兴起....

如今，互联网技术、云计算的发展呈现出日新月异的特征，“大数据”这一概念越来越深入人心、为人们所熟知。各行各业企业的数....

前言 这篇文章主要聊2个话题：服务启动原理及消费者与提供者则交互过程 服务启动原理 dubbo支持2种启动方式：脚本启动（不需....