在 Flink 1.10 的 Table API 和 SQL 中，表支持的格式有四种： CSV Format JSON Format Apache Avro Format Old CSV Format 官网地址如下：https://ci.apache.org/projects/flink/flink ...
分类：
数据库 时间：
2020-04-12 16:05:50
阅读次数：
287
public class AvroDeserializationSchema<T> implements DeserializationSchema<T> { private static final long serialVersionUID = 1L; private final Class<T ...
分类：
其他好文 时间：
2020-03-31 22:52:42
阅读次数：
94
from：https://blog.csdn.net/zhanglh046/article/details/78505038 一 Spark SQL运行架构Spark SQL对SQL语句的处理和关系型数据库类似，即词法/语法解析、绑定、优化、执行。Spark SQL会先将SQL语句解析成一棵树，然后 ...
分类：
数据库 时间：
2020-03-08 16:00:50
阅读次数：
107
Flume: source: Avro是一个轻量级的rpc框架，可以解决单点故障。 Thrift少用。 Exec:类似 tail -f spooling Directory:目录 Tail dir多个目录里面动态变化的数据 kafka sosurce netcat source 图中红色用法较多。 ...
分类：
Web程序 时间：
2020-03-03 10:33:19
阅读次数：
61
电脑修好了，但之前落下的几天博客确实没啥补的劲头，今天先写一份报告吧。 实验内容和要求 安装 Flume 安装成功。 使用 Avro 数据源测试 Flume 配置文件 启动flume agent a1 创建指定的日志文件 客户端传输 传输完成 使用 netcat 数据源测试 Flume 创建exam ...
分类：
其他好文 时间：
2020-02-13 22:48:41
阅读次数：
83
昨天的下载完成后运行报错，应该是下载的spark版本和教程不符合，然后pom.xml文件中的spark-core内容而应该不同，但是我还是用的教程导致，现在正在尝试安装教程给的网站找的内容又下载中，不知道这次又要下载多久。（我下载的是spark 2.4.4） <?xml version="1.0" ...
分类：
其他好文 时间：
2020-02-06 01:23:10
阅读次数：
63
今天完成了实验六 安装了Flume，Flume是Cloudera提供的一个高可用的，高可靠的，分布式的海量日志采集、聚合和传输的系统，Flume支持在日志系统中定制各类数据发送方，用于收集数据；同时，Flume提供对数据进行简单处理，并写到各种数据接受方（可定制）的能力。 2. 使用 Avro 数据 ...
分类：
其他好文 时间：
2020-02-05 23:06:48
阅读次数：
83
1.环境 CDH 5.16.1 Spark 2.3.0 cloudera4 Kafka 2.1.0+kafka4.0.0 2.Log4j—— Flume 2.1 Log4j 产生日志 ~~~ import org.apache.log4j.Logger; / @ClassName LoggerGen ...
分类：
Web程序 时间：
2020-02-04 00:37:16
阅读次数：
104
历经大约3个月时间，Apache Hudi 社区终于发布了0.5.1版本，这是Apache Hudi发布的第二个Apache版本，该版本中一些关键点如下 版本升级 将Spark版本从2.1.0升级到2.4.4 将Avro版本从1.7.7升级到1.8.2 将Parquet版本从1.8.1升级到1.10 ...
分类：
Web程序 时间：
2020-02-01 10:31:42
阅读次数：
386
工作方式 Flume-og采用了多Master的方式。为了保证配置数据的一致性，Flume引入了ZooKeeper，用于保存配置数据，ZooKeeper本身可保证配置数据的一致性和高可用，另外，在配置数据发生变化时，ZooKeeper可以通知Flume Master节点。Flume Master间使 ...
分类：
Web程序 时间：
2020-01-20 14:26:47
阅读次数：
98
