發(fā)簡信
IP屬地：廣東
-
構(gòu)建并生成日期維度數(shù)據(jù)表
基于 MySQL 生成日期維度數(shù)據(jù)創(chuàng)建日期維度數(shù)據(jù)表DROP TABLE IF EXISTS `date_dim`;CREATE TABLE I...
-
Flink 在 Idea上提交任務(wù)到遠(yuǎn)程服務(wù)器
Flink自身提供了遠(yuǎn)程提交任務(wù)的環(huán)境,源碼如下: 請(qǐng)查看StreamExecutionEnvironment 類中 createRemoteE...
-
Flink 本地運(yùn)行日志配置
方法一: 使用 log4j.properties在 src/main/resources 中添加 log4j.properties 文件####...
-
使用 Imply 安裝部署 Druid 集群并測試
下載 imply 安裝包[root@node01 opt]# wget https://static.imply.io/release/impl...
-
Flume 采集 kafka 數(shù)據(jù)實(shí)時(shí)寫入 Kudu
創(chuàng)建 JsonKuduOperationsProducer.java 用于處理 Json 字符串寫入Kuduimport com.alibaba...
-
Cloudera Manager中安裝部署Flink服務(wù)
制作Flink的Parcel包和csd文件 將Parcel包和manifest.json文件部署到httpd服務(wù)中[root@node01 ~]...
-
利用 StreamSets 實(shí)現(xiàn)將 SQL Server 中數(shù)據(jù)實(shí)時(shí)同步寫入 Kudu
環(huán)境準(zhǔn)備SQL Server 中創(chuàng)建測試庫表CREATE DATABASE test;CREATE TABLE [dbo].[cdc_test]...
-
利用StreamSets實(shí)現(xiàn)MySQL中變化數(shù)據(jù)實(shí)時(shí)寫入Kudu
環(huán)境準(zhǔn)備開啟MariaDB的Binlog日志修改/etc/my.conf文件，在配置文件[mysqld]下增加如下配置server-id=999...