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

JDK：1.8.0_211 Maven：3.6.0 IDEA：2018.3.5 (Ultimate Edition) Flink版本：1.9.2 关于正版IDEA 如何免费使用正版IDEA....

环境信息 以下是本次实战的环境信息，请确保您的Elasticsearch可以正常运行： 操作系统：Ubuntu 18.04.2 LTS JDK：1.8.0_1....

Fink DataSet 常用API 一、DataSource二、Transformation三、Sink Flink DataSet 常用API主要分为3部分： DataSource：是程....

TransportClient client = EsClient.getTransportClient(); try { IndicesSegmentsRequest request = new IndicesSegmentsReques

近些年，跨境电商市场在快速发展，国内很多自有品牌开始把目光转向海外市场。但是国内品牌出海遇到的问题就是，他们在国外市....

【自学elasticsearch7】结合es语法和java的HighLevelClient：match、term和bool 1.match搜索：一般用来模糊查询 match语句的....

近年来，奢侈品也不再是小众高净值资产人士“专属消费品”，随着奢侈品品牌在价格、定位上的进一步下沉，越来越多的普通消费....

1、分别创建两个文件夹(saftware、module) 注：在/opt文件下创建 ,saftware存放的是解压前的文件，module存放的是解压后的问....

import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable;

Cloud  Exchange已上线 KIC/USDT 交易对，详情如下： 币种名称：KIC (KIC) 币种全称：麒麟币 流通量：1,000,000 发行时间....

对于这个异常，要具体问题具体分析，我这个异常是因为在使用侧输出流的时候， outputTag, 向kafka发送数据的时候序列化用的....

需求：在node2节点上远程调用node4节点执行spark任务 在node2上编写脚本remote_exec_sparkpi.sh echo "开始执行任务"echo "....

centos使用systemctl stop firewalld.service（关闭防火墙命令）出现以下错误 Failed to stop firewalld.service: Unit fire....

本篇博客主要是对hadoop hdfs的故障排除，主要包括：NameNode故障的处理，集群安全模式和磁盘修复。有不好的地方欢迎各位大....

步骤 1、切换到Hadoop下面的etc 切换命令：cd /opt/module/hadoop-3.1.3/etc/hadoop/ 用 ll查看，下图标注的是需要配置的文....

大数据业务处理场景中，经常有这样的分析场景： A 任务：将收集的数据通过一系列的规则进行清洗，然后存入 Hive 表 a 中。 B....

问题描述 第一次出现是在操作完A号broker的重启后，13号broker的网络线程idle走低 一直到14号发起了一次重均衡（触发leader....

大数据产业是以数据生成、采集、存储、加工、分析、服务为主的战略性新兴产业。工信部近日发布的《“十四五”大数据产业发展....

在大数据BI分析需求中，经常会同时存在对大量历史数据进行分析和对时点数据进行实时分析的需求。这两种情况，所需要分析的数....

azkaban-web只能单点部署，因此考虑使用supervisor来启动azkaban-web，即使进程意外挂掉，也能自动重启。 supervisor的基本....