榜单
服务器优惠
AI论文
-
Storm 集群环境搭建
Storm集群环境搭建 一、集群规划 二、前置条件 三、集群搭建 1. 下载并解压 2. 配置环境变量 3. 集群配置 4. 安装包分发 四. 启动集群 4.1 启动ZooKeeper集群 4.2 启动Storm集群 4.3 查看集群 五、高可用验证 Storm集群环境搭建 一、集群规划 这里搭建一个 3 节点的 Stor... -
Storm 单机环境搭建
Storm单机版本环境搭建 1. 安装环境要求 2. 下载并解压 3. 配置环境变量 4. 启动相关进程 5. 验证是否启动成功 Storm单机版本环境搭建 1. 安装环境要求 you need to install Storm’s dependencies on Nimbus and the worker machines. The... -
Storm 和流处理简介
Storm和流处理简介 一、Storm 1.1 简介 1.2 Storm 与 Hadoop对比 1.3 Storm 与 Spark Streaming对比 1.4 Strom 与 Flink对比 二、流处理 2.1 静态数据处理 2.2 流处理 参考资料 Storm和流处理简介 一、Storm 1.1 简介 Storm 是一... -
Storm 集成 HDFS-HBase
Storm集成HDFS和HBase 一、Storm集成HDFS 1.1 项目结构 1.2 项目主要依赖 1.3 DataSourceSpout 1.4 将数据存储到HDFS 1.5 启动测试 二、Storm集成HBase 2.1 项目结构 2.2 项目主要依赖 2.3 DataSourceSpout 2.4 SplitBolt 2.5 C... -
使用 Maven 构建 Storm 应用
使用 Maven 构建 Storm 应用 Storm 开发 使用 Maven 构建 Storm 应用 在开发拓扑的时候，你需要在 classpath 中包含 Storm 的相关 jar 包。你可以将各个 jar 包直接包含到你的项目的 classpath 中，也可以使用 Maven 将 Storm 添加到依赖项中。Storm 已经集成到 Maven... -
定义 Storm 的非 JVM 语言 DSL
定义 Storm 的非 JVM 语言 DSL 定义 Storm 的非 JVM 语言 DSL 实现非 JVM 语言 DSL（Domain Specific Language，领域专用语言）应该从 storm-core/src/storm.thrift 文件开始。由于 Storm 拓扑是 Thrift 结构，而且 Nimbus 是一个 Thrift 后... -
理解 Storm 拓扑的并发数(parallelism)概念
理解 Storm 拓扑的并行度(parallelism)概念 一个运行中的拓扑是由什么构成的：工作进程（worker processes），执行器（executors）和任务（tasks） 配置拓扑的并行度（parallelism） Worker 数量 Executors（线程）数量 Tasks 数量 拓扑示例 如何修改运行中的拓扑的并行度 ... -
Storm 项目三种打包方式对比分析
Storm三种打包方式对比分析 一、简介 二、mvn package 2.1 mvn package的局限 2.2 解决办法 三、maven-assembly-plugin插件 1. 引入插件 2. 打包命令 四、maven-shade-plugin插件 4.1 官方文档说明 4.2 配置 4.3 打包命令 五、结论 六、打包注意事... -
序列化
序列化 动态类型 定制序列化 Java 序列化 特定组件的序列化注册 序列化 本文阐述了 Storm 0.6.0 以上版本的序列化机制。在低于 0.6.0 版本的 Storm 中使用了另一种序列化系统，详细信息可以参考 Serialization (prior to 0.6.0) 一文。 Storm 中的 tuple 可以包含任何类型的对... -
常用集合类型之 —— Map & Tuple
Map & Tuple 一、映射(Map) 1.1 构造Map 1.2 获取值 1.3 新增/修改/删除值 1.4 遍历Map 1.5 yield关键字 1.6 其他Map结构 1.7 可选方法 1.8 与Java互操作 二、元组(Tuple) 2.1 模式匹配 2.2 zip方法 参考资料 Map & Tuple 一...