Lv.3
Copy工程师
更多个人资料
175
成长值
1
关注
2
粉丝
+ 关注
私信
个人介绍
这个人很懒,什么都没有留下
感兴趣或擅长的领域
大数据
个人勋章
TA还没获得勋章~
成长雷达
160
12
0
0
3
个人资料
个人介绍
这个人很懒,什么都没有留下
感兴趣或擅长的领域
大数据
达成规则
以上满足
项可达成此勋章
博客
关注
粉丝
论坛
全部时间
全部时间
最近三天
最近一周
最近一月
全部
暂无专栏分类
【SparkSQL笔记】SparkSQL高并发读取数据库和存储数据到数据库
1. SparkSql 高并发读取数据库SparkSql连接数据库读取数据给了三个API://Construct a DataFrame representing the database table accessible via JDBC URL url named table and connection properties.Dataset<Row> jdbc(String url...
EI企业智能
Java
spark
可信智能计算服务 TICS
智能数据
Copy工程师
2022-01-25 14:21:26
5521
0
1
2022-01-25 14:21:26
999+
0
1
【SparkAPI JAVA版】JavaPairRDD——countByValue、countByValueApprox
JavaPairRDD的countByValue方法讲解 官方文档/** * Return the count of each unique value in this RDD as a map of (value, count) pairs. The final * combine step happens locally on the master, equivalent to...
EI企业智能
Java
spark
可信智能计算服务 TICS
智能数据
Copy工程师
2022-01-24 15:46:18
7075
0
0
2022-01-24 15:46:18
999+
0
0
【SparkAPI】JavaPairRDD——countByKey、countByKeyApprox
JavaPairRDD的countByKey方法讲解 官方文档/** * Count the number of elements for each key, collecting the results to a local Map. * * @note This method should only be used if the resulting map is expec...
EI企业智能
Java
spark
可信智能计算服务 TICS
智能数据
Copy工程师
2022-01-24 15:42:09
7164
0
0
2022-01-24 15:42:09
999+
0
0
【SparkAPI】countApprox、countApproxDistinct、countApproxDistinctByK
JavaPairRDD的context方法讲解 官方文档/** * Approximate version of count() that returns a potentially incomplete result * within a timeout, even if not all tasks have finished. * * The confidence is...
EI企业智能
spark
可信智能计算服务 TICS
智能数据
Copy工程师
2022-01-24 15:38:32
7251
0
0
2022-01-24 15:38:32
999+
0
0
【SparkAPI】flatMap、flatMapToDouble、flatMapToPair、flatMapValues
JavaPairRDD的flatMap方法讲解 官方文档/** * Return a new RDD by first applying a function to all elements of this * RDD, and then flattening the results. */ 说明首先将一个函数应用于该函数的所有元素,从而返回一个新的RDD然后将结果展平。 ...
EI企业智能
spark
可信智能计算服务 TICS
智能数据
Copy工程师
2022-01-24 15:36:27
3780
0
0
2022-01-24 15:36:27
999+
0
0
【Kafka笔记】Kafka API详细解析 Java版本(Producer API,Consumer API,拦截器等)
简介Kafka的API有Producer API,Consumer API还有自定义Interceptor (自定义拦截器),以及处理的流使用的Streams API和构建连接器的Kafka Connect API。 Producer APIKafka的Producer发送消息采用的是异步发送的方式。在消息发送过程中,涉及两个线程:main线程和Sender线程,以及一个线程共享变量Rec...
EI企业智能
Java
Kafka
可信智能计算服务 TICS
智能数据
Copy工程师
2022-01-24 15:31:16
7746
0
0
2022-01-24 15:31:16
999+
0
0
【Java】Java项目的绝对地址和相对地址问题以及ClassLoader
说明在java项目中我们经常会读取配置文件,但是文件的路径在获取时我们是怎么得到的?因为我总是忘记获取文件地址的方法,就在此记录一下 关于在获取路径的的绝对路径问题和相对路径问题在纯java代码里 我们一般都会用class.getResource(String name) 或者 class.getClassLoader().getResource(String name) 两种方法获取文件...
EI企业智能
Java
可信智能计算服务 TICS
智能数据
Copy工程师
2022-01-24 15:15:31
7760
0
0
2022-01-24 15:15:31
999+
0
0
【Java】读取/加载 properties配置文件的几种方法
说明在java项目中经常会使用到配置文件,这里就介绍几种加载配置文件的方法 目录结构我是使用的maven搭建的项目,resources其实就是在根目录下配置文件很简单 一、 基于ClassLoader读取配置文件注意:有局限性 只能在类路径下比较方便Properties properties = new Properties();// 注意这里的路径是根据根目录写的InputStream ...
EI企业智能
Java
可信智能计算服务 TICS
智能数据
Copy工程师
2022-01-24 15:13:51
11167
0
0
2022-01-24 15:13:51
999+
0
0
【SparkAPI JAVA版】JavaPairRDD——cache、persist、unpersist、getStorageL
说明这四个方法都和缓存有关,所以写在一块。 JavaPairRDD的cache方法讲解 官方文档说明Persist this RDD with the default storage level (MEMORY_ONLY). 中文含义cache就是在内存中缓存数据,其实也是使用的persist。使用非序列化的方式将RDD的数据全部尝试持久化到内存中,cache()只是一个transform...
EI企业智能
Java
spark
可信智能计算服务 TICS
智能数据
Copy工程师
2022-01-20 20:17:37
3990
0
0
2022-01-20 20:17:37
999+
0
0
【SparkAPI JAVA版】JavaPairRDD——cartesian(三)
JavaPairRDD的cartesian方法讲解 官方文档说明Return the Cartesian product of this RDD and another one, that is, the RDD of all pairs of elements (a, b) where a is in `this` and b is in `other`. 中文含义该函数返回的是Pair...
EI企业智能
Java
spark
可信智能计算服务 TICS
智能数据
Copy工程师
2022-01-20 20:16:11
7273
0
0
2022-01-20 20:16:11
999+
0
0
总条数:19
10
10
20
50
100
1
2
上滑加载中
https://www.baidu.com/s?ie=utf-8&f=3&rsv_bp=0&rsv_idx=1&tn=baidu&wd=sed%20%E6%9B%BF%E6%8D%A2%E5%AD%97%E7%AC%A6%E4%B8%B2&rsv_pq=c7db61a600035dc5&rsv_t=5e19yEsbV9N5fIvdlGRU
+ 关注