Hadoop使用学习笔记1.Hadoop安装与基本概念Hadoop发行版本地址(https://www.oschina.net/action/GoToLink?urlhttp%3A%2F%2Fhadoop.apache.org%2Freleases.html)1.1环境配置需

FlinkKafka整合实例1.使用工具IntelligIDEA新建一个maven项目，为项目命名为kafka01。2.我的pom.xml文件配置如下。<?xmlversion"1.0"encoding"UTF8"?<projectxmlns"http://maven.apache.org/POM/4

本文是根据ApacheFlink基础篇系列直播整理而成，由ApacheFlinkPMC戴资力与阿里巴巴高级产品专家陈守元共同分享。ApacheFlink系列入门教程每周更新一期，持续推送。▼预告 ▼自Flink1.0版本后变动最大又十分神秘的Flink1.9版本即将发布，Flink1.9

准备环境：3台linux虚拟主机，zookeeper安装包，zookeeper版本号是3.4.6，本文zookeeper安装在/usr/local目录下一、首先下载zookeepercd/usr/localwget http://apache.org/dist/zookeeper/zookeeper3.4.6/zookeeper3.4.6

在CentOS7.4（LAMP）上安装Apache，PHP和MariaDB在本教程中，我使用IP地址为192.168.10.10的主机这些设置可能会有所不同，因此您必须在适当的位置替换它们。版本说明Linux：CentOS7.4

一、reduceByKey作用    reduceByKey将RDD中所有K,V对中，K值相同的V进行合并，而这个合并，仅仅根据用户传入的函数来进行，下面是wordcount的例子。importjava.util.Arrays;importjava.util.List;importorg.apache.sp

Nging!Nging'slogo(https://github.com/admpub/nging/blob/master/public/assets/images/nginggear.png?rawtrue)Nging是一个网站服务程序，可以代替Nginx或Apache来搭建Web开发测试环境，并附带了实用的周边工具，例如：计

都知道Flink中的角色分为Jobmanager,TaskManger在启动脚本里面已经找到了jobmanager的启动类org.apache.flink.runtime.entrypoint.StandaloneSessionClusterEntrypoint(local模式更简单直接在Driver端的env.exection()直接启动了，有兴趣可以

导语：SQL作为现代计算机行业的数据处理事实标准，是目前最重要的数据处理接口之一，从传统的DBMS(如MySQL、Oracle)，到主流的计算框架（如spark，flink）都提供了SQL的解析引擎，因此想对sql进行精细化的操作，一定离不开SQLPars

作者：京东零售杨博文一、背景介绍京东广告围绕ApacheDoris建设广告数据存储服务，为广告主提供实时广告效果报表和多维数据分析服务。历经多年发展，积累了海量的广告数据，目前系统总数据容量接近1PB，数据行数达到18万亿行，日查询请求量8,000万次