- @zuochang_liu
简介
该用户还未填写简介
擅长的技术栈
可提供的服务
暂无可提供的服务
final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();//指定使用eventTimeenv.setStreamTimeCharacteristic(TimeCharacteristic.EventTime);//1590894238,江西,高安,100//仅提取时间字段
一clickhouse简介1.1什么是clickhouseClickHouse是俄罗斯的Yandex于2016年开源的一个用于联机分析(OLAP:Online Analytical Processing)的列式数据库管理系统(DBMS:Database Management System)，简称CH ,主要用于在线分析处理查询（OLAP），能够使用SQL查询实时生成分析数据报告。ClickHou
1.下载安装包https://www.oracle.com/database/technologies/instant-client/downloads.html下载 instantclient-basic-linux.x64-11.2.0.4.0.zipinstantclient-sdk-linux.x64-11.2.0.4.0.zipin...
目录1.Hive基本概念2.Hive架构3.Hive安装部署4.Hive使用方式5.Hive建库建表与数据导入6.hive查询语法7.hive函数使用8 综合查询案例1.Hive基本概念1.1 Hive简介1.1.1 什么是HiveHive是基于Hadoop的一个数据仓库工具，可以将结构化的数据文件映射为一张数据库表，并提供类SQL查询功能。1...
distinct算子原理：贴上spark源码：/*** Return a new RDD containing the distinct elements in this RDD.*/def distinct(numPartitions: Int)(implicit ord: Ordering[T] = null): RDD[T] = withScope ...
参考自：http://spark.apache.org/docs/latest/running-on-yarn.html#preparations在spark on yarn模式下，/usr/local/spark-current2.3/conf下的spark-defaults.conf配置文件有一个spark.yarn.archive配置项1.如果没有配置#spark.yarn.a...
{"job": {"setting": {"speed": {"channel": 1},"errorLimit": {"record": 0,"percentage": 0.02}},"content": [{"reader": {"name": "oraclereader","pa...
http://scikit-learn.org/stable/modules/generated/sklearn.feature_selection.VarianceThreshold.html1.特征选择原因冗余：部分特征的相关度高，容易消耗计算性能噪声：部分特征对预测结果有负影响2.什么是特征选择特征选择就是单纯地从提取到的所有特征中选择部分特征作为训练集特征， 特征在选...
Traceback (most recent call last):File "pg2drg2pg.py", line 259, in post2DrgAndGetSqldata = json.dumps(i_params)File "/usr/local/python3/lib/python3.6/json/__init__.py", line 231, in dumps...
