
一、安装kafka 官网安装kafka http://kafka.apache.org/downloads (安装2.8版本的,其他版本可能会出现各种问题。。。) ....
需求 在数仓游戏产品中,用户粘性指标很重要。请看下面数据结构,统计出最近一月内连续3天登陆的用户。请根据下边数据创建....
当前hive社区已到3.1.2版本,较多hive用户还不太清楚在0.14版本之后开始已支持事务,对于批处理任务中要用到update/delete/m....
{"movie":"1193","rate":"5","timeStamp":"978300760","uid":"1"} 1、创建一张表,表中只有一个字段,这一个字段就是一条jso....
我不去想是否能够成功 既然选择了Java 便只顾风雨兼程 我不去想能否征服Kafka集群 既然钟情于Java 就勇敢地追随千锋 我不去....
一、去https://www.elastic.co/downloads/ 下载 ElasticSearch: 6.0.1 Logstash: 6.0.1 ....
1、简单转化算子(map,flatmap,filter这些)datastream和keyedStream都可以有,但是datastream没有聚合算子,只有keyedStream....
现在页面上显示的都是大数据学科下的标签列表,需求时点击左侧导航标签按钮页面显示所有学科的标签列表 点击之前: ....
1工具 postman 、 2 请求方法 Post 3 URL Elasticsearch地址/索引名称/_search 4 简单说明 ....
一、linux版本:lsb_release -a 二、官网地址:https://zookeeper.apache.org/ 我们选择稳定版:3.6.3 三、安装JDK zookee....
在spark中如果使用的是scopt技术传递参数,则scopt参数在ds中的传递位置和格式如下:
本文前置知识 云服务器的基本使用Docker 基本命令Spring Boot Docker 搭建 RabbitMQ 环境 为了方便,采用 Docker 进行安装,....
1.创建maven项目,引入pom依赖 ```xml org.apache.spark spark-core_2.12 3.0.0 net.alchim31.maven scala-maven-plugi....
文章目录 前言一、Zookeeper的Java客户端1.Zookeeper分布式配置中心使用2.Zookeeper的JavaAPI使用 二、使用Curator客户端1.....
文章目录 一、kafka的下载二、kafka、zookeeper的开启三、kafka、zookeeper的关闭四、可能会遇到的问题 一、kafka的下载 下....
1、mybatis整合spring技术 2、dubbo是个啥 3、flink基本知识和学习flink实时数仓 4、flink内核 5、spring和spring mvc 6、基....
(1)启动集群 (2)查看在线节点数 调用Hadoop的示例jar包 提交任务 终断任务 (1)提交任务 (2)中断....
1.解压jdk到src文件夹下 tar zxvf /h3cu/jdk-8u311-linux-x64.tar.gz -C /usr/local/src/ 2.修改jdk1.8.0_311 名字为jdk mv ....
我们知道在Spark中RDD是一个特别重要的概念,可以说spark所有的逻辑都需要依赖RDD,这篇我们简单聊聊Spark中的RDD,spark中R....
消息队列服务 RabbitMQ 消息发布消费为什么选择RabbitMQmq优点相对缺点常用消息队列服务对比 消息队列RabbitMQ基本对象交换....