用户组:游客
Flink提供了一个file system connector,可以使用DDL创建一个table,然后使用sql的方法将数据写入hdfs、local等文件系统,支持 ...
案例1:一个大数据实时数仓项目的demo 技术架构: kafka+Redis+Spark+ES 语言: Scala+Java+Shell 链接: https ...
有如下功能: 1.hive元数据信息的查看,包括表基本信息,数据库基本信息,字段信息,分区信息,索引信息等; 2.对hive元数 ...
说明: Class Dataserver将侦听端口7777上的连接,并将每秒两次将1-6的随机数发送到任何已连接的sockets 。 StateServer类 ...
技术路线 一图胜千言,如图是所使用的大数据组件,离线数仓的搭建涉及Kafka、Flume、Sqoop、Hive,实时路线包含Kafka、SparkS ...
代码下载:https://github.com/lyy289065406/hadoop-for-winx64 网盘下载: 链接: https://pan.baidu.com/s/1f2OeLJ4hHhvL ...
版本说明: Spark:2.3/2.4 代码下载: 1 Structured内置的输入源 Source 官网文档:http://s ...
kafka核心Api kafka有四个核心API 应用程序使用producer API发布消息到1个或多个topic中。 应用程序使用consumer API来 ...
本版积分规则 发表帖子
查看 »