發(fā)簡信
IP屬地：湖北
package com.ky.produce; import org.apache.kafka.clients.producer.KafkaPr...
Mysql離線安裝文檔 第一大部分 Linux離線安裝mysql 要用到編譯工具(cmake)以及庫文件。 可以使用命令查看服務(wù)器上是否已經(jīng)安裝...
springboot如何訪問windows本地和linux上的外部文件？首先編寫一個WebMvcConfiguration配置文件類@Confi...
spark連接到hive首先要先配置3個文件，放到idea的resource目錄下，如下：core-site.xml從集群環(huán)境中拉下來。hdfs...
// HBase.createTable(table, new String[]{family}, false);fina...
需要自定義一個sink組件，其實很簡單，只需要繼承ForeachWriter，實現(xiàn)相關(guān)的方法即可。class RedisSink extends...
springboot整合redis@Configuration@EnableCachingpublic class RedisConfig { ...
groupingBy和partitioningBy的區(qū)別我們先來看官方源碼說明public static <T, K> Collector<T,...
手寫編寫一個工具類的接口程序：package com.ky.kafka.consumer; /** @Author: xwj @Date: 20...