发简信
IP属地：湖北
package com.ky.produce; import org.apache.kafka.clients.producer.KafkaPr...
Mysql离线安装文档 第一大部分 Linux离线安装mysql 要用到编译工具(cmake)以及库文件。 可以使用命令查看服务器上是否已经安装...
springboot如何访问windows本地和linux上的外部文件？首先编写一个WebMvcConfiguration配置文件类@Confi...
spark连接到hive首先要先配置3个文件，放到idea的resource目录下，如下：core-site.xml从集群环境中拉下来。hdfs...
// HBase.createTable(table, new String[]{family}, false);fina...
需要自定义一个sink组件，其实很简单，只需要继承ForeachWriter，实现相关的方法即可。class RedisSink extends...
springboot整合redis@Configuration@EnableCachingpublic class RedisConfig { ...
groupingBy和partitioningBy的区别我们先来看官方源码说明public static <T, K> Collector<T,...
手写编写一个工具类的接口程序：package com.ky.kafka.consumer; /** @Author: xwj @Date: 20...