一：介绍 1.说明 Storm里面引入DRPC主要是利用storm的实时计算能力来并行化CPU intensive的计算。DRPC的storm topology以函数的参数流作为输入，而把这些函数调用的返回值作为topology的输出流。 2.工作机制 Distributed RPC是由一个”DPR ...
分类：
其他好文 时间：
2018-06-12 23:30:05
阅读次数：
275
1.项目结构 · 2.启动的服务 无 3.驱动程序 4.打印程序 5.效果 ...
分类：
其他好文 时间：
2018-06-09 22:12:13
阅读次数：
209
拓扑是研究几何图形或空间在连续改变形状后还能保持不变的一些性质的一个学科。它只考虑物体间的位置关系而不考虑它们的形状和大小。 拓扑是集合上的一种结构。 拓扑英文名是Topology，直译是地志学，最早指研究地形、地貌相类似的有关学科。几何拓扑学是十九世纪形成的一门数学分支，它属于几何学的范畴。 “代 ...
分类：
其他好文 时间：
2018-06-08 19:28:00
阅读次数：
288
本文介绍如何将表数据通过ODI导成CSV文件。一、源表准备工作1.1定义物理体系结构定义NewDataServerODI->Topology->PhysicalArchitecture，右击Oracle，选择”NewDataServer“，在Definition对话框中定义一个名称，输入Oracle实例名称以及用户信息，保存。接着在JDBC对话框中，选择JDBC驱动以及输入jdbc连接
分类：
数据库 时间：
2018-06-07 11:40:10
阅读次数：
173
conf.setNumWorkers(2); // 该Topology运行在Supervisor节点的2个Worker进程中 topologyBuilder.setSpout("blue spout", new BlueSpout(), 2); // 设置并行度为2，则Task个数为2 1 topo ...
分类：
其他好文 时间：
2018-05-28 15:02:55
阅读次数：
171
nimbus 是集群的管理节点 superviser ： 一个superviser 在一台机器上， 它本身是一个进程，有一个id 管理在同一机器上的 多个worker进程，每个worker进程只服务于一个topology，每个worker对外有一个port，用于接收数据； 一个worker内有多个e ...
分类：
其他好文 时间：
2018-05-28 13:47:53
阅读次数：
144
进到一个topology的页面， 里面有整体的stat， spout的情况 bolt的情况 其中b 0，负责的是数据持久化，如果这个有fail，那么会导致数据处理延迟 其他有少量fail，是没什么关系的 那如何查找某个具体是哪个spout和bolt，哪台机器，什么错？ 比如b 0有fail 那么点击 ...
分类：
其他好文 时间：
2018-05-27 23:40:55
阅读次数：
185
James Munkres "Topology" Chapter 1 Set Theory and Logic Chapter 1 Set Theory and Logic ...
分类：
其他好文 时间：
2018-05-20 10:39:17
阅读次数：
149
Storm Features Storm 简介 Storm Topology的并发度 Storm - Guaranteeing message processing Storm - Transactional-topologies Twitter Storm – DRPC Storm 多语言支持 S ...
分类：
其他好文 时间：
2018-05-15 14:06:04
阅读次数：
144
网络拓扑 (Topology) 结构是指用传输介质互连各种设备的物理布局。 星型拓扑结构（如图 1 、图 2 ） 星型网络由中心节点和其它从节点组成，中心节点可直接与从节点通信，而从节点间必须通过中心节点才能通信。在星型网络中中心节点通常由一种称为集线器或交换机的设备充当，因此网络上的计算机之间是通 ...
分类：
其他好文 时间：
2018-05-12 03:18:18
阅读次数：
200
