IP属地：陕西
-
02-Flink流处理API
1.Environment 1.1 getExecutionEnvironment 创建一个执行环境，表示当前执行程序的上下文。 如果程序是独立...
-
01-Flink原理Flink运行时组件 作业管理器（JobManager）、资源管理器（ResourceManager）、任务管理器（TaskManager）， ...
-
Mysql数据通过Sqoop导入HDFS同步策略 Ø 全量表：存储完整的数据。 Ø 增量表：存储新增加的数据。 Ø 新增及变化表：存储新增加的数据和变化的数据。 Ø特殊表：只需要存储一...
-
Flume
file->flume->kafka Flume组件选型 1）Source （1）Taildir Source相比Exec Source、Spo...
-
Kafka
Kafka 压测 用Kafka官方自带的脚本，对Kafka进行压测。Kafka压测时，可以查看到哪个地方出现了瓶颈（CPU，内存，网络IO）。一...
-
hadoop模块HDFS存储多目录 1.在DataNode节点增加磁盘并进行挂载 2.在hdfs-site.xml文件中配置多目录，注意新挂载磁盘的访问权限问题...