Hadoop - Code notes

flink的时间语义(附示例代码) Flink

Flink支持三种时间语义：Processing Time、Event Time和Ingestion Time。

标签: Flink Scala

Linh 发布于 2023-3-19 12:38

评论(0) 浏览(11)

使用Maxwell时，对MySQL进行配置 Maxwell

配置MySQL的二进制日志（binlog）：Maxwell是通过监控MySQL的binlog来获取数据库更改信息的。因此，需要在MySQL的配置文件中启用binlog，配置binlog格式以及binlog位置等参数。例如，在MySQL的配置文件my.cnf中添加以下内容：

Linh 发布于 2023-3-18 21:58

评论(0) 浏览(7)

Hive添加hbase外表 Hive

如果大量的数据已经存放再hbase上面，需要对已经存在的数据进行数据分析处理，那么phoenix并不合适做特别复杂的SQL处理，此时可以使用hive映射hbase的表格，之后写HQL进行分析处理。

标签: Hadoop Hive Hbase

Linh 发布于 2023-3-14 19:52

评论(0) 浏览(16)

Flume采集端口信息输出到Kafka和hdfs Flume

Flume采集端口信息输出到Kafka和hdfs

标签: Hadoop Kafka Flume

Linh 发布于 2023-3-12 20:17

评论(0) 浏览(16)

Flink报错could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInformation[Int] Flink

could not find implicit value for evidence parameter of type org.apache.flink.api.common.typeinfo.TypeInformation[Int]

标签: Flink Scala

Linh 发布于 2023-3-8 15:44

评论(0) 浏览(20)

hadoop全分布式配置文件 Hadoop

hadoop全分布式配置文件

标签: Hadoop 集群

Linh 发布于 2023-2-28 16:57

评论(0) 浏览(45)

Hive配置文件 Hive

Hive配置文件

标签: Hive

Linh 发布于 2023-2-28 12:04

评论(0) 浏览(35)

Kafka的一些基本操作 Kafka

Kafka的一些基本命令操作

标签: Hadoop Linux Kafka

Linh 发布于 2023-2-21 22:01

评论(0) 浏览(36)

Hadoop镜像下载地址 Hadoop

Hadoop

标签: Hadoop

Linh 发布于 2023-2-17 11:16

评论(0) 浏览(29)

Hadoop伪分布式配置文件 Hadoop

Hadoop伪分布式配置文件

标签: Hadoop 伪分布式

Linh 发布于 2023-2-16 20:19

评论(0) 浏览(63)