单机模式 代码片段安装 pip install redisimport redisr = redis.Redis(host='192.168.1.3', port=6188,db=0,decode_responses=True)list_keys = r.keys("DEMO_xx_*")for key in list_keys:r.delete(key)集群模式 代...

示例：demo数据userIdplace1001北京1001上海spark建立的虚拟表 userPlaceView。根据用户ID进行分组，用collect_set(place)获取place信息。spark sql 函数查询 地址Dataset<Row> resultDataSet = SqlContext.sql("select userId, collect_set(place)

./zkCleanup.sh 数据目录 -n 5参数说明数据目录：/data/zkdata5保留快照日志的数量

基础镜像拉取此处演示采用网易云提供的centos基础镜像作为演示model。将已有的jdk包打到docker镜像中。此处演示jdk版本jdk-8u201-linux-x64.tar.gz拉取镜像docker pull hub.c.163.com/public/centos:7.2-tools查看镜像docker images结果G:\dockertest\jdk>docke...

curl -H "Content-Type:application/json" -X POST -d '{"service":10,"partId":"2354325235"}' 'http://www.baidu.ad/getapi'

kafka与storm的集成步骤storm采用最新版本1.1.1

JTS简介JTS提供了一套操作几何向量的java类库早期版本 com.vividsolutions，已废弃不在维护现在版本 com.locationtech.jts 由eclipse开源基金会托管代码类库地址JTS GitHub代码包结构核心模块:jts-core - 核心类库:提供geometry model, operations, algorithms, and spatial data s