发简信
IP属地：广东
-
构建并生成日期维度数据表
基于 MySQL 生成日期维度数据创建日期维度数据表DROP TABLE IF EXISTS `date_dim`;CREATE TABLE I...
-
Flink 在 Idea上提交任务到远程服务器
Flink自身提供了远程提交任务的环境,源码如下: 请查看StreamExecutionEnvironment 类中 createRemoteE...
-
Flink 本地运行日志配置
方法一: 使用 log4j.properties在 src/main/resources 中添加 log4j.properties 文件####...
-
使用 Imply 安装部署 Druid 集群并测试
下载 imply 安装包[root@node01 opt]# wget https://static.imply.io/release/impl...
-
Flume 采集 kafka 数据实时写入 Kudu
创建 JsonKuduOperationsProducer.java 用于处理 Json 字符串写入Kuduimport com.alibaba...
-
Cloudera Manager中安装部署Flink服务
制作Flink的Parcel包和csd文件 将Parcel包和manifest.json文件部署到httpd服务中[root@node01 ~]...
-
利用 StreamSets 实现将 SQL Server 中数据实时同步写入 Kudu
环境准备SQL Server 中创建测试库表CREATE DATABASE test;CREATE TABLE [dbo].[cdc_test]...
-
利用StreamSets实现MySQL中变化数据实时写入Kudu
环境准备开启MariaDB的Binlog日志修改/etc/my.conf文件，在配置文件[mysqld]下增加如下配置server-id=999...