elasticsearch|大数据|elasticsearch的api部分实战操作以及用户和密码的管理
只在master节点生成，然后拷贝到其它节点即可，scp命令或者什么其它的方式都可以，不得在其它节点自己生成。
【Flink-Kafka-To-Hive】使用 Flink 实现 Kafka 数据写入 Hive
需求描述：1、数据从 Kafka 写入 Hive。2、相关配置存放于 Mysql 中，通过 Mysql 进行动态读取。3、此案例中的 Kafka 是进行了 Kerberos 安全认证的，如果不需要自行修改。4、Flink 集成 Kafka 写入 Hive 需要进行 checkpoint 才能落盘至
hive中map相关函数总结
具体来说，str_to_map 函数会将一个由键值对组成的字符串解析成一个 Map 对象，其中键和值之间使用指定的分隔符进行分隔。其中，str 是要转换的字符串，delimiter1 是键值对之间的分隔符，delimiter2 是键和值之间的分隔符。第三种sql,maps字段的类型是map;给出一组
Zookeeper断网重连事件回调源码分析
不积跬步，无以至千里。
Spark SQL实战(08)-整合Hive
统计每个人爱好的个数* pk：3* 1）定义函数* 2）注册函数* 3）使用函数。
华为云耀云服务器L实例-大数据学习-hadoop 正式部署
它的设计理念使得它适用于在常规硬件上搭建的大规模集群，并为用户提供了一种可靠、高效、可扩展的大数据处理解决方案。Hadoop 具有良好的可扩展性，可以轻松地在集群中添加新的节点以处理不断增长的数据量。hadoop 部署的准备工作基本完成，为了确保安全， hadoop 系统不以 root 用户启动，我
RabbitMq - windows 系统上安装
在安装rabbitmq 之前，我们需要了解 RabbitMQ 和 Erlang/OTP 版本对应关系：官网地址：https://www.rabbitmq.com/which-erlang.html。
springboot/java/php/node/python基于Java的比亚迪汽车大数据评分系统【计算机毕设】
通过对客户数据的分析，可以发现客户的喜好、需求和痛点，为产品研发提供有针对性的建议。基于Java的比亚迪汽车大数据评分系统的建立将有助于提升比亚迪的整体竞争力，实现可持续发展。为了更好地了解客户需求，提高产品竞争力，比亚迪决定建立一个基于Java的大数据评分系统，通过对客户数据的分析，为产品研发、市
flink中值得监控的几个指标
flink监控指标
大数据编程实验四：SparkStreaming编程
大数据编程实验，学习有关Spark Streaming的基本编程方法和利用Spark Streaming处理来自不同数据源的数据以及DStream的各种转换、DStream的数据输出保存到文本文件或MySQL数据库中操作。
Kafka的简介及架构
消息队列是指数据在一个容器中,从容器中一端传递到另一端过程;Kafka是一款消息队列中间件产品,来源于领英公司,后期贡献给了Apache,目前是Apache旗下的顶级开源项目,采用语言是Scala;本文介绍了Kafka的的基本架构,以及Kafka使用中的常用shell命令,以及Kafka的Pytho
Hadoop精选18道面试题(附回答思路)
Hadoop精选18道面试题
Kafka中的max-poll-records和listener.concurrency配置
Kafka中的max-poll-records和listener.concurrency配置
大数据/人工智能/EXCEL/R语言精品教材推荐
通过采用任务式、项目式等多种教材编写模式，教材内容注重实践能力培养，贴合教师教学实际和学生实践实验，已经被1500余所院校选用为教材。
Hive实战：分科汇总求月考平均分
上传数据到hdfs、从hdfs加载数据到hive
Spark SQL
Spark SQL是Spark中用于结构化数据处理的组件，它提供了一种通用的访问多种数据源的方式，可以访问的数据源包括Hive、Avro、Parquet、ORC、JSON和JDBC等。
Flink｜《Flink 官方文档 - DataStream API - 状态与容错 - 使用状态》学习笔记
例如，Kafka Connector 是 Flink 中就使用了算子状态，Kafka consumer 的每个并行实例维护了 topic partitions 和偏移量的 map 作为它的算子状态。需要注意的是：因为在开启 TTL 特性后，状态上次的修改时间会和数据一起保存在 state backe
Hive字符串截取函数substr详解
Hive中的substr函数可以用来截取字符串的一部分，并返回截取后的结果。该函数有三个参数：第一个参数是要截取的字符串，第二个参数是截取的起始位置（从1开始），第三个参数是截取的长度。注意，如果截取的长度超过了字符串的实际长度，Hive会返回整个字符串。举个例子，假设有一个字符串。
ZooKeeper 高级应用
ZooKeeper 是 Apache 软件基金会的一个软件项目，它为大型分布式计算提供开源的分布式配置服务同步服务和命名注册，在架构上，通过冗余服务实现高可用性（CP）。ZooKeeper 的设计目标是将那些复杂且容易出错的分布式一致性服务封装起来，构成一个高效可靠的原语集，并以一系列简单易用的接口
你真的了解Zookeeper吗？
在分布式系统中，Zookeeper是一款非常重要的分布式协调服务框架。本文将深入介绍Zookeeper的基本概念、核心特性，并通过实际案例展示Zookeeper在分布式系统中的应用。Zookeeper是一种分布式协调服务，它提供了一个简单的文件系统命名空间和一个基于观察者模式的分布式服务。其主要作用
