区块链

1、运行mr程序出错　　connecting to resoucemanager 　　retrying …. 　　retrying ….. 　　原因是没有启…

1、下载源码，通过编译源码安装 　 tar -zxvf  /home/zfll/soft/snappy-1.1.2.tar.gz     c…

读取数据库数据和ElasticSearch数据进行连接处理 import java.util.HashMap; import java.util.List; import java…

1、Spark Streaming简介 　　官方网站解释：http://spark.apache.org/docs/latest/streaming-programming-gui…

废话不多说，直接上代码 package com.demo; import java.util.List; import java.util.regex.Pattern; impor…

写一个小小的Demo测试一下Spark提交程序的流程 Maven的pom文件 <properties> <maven.compiler.source>1.7…

首先是需要将hadoop的配置文件core-site,xml和hdfs-site.xml 拷贝到Spark conf目录下 然后启动提交即可 spark-submit /…

关于sparkStreaming的测试Drools框架结合版 package com.dinpay.bdp.rcp.service; import java.math.BigDec…

1、spark是什么？ 　　快速，通用，可扩展的分布式计算引擎 2、弹性分布式数据集RDD 　　RDD（Resilient Distributed Dataset）叫做分布式数据集…

spark单个master节点的提交方式 spark-submit –master spark://hadoop-namenode-02:7077 / –class com.d…