三云时光

三云时光

Flink模拟延迟数据处理过程

使用侧边数据输出流输出严重迟到的数据 import org.apache.flink.api.common.eventtime.SerializableTimestampAssigner; impo


云哥  145  2022-10-08 阅读全文

elastic 客户端 ElasticHD 的使用

https://github.com/qax-os/ElasticHD/releases 下载 启动 ElasticHD -p localhost:9800


云哥  174  2022-04-25 阅读全文

kafka管理工具kafka-eagle安装

下载安装包 http://download.kafka-eagle.org/ 环境需要安装jdk这里不在 scp kafka-eagle-bin-2.1.0.tar.gz root@172.16.1.


云哥  267  2022-02-08 阅读全文

presto链接kafka数据源操作数据仓库以及表数据

presto链接kafka数据源的source数据仓库 创建kafka数据 vim /opt/env/presto/presto/etc/catalog/kafka.properties 内容如下:


云哥  329  2022-02-07 阅读全文

flink JDBC SQL 连接器

1、csv连接器 CREATE TABLE employee_information ( emp_id INT, name VARCHAR, dept_id INT ) WIT


云哥  530  2021-10-21 阅读全文

filebeat 启动方式

一、 在前台启动 ./filebeat -e -c filebeat.yml 二、在后端启动 nohup ./filebeat -e -c filebeat.yml &


云哥  7563  2020-03-05 阅读全文