# bigdata-demos **Repository Path**: gitofphb/bigdata-demos ## Basic Information - **Project Name**: bigdata-demos - **Description**: hello - **Primary Language**: Unknown - **License**: Not specified - **Default Branch**: master - **Homepage**: None - **GVP Project**: No ## Statistics - **Stars**: 0 - **Forks**: 0 - **Created**: 2018-05-13 - **Last Updated**: 2026-09-28 ## Categories & Tags **Categories**: Uncategorized **Tags**: None ## README # bigdata-demos #### 项目介绍 #### 目录结构 ``` . ├── core │   ├── architecture │   │   ├── doc │   │   │   ├── 分布式理论 │   │   │   ├── 架构模式 │   │   │   │   ├── 架构类型.txt │   │   │   │   └── 微服务 │   │   │   ├── 领域问题 │   │   │   │   ├── 分布式 │   │   │   │   ├── 分布式方案.txt │   │   │   │   ├── 复杂业务逻辑抽象.txt │   │   │   │   └── 用户画像.km │   │   │   ├── 设计原则 │   │   │   │   ├── help.md │   │   │   │   ├── 高并发 │   │   │   │   ├── 高可用 │   │   │   │   ├── 设计原则.km │   │   │   │   └── 业务设计 │   │   │   ├── 实验报告 │   │   │   └── 系统分类 │   │   │   ├── ERP │   │   │   ├── sohpon │   │   │   ├── 博客 │   │   │   ├── 电商 │   │   │   ├── 日志系统 │   │   │   ├── 推荐系统 │   │   │   ├── 微博 │   │   │   └── 运维管理 │   ├── 编译原理 │   │   ├── PlayWithCompiler │   │   ├── 编译器实现 │   │   │   └── 编译器.md │   │   ├── 编译原理.km │   │   ├── 编译原理.txt │   │   ├── 后端技术 │   │   │   ├── 代码优化 │   │   │   │   └── 代码优化.md │   │   │   └── 目标代码生成 │   │   │   └── 目标代码生成.md │   │   ├── 基础理论 │   │   │   ├── 编译理论.km │   │   │   ├── 文法 │   │   │   │   ├── 分类.md │   │   │   │   ├── 文法.md │   │   │   │   └── 语言.md │   │   │   └── 语言特性 │   │   │   └── 程序语言基本成分.md │   │   ├── 其它 │   │   │   └── faq │   │   │   └── list0.md │   │   └── 前端技术 │   │   ├── 词法分析 │   │   │   └── 词法分析.md │   │   ├── 前端技术.km │   │   └── 语法分析 │   │   └── 语法分析.md │   ├── 操作系统 │   │   ├── os.km │   │   ├── os.png │   │   ├── pic │   │   │   ├── ext2文件系统结构.webp │   │   │   ├── linux工作流程.png │   │   │   ├── os图谱.jpeg │   │   │   ├── 段页管理.webp │   │   │   ├── 多级索引块.webp │   │   │   ├── 二级分页.webp │   │   │   ├── 分段地址映射.webp │   │   │   ├── 分页寻址.webp │   │   │   ├── 空闲表法.webp │   │   │   ├── 空闲链表法.webp │   │   │   ├── 连续空间存放.webp │   │   │   ├── 链式索引块.webp │   │   │   ├── 目录哈希表格式存放.webp │   │   │   ├── 内存分段寻址.webp │   │   │   ├── 内存分页.webp │   │   │   ├── 内存管理演进.png │   │   │   ├── 软链接.webp │   │   │   ├── 四级页表.webp │   │   │   ├── 索引存放.webp │   │   │   ├── 文件存储.webp │   │   │   ├── 文件系统架构.webp │   │   │   ├── 显式链接存放.webp │   │   │   ├── 线程混合态实现.png │   │   │   ├── 线程切换到内核态.png │   │   │   ├── 虚拟内存寻址.png │   │   │   ├── 页换入换出.webp │   │   │   ├── 隐式链表存放.webp │   │   │   └── 硬链接.webp │   │   ├── 操作系统.md │   │   ├── 概述 │   │   │   ├── learning-pratice │   │   │   │   ├── linux │   │   │   │   ├── README.md │   │   │   │   ├── redis │   │   │   │   ├── thrift │   │   │   │   └── zookeeper │   │   │   ├── 概述.txt │   │   │   └── 趣谈os.txt │   │   │   └── info │   │   ├── 计算机操作系统.md │   │   ├── 进程管理 │   │   │   ├── pic │   │   │   │   ├── 3态模型.png │   │   │   │   ├── 5态模型.png │   │   │   │   ├── 7态模型.png │   │   │   │   ├── 7态模型.webp │   │   │   │   ├── ipc模型.png │   │   │   │   ├── LWP模型.webp │   │   │   │   ├── 共享内存.png │   │   │   │   ├── 内核线程模型.webp │   │   │   │   ├── 信号生命周期.png │   │   │   │   └── 用户级线程模型.webp │   │   │   ├── 进程 │   │   │   │   └── 进程.md │   │   │   ├── 进程调度 │   │   │   │   └── 进程调度.md │   │   │   ├── 进程管理.km │   │   │   ├── 进程管理.md │   │   │   ├── 进程管理.png │   │   │   ├── 进程通信 │   │   │   │   └── 进程通信.md │   │   │   └── 线程 │   │   │   ├── 死锁 │   │   │   ├── 同步 │   │   │   └── 线程.md │   │   ├── 内存管理 │   │   │   ├── 段式内存管理 │   │   │   │   └── 段式内存管理.md │   │   │   ├── 分区存储管理 │   │   │   │   └── 分区.md │   │   │   ├── 基本概念.txt │   │   │   ├── 内存管理1.png │   │   │   ├── 内存管理.km │   │   │   ├── 内存管理.md │   │   │   └── 页式内存管理 │   │   │   └── 页式内存管理.md │   │   ├── 其它 │   │   │   ├── 调度.md │   │   │   ├── 系统参数.a.md │   │   │   └── 系统参数.md │   │   ├── 设备管理 │   │   │   ├── 缓存技术 │   │   │   │   ├── DMA.txt │   │   │   │   ├── spooling.txt │   │   │   │   └── 通道.txt │   │   │   ├── 设备管理.md │   │   │   └── 中断.md │   │   └── 文件管理 │   │   ├── IO │   │   │   ├── IO.md │   │   │   ├── IO函数 │   │   │   ├── IO模型 │   │   │   └── 零拷贝 │   │   ├── pic │   │   │   ├── IO多路复用.webp │   │   │   ├── IO复用.jpeg │   │   │   ├── IO模型比较.jpeg │   │   │   ├── 非阻塞IO.webp │   │   │   ├── 非阻塞.jpeg │   │   │   ├── 零拷贝数据传输.png │   │   │   ├── 网络包发送流程.png │   │   │   ├── 无零拷贝数据传输.png │   │   │   ├── 信号驱动.jpeg │   │   │   ├── 异步IO.webp │   │   │   ├── 异步.jpeg │   │   │   ├── 阻塞IO.webp │   │   │   └── 阻塞.jpeg │   │   ├── source.md │   │   ├── 文件.md │   │   ├── 文件管理.km │   │   ├── 文件管理.md │   │   └── 文件系统 │   │   ├── ext2.md │   │   └── 文件系统.md │   ├── 计算机网络 │   │   ├── faq │   │   │   ├── url到网页.md │   │   │   ├── 超时.md │   │   │   └── 网络穿透.md │   │   ├── net.md │   │   ├── pic │   │   │   ├── dns解析.png │   │   │   ├── http数据包.png │   │   │   ├── IP报文.png │   │   │   ├── mac报文.png │   │   │   ├── mac地址表.png │   │   │   ├── tcp报文.png │   │   │   ├── tcp分割数据1.png │   │   │   ├── tcp分割数据2.png │   │   │   ├── tcp数据包.png │   │   │   ├── udp头部.png │   │   │   ├── 互相扒皮.png │   │   │   ├── 路由转发.png │   │   │   ├── 三次握手.png │   │   │   ├── 三次握手优化.png │   │   │   ├── 数据传输优化.png │   │   │   ├── 四次握手优化.png │   │   │   ├── 网卡部分.png │   │   │   ├── 网络包发送流程.png │   │   │   └── 协议栈.png │   │   ├── 传输层 │   │   │   ├── pic │   │   │   │   ├── TCP报文格式.png │   │   │   │   ├── 三次握手.png │   │   │   │   ├── 四次握手.png │   │   │   │   ├── 状态机.png │   │   │   │   └── 状态迁移.png │   │   │   ├── TCP │   │   │   │   ├── tcp.km │   │   │   │   ├── TCP.md │   │   │   │   ├── 三大问题.md │   │   │   │   └── 握手问题.md │   │   │   ├── UDP.md │   │   │   ├── 传输层.km │   │   │   └── 传输层.md │   │   ├── 计算机网络.md │   │   ├── 数据链路层 │   │   │   ├── 基本问题 │   │   │   │   ├── 差错检测.txt │   │   │   │   ├── 封装成帧.txt │   │   │   │   └── 透明传输.txt │   │   │   ├── 设备.txt │   │   │   ├── 数据链路层.md │   │   │   └── 协议 │   │   │   ├── CSMA-CD.txt │   │   │   └── PPP.txt │   │   ├── 网络.km │   │   ├── 网络安全 │   │   │   ├── 安全协议 │   │   │   │   ├── https │   │   │   │   ├── 传输层.txt │   │   │   │   ├── 网络层.txt │   │   │   │   └── 应用层.txt │   │   │   ├── 保密 │   │   │   │   ├── 保密.txt │   │   │   │   └── 数字签名.png │   │   │   ├── 访问控制 │   │   │   │   └── 访问控制.txt │   │   │   └── 网络安全.md │   │   ├── 网络安全.md │   │   ├── 网络层 │   │   │   ├── ip多播 │   │   │   │   ├── ICMP.txt │   │   │   │   ├── ip多播.txt │   │   │   │   └── 多播路由选择协议.txt │   │   │   ├── pic │   │   │   │   ├── 单臂路由.webp │   │   │   │   └── 三层交换机.webp │   │   │   ├── 私有地址通信 │   │   │   │   ├── nat.txt │   │   │   │   └── vpn.txt │   │   │   ├── 网络层.md │   │   │   ├── 协议 │   │   │   │   ├── ICMP.md │   │   │   │   ├── ICMP报文类型.png │   │   │   │   ├── IP │   │   │   │   └── 路由选择.txt │   │   │   └── 子网划分 │   │   │   └── 子网划分.txt │   │   ├── 网络设备 │   │   │   ├── 交换机.txt │   │   │   ├── 路由器.txt │   │   │   └── 网络设备.md │   │   ├── 物理层 │   │   │   └── 物理层.md │   │   └── 应用层 │   │   ├── dns.txt │   │   ├── pic │   │   │   ├── 3次握手.png │   │   │   ├── http2报文.png │   │   │   ├── https混合加密.png │   │   │   ├── https数字证书.png │   │   │   ├── https摘要算法.png │   │   │   ├── http协议演进.png │   │   │   └── SSL握手.png │   │   ├── 实际问题 │   │   │   └── url到页面.md │   │   ├── 协议 │   │   │   ├── dhcp.txt │   │   │   ├── ftp.txt │   │   │   ├── http │   │   │   ├── snmp.txt │   │   │   ├── ssh.md │   │   │   ├── telnet.txt │   │   │   └── 邮件协议.txt │   │   └── 应用层.md │   ├── 计算机系统 │   │   ├── pic │   │   │   ├── 32位浮点.png │   │   │   ├── 64位浮点.png │   │   │   ├── 存储器层次.png │   │   │   ├── 存储器成本.png │   │   │   ├── 存储体类比.png │   │   │   ├── 计算机分层.webp │   │   │   ├── 计算机组成原理.png │   │   │   └── 嵌入式开发.jpg │   │   ├── 汇编.km │   │   ├── 计算机系统.md │   │   ├── 计算机组成 │   │   │   ├── IO │   │   │   │   ├── IO技术.md │   │   │   │   └── 总线.md │   │   │   ├── 处理器 │   │   │   │   └── 处理器.md │   │   │   ├── 存储器 │   │   │   │   └── 存储器.md │   │   │   ├── 计算机组成.km │   │   │   ├── 硬件信息获取.md │   │   │   ├── 运算 │   │   │   │   └── 数据表示.md │   │   │   └── 指令集 │   │   │   └── 指令系统.md │   │   ├── 嵌入式技能.km │   │   └── 信息 │   │   ├── 编码.md │   │   ├── 多媒体.md │   │   ├── 数据表示.md │   │   ├── 信息.md │   │   └── 信息安全.md │   └── 软件工程 │   ├── UML与建模 │   ├── 软件测试 │   │   ├── 测试策略 │   │   ├── 测试对象 │   │   ├── 测试阶段 │   │   ├── 测试领域 │   │   ├── 软件测试.km │   │   └── 质量 │   ├── 软件工程.km │   ├── 系统分析 │   ├── 系统设计 │   ├── 系统实施 │   └── 系统维护 ├── files │   ├── faq │   │   ├── hadoop │   │   │   ├── 01.txt │   │   │   ├── container退出.txt │   │   │   ├── executor lost.md │   │   │   ├── hbase.md │   │   │   ├── hdfs权限问题.md │   │   │   ├── sparkr.md │   │   │   ├── sparksql不支持hive.md │   │   │   ├── yarn nm退出.txt │   │   │   └── 集群外节点无法提交spark任务.txt │   │   ├── io │   │   │   ├── socket.md │   │   │   ├── ssh失联.txt │   │   │   ├── websocket失联.txt │   │   │   └── 序列化问题.txt │   │   ├── net │   │   │   └── net01.md │   │   ├── os │   │   │   ├── os启动失败.md │   │   │   ├── systemd失去响应.txt │   │   │   ├── 编码问题.md │   │   │   ├── 磁盘空间清理.txt │   │   │   ├── 内存占满.md │   │   │   ├── 系统编码.md │   │   │   └── 系统救援.md │   │   ├── other │   │   │   ├── jar问题.md │   │   │   ├── redis集合数据大量丢失.txt │   │   │   ├── redis无法检测key存在.txt │   │   │   └── 开发环境 │   │   │   └── spark-idea.md │   │   ├── support │   │   │   └── jdk.md │   │   ├── tomcat │   │   │   ├── server.xml │   │   │   └── tomcat假死.md │   │   └── web │   │   ├── list0.md │   │   └── 跨域.md │   ├── test │   │   ├── list0.md │   │   └── 实验设计.md │   ├── tools │   │   ├── IDE │   │   │   ├── clion │   │   │   ├── codegen │   │   │   ├── eclipse │   │   │   ├── idea │   │   │   ├── model │   │   │   ├── pycharm │   │   │   └── vscode │   │   ├── log4j │   │   ├── other │   │   │   └── r │   │   │   ├── r.km │   │   │   └── r.md │   │   ├── pcap │   │   │   ├── packetCapture.txt │   │   │   └── pcap.km │   │   ├── pic │   │   │   ├── draw │   │   │   ├── echarts │   │   │   ├── mermaid │   │   │   └── uml │   │   ├── 安全 │   │   │   └── 校验.md │   │   ├── 版本控制 │   │   │   ├── git │   │   │   └── svn │   │   ├── 测试调试 │   │   │   ├── ab │   │   │   ├── chrome │   │   │   ├── jmeter │   │   │   ├── junit │   │   │   ├── swagger │   │   │   ├── win │   │   │   └── 校验 │   │   ├── 构建 │   │   │   ├── ant │   │   │   ├── cseries │   │   │   ├── gradle │   │   │   ├── maven │   │   │   └── sbt │   │   └── 网络 │   │   ├── whireshark.km ├── hadoop_demos │   ├── es │   ├── flink │   │   ├── flink-learning │   │   │   ├── Flink-Forward-2020 │   │   │   │   └── README.md │   │   │   ├── Flink-Forward-Asia-2019-PPT │   │   │   │   └── README.md │   │   │   ├── Flink-Forward-Asia-2020-PPT │   │   │   │   └── README.md │   │   │   ├── flink-learning-common │   │   │   │   ├── flink-learning-common.iml │   │   │   │   ├── pom.xml │   │   │   │   ├── README.md │   │   │   │   ├── src │   │   │   │   └── target │   │   │   ├── flink-learning-configration-center │   │   │   │   ├── flink-learning-configration-center-apollo │   │   │   │   ├── flink-learning-configration-center.iml │   │   │   │   ├── flink-learning-configration-center-nacos │   │   │   │   └── pom.xml │   │   │   ├── flink-learning-connectors │   │   │   │   ├── flink-learning-connectors-activemq │   │   │   │   ├── flink-learning-connectors-akka │   │   │   │   ├── flink-learning-connectors-cassandra │   │   │   │   ├── flink-learning-connectors-clickhouse │   │   │   │   ├── flink-learning-connectors-es │   │   │   │   ├── flink-learning-connectors-es6 │   │   │   │   ├── flink-learning-connectors-flume │   │   │   │   ├── flink-learning-connectors-gcp-pubsub │   │   │   │   ├── flink-learning-connectors-hbase │   │   │   │   ├── flink-learning-connectors-hdfs │   │   │   │   ├── flink-learning-connectors-hive │   │   │   │   ├── flink-learning-connectors.iml │   │   │   │   ├── flink-learning-connectors-influxdb │   │   │   │   ├── flink-learning-connectors-jdbc │   │   │   │   ├── flink-learning-connectors-kafka │   │   │   │   ├── flink-learning-connectors-kinesis │   │   │   │   ├── flink-learning-connectors-kudu │   │   │   │   ├── flink-learning-connectors-mysql │   │   │   │   ├── flink-learning-connectors-netty │   │   │   │   ├── flink-learning-connectors-nifi │   │   │   │   ├── flink-learning-connectors-pulsar │   │   │   │   ├── flink-learning-connectors-rabbitmq │   │   │   │   ├── flink-learning-connectors-redis │   │   │   │   ├── flink-learning-connectors-rocketmq │   │   │   │   ├── pom.xml │   │   │   │   └── README.md │   │   │   ├── flink-learning-core │   │   │   │   ├── flink-learning-core.iml │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── flink-learning-data-sinks │   │   │   │   ├── flink-learning-data-sinks.iml │   │   │   │   ├── pom.xml │   │   │   │   ├── README.md │   │   │   │   └── src │   │   │   ├── flink-learning-data-sources │   │   │   │   ├── flink-learning-data-sources.iml │   │   │   │   ├── pom.xml │   │   │   │   ├── README.md │   │   │   │   └── src │   │   │   ├── flink-learning-examples │   │   │   │   ├── flink-learning-examples.iml │   │   │   │   ├── pom.xml │   │   │   │   ├── README.md │   │   │   │   └── src │   │   │   ├── flink-learning.iml │   │   │   ├── flink-learning-libraries │   │   │   │   ├── flink-learning-libraries-cep │   │   │   │   ├── flink-learning-libraries-gelly │   │   │   │   ├── flink-learning-libraries.iml │   │   │   │   ├── flink-learning-libraries-machine-learning │   │   │   │   ├── flink-learning-libraries-state-processor-api │   │   │   │   ├── pom.xml │   │   │   │   └── README.md │   │   │   ├── flink-learning-metrics │   │   │   │   ├── flink-learning-metrics.iml │   │   │   │   ├── pom.xml │   │   │   │   ├── README.md │   │   │   │   └── src │   │   │   ├── flink-learning-monitor │   │   │   │   ├── flink-learning-monitor-alert │   │   │   │   ├── flink-learning-monitor-collector │   │   │   │   ├── flink-learning-monitor-common │   │   │   │   ├── flink-learning-monitor-dashboard │   │   │   │   ├── flink-learning-monitor.iml │   │   │   │   ├── flink-learning-monitor-log │   │   │   │   ├── flink-learning-monitor-pvuv │   │   │   │   ├── flink-learning-monitor-storage │   │   │   │   ├── flink_monitor_measurements.md │   │   │   │   ├── pom.xml │   │   │   │   └── README.md │   │   │   ├── flink-learning-project │   │   │   │   ├── flink-learning-project-common │   │   │   │   ├── flink-learning-project-deduplication │   │   │   │   ├── flink-learning-project-flink-job-scaffold │   │   │   │   ├── flink-learning-project.iml │   │   │   │   ├── flink-learning-project-log │   │   │   │   ├── flink-learning-project-monitor-alert │   │   │   │   ├── flink-learning-project-monitor-dashboard │   │   │   │   ├── flink-learning-project-real-time-computing-platform │   │   │   │   ├── flink-learning-project-real-time-data-warehouse │   │   │   │   ├── flink-learning-project-risk-management │   │   │   │   ├── pom.xml │   │   │   │   └── README.md │   │   │   ├── flink-learning-sql │   │   │   │   ├── flink-learning-sql-ago │   │   │   │   ├── flink-learning-sql-blink │   │   │   │   ├── flink-learning-sql-common │   │   │   │   ├── flink-learning-sql.iml │   │   │   │   ├── pom.xml │   │   │   │   └── README.md │   │   │   ├── flink-learning-state │   │   │   │   ├── flink-learning-state.iml │   │   │   │   ├── pom.xml │   │   │   │   ├── README.md │   │   │   │   └── src │   │   │   ├── flink-learning-template │   │   │   │   ├── flink-learning-template.iml │   │   │   │   ├── pom.xml │   │   │   │   ├── README.md │   │   │   │   └── src │   │   │   ├── flink-learning-window │   │   │   │   ├── flink-learning-window.iml │   │   │   │   ├── pom.xml │   │   │   │   ├── README.md │   │   │   │   └── src │   │   │   ├── LICENSE │   │   │   ├── paper │   │   │   │   └── paper.md │   │   │   ├── pics │   │   │   │   └── Flink-code.png │   │   │   ├── pom.xml │   │   │   ├── README.md │   │   │   ├── tree.md │   │   │   └── VERSION │   │   ├── flink-recommand │   │   │   ├── flink-2-hbase │   │   │   │   ├── flink-2-hbase.iml │   │   │   │   ├── pom.xml │   │   │   │   ├── src │   │   │   │   └── target │   │   │   ├── flink-recommand.iml │   │   │   ├── pom.xml │   │   │   ├── README.md │   │   │   ├── resources │   │   │   │   ├── docker │   │   │   │   ├── icon │   │   │   │   ├── pic │   │   │   │   └── sql │   │   │   └── web │   │   │   ├── pom.xml │   │   │   ├── src │   │   │   ├── target │   │   │   └── web.iml │   │   ├── geektime-Flink │   │   │   ├── data-set │   │   │   │   └── frostroad.txt │   │   │   ├── doc │   │   │   │   ├── 1.Apache Flink介绍.pdf │   │   │   │   ├── 2.Flink部署与应用.pdf │   │   │   │   ├── 3.Flink DataStream API实践原理.pdf │   │   │   │   ├── 3.Flink状态管理和容错.pdf │   │   │   │   ├── 5.Flink Table & SQL实践原理(上).pdf │   │   │   │   ├── 5.Flink Table & SQL实践原理(下).pdf │   │   │   │   ├── 6.Flink Runtime设计与实现.pdf │   │   │   │   ├── 7.Flink监控与性能优化.pdf │   │   │   │   ├── 8.Flink组件栈介绍与使用.pdf │   │   │   │   └── 9.项目实战-使用Flink构建推荐系统实时数据流.pdf │   │   │   ├── geektime-flink.iml │   │   │   ├── lab-2-install-flink-cluster │   │   │   │   ├── docker-deploy │   │   │   │   ├── high-aviable-config │   │   │   │   ├── kubernetes-deploy │   │   │   │   ├── user-lib │   │   │   │   └── yarn-deploy │   │   │   ├── lab-3-datastream-api │   │   │   │   ├── lab-3-datastream-api.iml │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── lab-4-stateful-compute │   │   │   │   ├── lab-4-stateful-compute.iml │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── lab-5-table-api-with-sql │   │   │   │   ├── lab-5-table-api-with-sql.iml │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── lab-6-flink-runtime │   │   │   │   ├── lab-6-flink-runtime.iml │   │   │   │   └── pom.xml │   │   │   ├── lab-7-alink-project │   │   │   │   ├── lab-7-alink-project.iml │   │   │   │   ├── pom.xml │   │   │   │   ├── README.md │   │   │   │   └── src │   │   │   ├── pom.xml │   │   │   ├── project-1-pv-uv-computing │   │   │   │   ├── pom.xml │   │   │   │   ├── project-1-pv-uv-computing.iml │   │   │   │   ├── README.md │   │   │   │   └── src │   │   │   ├── project-2-fraud-detection │   │   │   │   ├── docker-compose-flink-job.yaml │   │   │   │   ├── docker-compose-flink-session.yaml │   │   │   │   ├── docker-compose-kafka.yaml │   │   │   │   ├── docker-compose-local-job.yaml │   │   │   │   ├── docker-compose-local.yaml │   │   │   │   ├── docker-compose.yaml │   │   │   │   ├── flink-job │   │   │   │   ├── pom.xml │   │   │   │   ├── preject-2-fraud-detection.iml │   │   │   │   ├── project-sql │   │   │   │   ├── README.md │   │   │   │   └── webapp │   │   │   ├── project-3-table-and-sql │   │   │   │   ├── pom.xml │   │   │   │   ├── project-03-sql.iml │   │   │   │   └── src │   │   │   ├── project-4-recommend │   │   │   │   ├── pom.xml │   │   │   │   ├── project-4-recommend.iml │   │   │   │   ├── README.md │   │   │   │   ├── recommend-backend │   │   │   │   ├── recommend-flink-job │   │   │   │   └── recommend-front │   │   │   └── README.md │   │   ├── info.txt │   │   ├── logs │   │   ├── pom.xml │   │   ├── sgg │   │   │   ├── Data │   │   │   │   ├── AdClickLog.csv │   │   │   │   ├── apache.log │   │   │   │   ├── LoginLog.csv │   │   │   │   ├── OrderLog.csv │   │   │   │   ├── ReceiptLog.csv │   │   │   │   ├── TestData │   │   │   │   └── UserBehavior.csv │   │   │   ├── doc │   │   │   │   ├── 1_Flink简介.pdf │   │   │   │   ├── 2_Flink运行架构.pdf │   │   │   │   ├── 3_Flink window API .pdf │   │   │   │   ├── 4_Flink中的时间语义和watermark.pdf │   │   │   │   ├── 5_Flink的状态管理.pdf │   │   │   │   ├── 6_Flink的容错机制.pdf │   │   │   │   ├── 7_Flink的状态一致性.pdf │   │   │   │   ├── 8_Table API 和 Flink SQL.pdf │   │   │   │   ├── 9_Flink CEP简介.pdf │   │   │   │   ├── 电商用户行为数据分析.pdf │   │   │   │   ├── 尚硅谷大数据技术之电商用户行为数据分析 - Java版.pdf │   │   │   │   ├── 尚硅谷大数据之flink教程-Java版.pdf │   │   │   │   └── 尚硅谷大数据之flink教程-TableAPI和SQL-Java版.pdf │   │   │   ├── FlinkTutorial │   │   │   │   ├── config │   │   │   │   ├── FlinkTutorial.iml │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── pom.xml │   │   │   └── sgg.iml │   │   └── src │   │   └── main │   │   ├── java │   │   ├── resources │   │   └── scala │   ├── hadoop-demo.iml │   ├── hadooponwindows │   │   ├── bin │   │   │   ├── container-executor │   │   │   ├── hadoop │   │   │   ├── hadoop.cmd │   │   │   ├── hadoop.dll │   │   │   ├── hadoop.exp │   │   │   ├── hadoop.lib │   │   │   ├── hadoop.pdb │   │   │   ├── hdfs │   │   │   ├── hdfs.cmd │   │   │   ├── hdfs.dll │   │   │   ├── hdfs.exp │   │   │   ├── hdfs.lib │   │   │   ├── hdfs.pdb │   │   │   ├── hdfs_static.lib │   │   │   ├── hdfs_static.pdb │   │   │   ├── libwinutils.lib │   │   │   ├── mapred │   │   │   ├── mapred.cmd │   │   │   ├── rcc │   │   │   ├── test-container-executor │   │   │   ├── winutils.exe │   │   │   ├── winutils.pdb │   │   │   ├── yarn │   │   │   └── yarn.cmd │   │   ├── etc │   │   │   └── hadoop │   │   │   ├── capacity-scheduler.xml │   │   │   ├── configuration.xsl │   │   │   ├── container-executor.cfg │   │   │   ├── core-site.xml │   │   │   ├── hadoop-env.cmd │   │   │   ├── hadoop-env.sh │   │   │   ├── hadoop-metrics2.properties │   │   │   ├── hadoop-metrics.properties │   │   │   ├── hadoop-policy.xml │   │   │   ├── hdfs-site.xml │   │   │   ├── httpfs-env.sh │   │   │   ├── httpfs-log4j.properties │   │   │   ├── httpfs-signature.secret │   │   │   ├── httpfs-site.xml │   │   │   ├── kms-acls.xml │   │   │   ├── kms-env.sh │   │   │   ├── kms-log4j.properties │   │   │   ├── kms-site.xml │   │   │   ├── log4j.properties │   │   │   ├── mapred-env.cmd │   │   │   ├── mapred-env.sh │   │   │   ├── mapred-queues.xml.template │   │   │   ├── mapred-site.xml │   │   │   ├── mapred-site.xml.template │   │   │   ├── slaves │   │   │   ├── ssl-client.xml.example │   │   │   ├── ssl-server.xml.example │   │   │   ├── yarn-env.cmd │   │   │   ├── yarn-env.sh │   │   │   └── yarn-site.xml │   │   └── README.md │   ├── hbase │   │   ├── files │   │   │   ├── faq │   │   │   │   └── 设计思路.md │   │   │   ├── hbase-client.km │   │   │   ├── hbase-server.km │   │   │   ├── notes │   │   │   │   ├── Hbase_Java_API.md │   │   │   │   ├── Hbase_Shell.md │   │   │   │   ├── Hbase的SQL中间层_Phoenix.md │   │   │   │   ├── Hbase过滤器详解.md │   │   │   │   ├── Hbase简介.md │   │   │   │   ├── Hbase容灾与备份.md │   │   │   │   ├── Hbase系统架构及数据结构.md │   │   │   │   ├── Hbase协处理器详解.md │   │   │   │   └── Spring+Mybtais+Phoenix整合.md │   │   │   ├── pic │   │   │   │   ├── HBaseArchitecture-Blog-Fig7.png │   │   │   │   ├── hbase-bytearraycomparable.png │   │   │   │   ├── hbase-compareFilter.png │   │   │   │   ├── hbase-connection.png │   │   │   │   ├── hbase-coprocessor.png │   │   │   │   ├── hbase-copy-table.png │   │   │   │   ├── hbase-co-unload.png │   │   │   │   ├── hbase-cp-hdfs.png │   │   │   │   ├── hbase-cp-helloworld.png │   │   │   │   ├── hbase-cp-lisi.png │   │   │   │   ├── hbase-cp-load.png │   │   │   │   ├── hbase-filterbase-subclass.png │   │   │   │   ├── hbase-fliter.png │   │   │   │   ├── hbase-hadoop.png │   │   │   │   ├── hbase-region-dis.png │   │   │   │   ├── hbase-Region-Server.png │   │   │   │   ├── hbase-region-splite.png │   │   │   │   ├── hbase-unload-test.png │   │   │   │   ├── hbase-webtable.png │   │   │   │   ├── hbase-web-ui-phoenix.png │   │   │   │   ├── hbase-web-ui.png │   │   │   │   ├── hbase宏观架构.png │   │   │   │   ├── hbase-集群搭建1.png │   │   │   │   ├── hbase-集群搭建2.png │   │   │   │   ├── hbase集群规划.png │   │   │   │   ├── hbase集群结构.png │   │   │   │   ├── hbase架构.png │   │   │   │   ├── hfile结构.png │   │   │   │   ├── phoenix-core-jar.png │   │   │   │   ├── Phoenix-create-table.png │   │   │   │   ├── Phoenix-delete.png │   │   │   │   ├── Phoenix-hadoop.png │   │   │   │   ├── Phoenix-java-api-result.png │   │   │   │   ├── Phoenix-select.png │   │   │   │   ├── phoenix-shell.png │   │   │   │   ├── Phoenix-update.png │   │   │   │   ├── regionServer结构.png │   │   │   │   └── region结构.png │   │   │   ├── 架构 │   │   │   │   ├── wal.txt │   │   │   │   ├── 安装管理 │   │   │   │   ├── 数据模型 │   │   │   │   ├── 系统架构 │   │   │   │   └── 优化 │   │   │   ├── 客户端 │   │   │   │   ├── api.txt │   │   │   │   ├── 高级特性 │   │   │   │   ├── 管理功能 │   │   │   │   └── 客户端 │   │   │   └── 应用 │   │   │   ├── spark hbase.txt │   │   │   └── 场景.md │   │   ├── hbase-book-master │   │   │   ├── bin │   │   │   │   ├── doprotoc.sh │   │   │   │   ├── dothrift.sh │   │   │   │   └── jdiff-hbase.sh │   │   │   ├── ch03 │   │   │   │   ├── bin │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── ch04 │   │   │   │   ├── bin │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── ch05 │   │   │   │   ├── bin │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── ch06 │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── ch07 │   │   │   │   ├── pom.xml │   │   │   │   ├── src │   │   │   │   └── test-data.txt │   │   │   ├── ch08 │   │   │   │   ├── bin │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── ch09 │   │   │   │   ├── bin │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── ch11 │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── ch12 │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── ch13 │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── cluster │   │   │   │   ├── ansible │   │   │   │   └── Vagrantfile │   │   │   ├── common │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── hush │   │   │   │   ├── bin │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── LICENSE │   │   │   ├── pom.xml │   │   │   └── README.rst │   │   ├── hbase.iml │   │   ├── pom.xml │   │   ├── ${project.basedir} │   │   │   └── src │   │   │   └── main │   │   ├── src │   │   │   └── main │   │   │   ├── assembly.xml │   │   │   └── scala │   │   └── target │   │   ├── classes │   │   ├── dependency │   │   │   ├── kafka_2.11-0.8.2.1.jar │   │   │   ├── kafka-clients-0.8.2.1.jar │   │   │   ├── log4j-1.2.14.jar │   │   │   ├── lz4-1.2.0.jar │   │   │   ├── metrics-core-2.2.0.jar │   │   │   ├── scala-library-2.11.5.jar │   │   │   ├── scala-parser-combinators_2.11-1.0.2.jar │   │   │   ├── scala-reflect-2.11.7.jar │   │   │   ├── scalatest_2.11-2.2.6.jar │   │   │   ├── scala-xml_2.11-1.0.2.jar │   │   │   ├── slf4j-api-1.7.2.jar │   │   │   ├── snappy-java-1.1.1.6.jar │   │   │   ├── spark-streaming-kafka-0-8_2.11-2.0.0.jar │   │   │   ├── spark-tags_2.11-2.0.0.jar │   │   │   ├── unused-1.0.0.jar │   │   │   └── zkclient-0.3.jar │   │   ├── generated-sources │   │   │   └── annotations │   │   ├── hbase-1.0-SNAPSHOT.jar │   │   └── maven-archiver │   │   └── pom.properties │   ├── hdfs │   │   ├── data │   │   │   ├── flow2.log │   │   │   ├── flow.log │   │   │   └── join │   │   │   ├── order.txt │   │   │   └── product.txt │   │   ├── files │   │   │   ├── config.md │   │   │   ├── faq │   │   │   │   └── list │   │   │   ├── hdfs.km │   │   │   ├── 架构 │   │   │   │   ├── info │   │   │   │   ├── 通信协议 │   │   │   │   └── 组成 │   │   │   └── 特性 │   │   │   ├── HA │   │   │   ├── 存储目录结构.md │   │   │   └── 特性.txt │   │   ├── hdfs.iml │   │   ├── pom.xml │   │   └── src │   │   └── main │   │   └── scala │   ├── hive │   │   ├── files │   │   │   ├── basic │   │   │   │   └── hive练习数据 │   │   │   ├── faq │   │   │   │   ├── 扩展.md │   │   │   │   └── 优化.md │   │   │   ├── hive.km │   │   │   ├── hql │   │   │   │   ├── DDL │   │   │   │   ├── DML │   │   │   │   ├── 查询 │   │   │   │   ├── 函数 │   │   │   │   ├── 视图 │   │   │   │   ├── 数据类型 │   │   │   │   └── 索引 │   │   │   ├── 工作常用语句.txt │   │   │   ├── 架构 │   │   │   │   ├── pic │   │   │   │   ├── 安全 │   │   │   │   ├── 参数 │   │   │   │   ├── 存储 │   │   │   │   ├── 架构.md │   │   │   │   └── 锁 │   │   │   ├── 面试题 │   │   │   │   ├── hql1 │   │   │   │   ├── hql2 │   │   │   │   ├── hql3 │   │   │   │   └── table │   │   │   └── 命令行 │   │   │   ├── beeline.txt │   │   │   └── cmd.md │   │   ├── hive.iml │   │   ├── pom.xml │   │   ├── ${project.basedir} │   │   │   └── src │   │   │   └── main │   │   ├── src │   │   │   └── main │   │   │   └── scala │   │   └── target │   │   ├── classes │   │   │   └── scala │   │   └── generated-sources │   │   └── annotations │   ├── impala │   │   ├── files │   │   │   └── 架构 │   │   │   └── info │   │   ├── impala.iml │   │   ├── pom.xml │   │   └── src │   │   └── main │   │   └── scala │   ├── kudu │   │   ├── files │   │   │   └── info │   │   ├── kudu.iml │   │   ├── pom.xml │   │   └── src │   │   └── main │   │   └── scala │   ├── kylin │   │   ├── kylin.iml │   │   ├── pom.xml │   │   └── src │   │   └── main │   │   └── scala │   ├── oozie │   │   ├── files │   │   ├── oozie.iml │   │   ├── pom.xml │   │   ├── src │   │   │   ├── main │   │   │   │   ├── resources │   │   │   │   └── scala │   │   │   └── test │   │   │   ├── java │   │   │   └── resources │   │   ├── target │   │   │   └── classes │   │   │   ├── oozie-login.conf │   │   │   ├── workflow-java-template.xml │   │   │   ├── workflow-shell-template.xml │   │   │   ├── workflow-spark2-template.xml │   │   │   └── workflow-spark-template.xml │   │   └── zzjz-interpreter.20190625.tar.gz │   ├── pom.xml │   ├── ${project.basedir} │   │   └── src │   │   └── main │   │   └── site │   ├── storm │   │   ├── files │   │   │   ├── notes │   │   │   │   ├── Storm编程模型详解.md │   │   │   │   ├── Storm单机环境搭建.md │   │   │   │   ├── Storm和流处理简介.md │   │   │   │   ├── Storm核心概念详解.md │   │   │   │   ├── Storm集成HBase和HDFS.md │   │   │   │   ├── Storm集成Kakfa.md │   │   │   │   ├── Storm集成Redis详解.md │   │   │   │   ├── Storm集群环境搭建.md │   │   │   │   └── Storm三种打包方式对比分析.md │   │   │   ├── 参数 │   │   │   │   ├── nimbus.txt │   │   │   │   ├── storm.yaml.txt │   │   │   │   ├── supervisor.txt │   │   │   │   ├── topology.txt │   │   │   │   ├── ui.txt │   │   │   │   ├── zk.txt │   │   │   │   └── 参数.txt │   │   │   └── 架构 │   │   │   ├── storm.sh │   │   │   └── 基本概念.txt │   │   ├── pom.xml │   │   ├── src │   │   │   ├── main │   │   │   │   ├── java │   │   │   │   ├── resources │   │   │   │   └── scala │   │   │   └── test │   │   │   └── scala │   │   ├── storm.iml │   │   └── target │   │   ├── classes │   │   │   ├── log4j.properties │   │   │   └── storm │   │   ├── generated-sources │   │   │   └── annotations │   │   └── maven-status │   │   └── maven-compiler-plugin │   ├── zookeeper │   │   ├── examples │   │   │   ├── configManagement │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   ├── zkClient │   │   │   │   ├── pom.xml │   │   │   │   └── src │   │   │   └── zookeeper │   │   │   ├── lib │   │   │   └── src │   │   ├── files │   │   │   ├── client │   │   │   │   ├── zkClient.md │   │   │   │   ├── Zookeeper常用Shell命令.md │   │   │   │   └── 命令 │   │   │   ├── faq │   │   │   │   └── faq.md │   │   │   ├── notes │   │   │   │   ├── Zookeeper_ACL权限控制.md │   │   │   │   ├── Zookeeper_Java客户端Curator.md │   │   │   │   ├── Zookeeper单机环境和集群环境搭建.md │   │   │   │   ├── 基于Zookeeper搭建Hadoop高可用集群.md │   │   │   │   └── 基于Zookeeper搭建Kafka高可用集群.md │   │   │   ├── pic │   │   │   │   ├── HA集群结构.png │   │   │   │   ├── zk分布式锁.webp │   │   │   │   └── 图画.png │   │   │   ├── zookeeper.km │   │   │   ├── zookeeper.md │   │   │   ├── 架构 │   │   │   │   ├── 概念 │   │   │   │   ├── 集群角色.txt │   │   │   │   ├── 架构.txt │   │   │   │   └── 数据结构.txt │   │   │   └── 实例 │   │   │   ├── leader选举.txt │   │   │   ├── 分布式锁.md │   │   │   ├── 服务实例.txt │   │   │   ├── 集群管理.md │   │   │   ├── 计数器.txt │   │   │   ├── 配置服务.txt │   │   │   ├── 统一命名服务.txt │   │   │   └── 注册中心.md │   │   ├── pom.xml │   │   ├── src │   │   │   └── main │   │   │   ├── java │   │   │   └── scala │   │   ├── target │   │   │   ├── classes │   │   │   │   ├── ServiceAProvider.class │   │   │   │   ├── ServiceBProvider.class │   │   │   │   ├── ServiceConsumer$1.class │   │   │   │   └── ServiceConsumer.class │   │   │   └── generated-sources │   │   │   └── annotations │   │   └── zookeeper.iml │   └── 性能调优 │   ├── jvm │   │   └── JAVA诊断arthas.txt │   ├── linux性能优化 │   │   ├── os调优.km │   │   ├── pic │   │   │   ├── linux性能优化.png │   │   │   ├── linux性能优化工具.png │   │   │   └── 性能指标.png │   │   ├── 进程.txt │   │   ├── 实践 │   │   │   ├── 程序资源分析.md │   │   │   └── 优化思路.md │   │   ├── 性能工具.km │   │   └── 原理 │   │   ├── cpu │   │   ├── IO.md │   │   ├── 内存 │   │   ├── 网络 │   │   ├── 系统参数.md │   │   └── 硬盘 │   ├── 方法论 │   │   ├── 故障排查.km │   │   └── 基础方法 │   ├── 工具 │   │   ├── commands.txt │   │   ├── 高级 │   │   │   ├── pidstat.txt │   │   │   ├── 进程树栈.txt │   │   │   └── 进程资源限制.txt │   │   ├── 基础 │   │   │   ├── iperf.txt │   │   │   ├── lsof.txt │   │   │   ├── nmap.txt │   │   │   ├── ps.txt │   │   │   ├── sar.txt │   │   │   ├── stat │   │   │   └── 系统 │   │   └── 性能工具.png │   └── 组件调优 │   ├── flume │   │   └── flume │   ├── hbase │   │   ├── 参数 │   │   ├── 集群规划 │   │   ├── 架构.txt │   │   ├── 性能分析 │   │   └── 性能优化 │   ├── hdfs │   │   ├── 集群规划 │   │   ├── 架构.txt │   │   ├── 配置参数 │   │   ├── 思路.txt │   │   ├── 性能调优 │   │   ├── 性能分析 │   │   └── 性能优化 │   ├── hive │   │   ├── 集群规划 │   │   ├── 架构.txt │   │   ├── 思路.txt │   │   ├── 性能分析 │   │   └── 性能优化 │   ├── kafka │   │   ├── 集群规划 │   │   ├── 架构.txt │   │   ├── 性能分析 │   │   └── 性能优化 │   ├── MR │   │   ├── MR过程.png │   │   ├── MR原理.txt │   │   ├── 集群规划 │   │   ├── 性能分析 │   │   └── 性能优化 │   ├── redis │   │   ├── redis架构.png │   │   ├── 集群规划 │   │   ├── 性能分析 │   │   └── 性能优化 │   ├── spark │   │   ├── 调优方法 │   │   ├── 服务规划.txt │   │   └── 性能分析 │   ├── yarn │   │   ├── 调优方法 │   │   ├── 集群规划.txt │   │   └── 性能分析 │   └── zookeeper │   ├── 集群规划 │   ├── 性能分析 │   └── 性能优化 ├── java-demos │   ├── basic │   │   ├── basic.iml │   │   ├── files │   │   │   ├── faq │   │   │   │   ├── 路径.md │   │   │   │   └── 数组转list.md │   │   │   ├── Java 8实战.pdf │   │   │   ├── java.km │   │   │   ├── Java相关 │   │   │   │   ├── J2EE基础知识.md │   │   │   │   ├── Java基础知识.md │   │   │   │   ├── Java虚拟机(jvm).md │   │   │   │   ├── jdk环境变量.txt │   │   │   │   ├── 搞定JVM垃圾回收就是这么简单.md │   │   │   │   └── 可能是把Java内存区域讲的最清楚的一篇文章.md │   │   │   ├── jvms8.pdf │   │   │   ├── pic │   │   │   │   ├── java7hashmap.png │   │   │   │   ├── java8hashmap.png │   │   │   │   ├── java集合.png │   │   │   │   ├── list.png │   │   │   │   ├── map.png │   │   │   │   └── set.png │   │   │   ├── 阿里巴巴Java开发手册泰山版.pdf │   │   │   ├── 基础特性 │   │   │   │   ├── 泛型 │   │   │   │   ├── 关键字 │   │   │   │   ├── 基本类型 │   │   │   │   ├── 面向对象 │   │   │   │   ├── 异常 │   │   │   │   └── 注解.md │   │   │   ├── 集合 │   │   │   │   ├── Collection │   │   │   │   ├── 工具类 │   │   │   │   └── 集合.md │   │   │   └── 新特性 │   │   │   ├── jdk8.md │   │   │   ├── stream.md │   │   │   ├── 函数式接口.md │   │   │   └── 实例1.txt │   │   ├── pom.xml │   │   ├── src │   │   │   └── main │   │   │   └── java │   │   └── target │   │   ├── classes │   │   │   ├── collection │   │   │   ├── exception │   │   │   ├── innerclass │   │   │   ├── jdk8 │   │   │   ├── math │   │   │   ├── object │   │   │   ├── Outter.class │   │   │   ├── Outter$Inner.class │   │   │   ├── reflection │   │   │   ├── sort │   │   │   ├── string │   │   │   ├── swing │   │   │   └── Test.class │   │   ├── generated-sources │   │   │   └── annotations │   │   └── maven-status │   │   └── maven-compiler-plugin │   ├── common │   │   ├── hutool │   ├── concurrency │   ├── design-pattern │   ├── io │   ├── jvm │   ├── nosql │   │   ├── cassandra │   │   ├── graph │   │   ├── mongo │   │   ├── mpp │   │   ├── neo4j │   │   ├── redis │   │   └── ssdb │   ├── openjdk-8-b132-03_mar │   ├── sql │   │   ├── jdbc │   │   ├── mysql │   │   ├── oracle │   │   ├── postgresql │   │   ├── sqlite │   │   ├── sqlserver │   ├── utils │   └── web ├── spark_demos │   ├── files │   │   ├── faq │   │   │   └── dataset.md │   │   ├── pic │   │   │   ├── executor堆内存.png │   │   │   ├── executor堆外内存.png │   │   │   ├── executor内存调整规则.png │   │   │   └── spark_memory_usage实例.png │   │   ├── sparkcore.km │   │   ├── spark优化.km │   │   ├── 工具 │   │   │   ├── spark应用提交流程.md │   │   │   └── 命令行.txt │   │   ├── 架构 │   │   │   ├── 高可用 │   │   │   │   ├── 高可用.txt │   │   │   │   └── 基于ZK HA.txt │   │   │   ├── 核心原理 │   │   │   │   ├── 部署模式 │   │   │   │   ├── 存储体系 │   │   │   │   ├── 辅助系统 │   │   │   │   ├── 计算引擎 │   │   │   │   ├── 任务提交和执行 │   │   │   │   ├── 上下文 │   │   │   │   └── 通信 │   │   │   └── 类加载.md │   │   ├── 矩阵计算 │   │   │   ├── eig.scala │   │   │   ├── LabeledPoint.scala │   │   │   ├── linalg │   │   │   │   ├── BLAS.scala │   │   │   │   ├── CholeskyDecomposition.scala │   │   │   │   ├── distributed │   │   │   │   ├── EigenValueDecomposition.scala │   │   │   │   ├── Matrices.scala │   │   │   │   ├── SingularValueDecomposition.scala │   │   │   │   └── Vectors.scala │   │   │   ├── linalg0 │   │   │   │   ├── BLAS.scala │   │   │   │   ├── Matrices.scala │   │   │   │   └── Vectors.scala │   │   │   ├── UFunc.scala │   │   │   └── Vector.scala │   │   ├── 扩展 │   │   │   ├── hiveOnSpark.txt │   │   │   ├── pyspark.txt │   │   │   ├── python库安装.txt │   │   │   ├── R依赖管理.txt │   │   │   ├── sparkOnHive.md │   │   │   ├── sparkOnTensorflow.txt │   │   │   ├── SparkR.md │   │   │   └── sparksql.txt │   │   ├── 类 │   │   │   ├── Partitioner.scala │   │   │   ├── 存储 │   │   │   │   ├── BlockManagerMaster.scala │   │   │   │   ├── BlockManager.scala │   │   │   │   ├── DiskBlockManager.scala │   │   │   │   └── DiskStore.scala │   │   │   ├── 上下文 │   │   │   │   ├── BlockManager.scala │   │   │   │   ├── DAGScheduler.scala │   │   │   │   ├── MapOutputTracker.scala │   │   │   │   ├── SparkConf.scala │   │   │   │   ├── SparkContext.scala │   │   │   │   ├── SparkEnv.scala │   │   │   │   ├── TaskContext.scala │   │   │   │   ├── TaskSchedulerImpl.scala │   │   │   │   └── TaskScheduler.scala │   │   │   └── 应用提交执行 │   │   │   ├── DAGScheduler.scala │   │   │   ├── ResultStage.scala │   │   │   ├── ResultTask.scala │   │   │   ├── ShuffleMapStage.scala │   │   │   ├── ShuffleMapTask.scala │   │   │   ├── Task.scala │   │   │   ├── TaskSetManager.scala │   │   │   ├── TaskSet.scala │   │   │   └── 应用提交 │   │   ├── 配置 │   │   │   ├── 参数配置 │   │   │   │   ├── faq │   │   │   │   ├── spark properties.md │   │   │   │   ├── 部署模式 │   │   │   │   ├── 行为策略 │   │   │   │   ├── 环境变量.md │   │   │   │   ├── 基础.md │   │   │   │   ├── 基础属性 │   │   │   │   └── 扩展 │   │   │   ├── 集群 │   │   │   │   ├── cdh │   │   │   │   ├── fusioninsight │   │   │   │   └── __init__.py │   │   │   ├── 内存模型 │   │   │   │   └── 统一内存模型.md │   │   │   └── 资源实例 │   │   │   ├── 内存管理.md │   │   │   └── 实例1.md │   │   └── 优化 │   │   └── 优化思路.md │   ├── graphx │   ├── hadoop │   ├── ml │   ├── scala-demo │   ├── spark │   │   ├── Example │   │   ├── FSUtils │   │   ├── hdfs │   │   ├── RDD │   │   ├── SparkSQL │   │   ├── sparkStreaming │   ├── spark-rdd │   │   ├── files │   │   │   ├── action │   │   │   │   └── 行动.md │   │   │   ├── baseRdd │   │   │   │   ├── rdd创建.md │   │   │   │   ├── 保存.md │   │   │   │   ├── 拆组.md │   │   │   │   ├── 分区.md │   │   │   │   ├── 分组排序.md │   │   │   │   ├── 聚合.md │   │   │   │   └── 筛选.md │   │   │   ├── core │   │   │   │   └── rdd │   │   │   ├── faq │   │   │   │   ├── 参数处理.txt │   │   │   │   ├── 构建df.md │   │   │   │   └── 构建rdd.md │   │   │   ├── kvRdd │   │   │   │   └── kv-api.md │   │   │   ├── rdd.km │   │   │   ├── spark rdd api.txt │   │   │   ├── Tranformation&Action.txt │   │   │   └── UserLocation.scala │   ├── spark-streaming │   ├── spark-warehouse │   ├── sql ```