Storm通过分组来指定数据的流向,主要指定了每个bolt消费哪个流,以及如何消费。
storm内置了7个分组方式,并提供了CustomStreamGrouping来创建自定义的分组方式。
1、随机分组 shuffleGrouping
这种方式会随机分发tuple给bolt的各个task,每个task接到到相同数量的tuple。
2、字段分组 fieldGrouping
按照...
分类:
其他好文 时间:
2015-06-17 15:27:40
阅读次数:
490
#include
#include
#include
#include
char *my_itoa(int value, char *s)
{
int sign;
int i = 0,j,k;
char *tmp = (char *)malloc(sizeof(char)*strlen(s));
if((sign=value) < 0) //记录符号,使value为正数
va...
分类:
其他好文 时间:
2015-06-17 15:24:47
阅读次数:
105
Time Limit: 2000/1000 MS (Java/Others) Memory Limit: 65536/32768 K (Java/Others)
Total Submission(s): 256935 Accepted Submission(s): 49653
Problem Description
I have a very simple probl...
分类:
其他好文 时间:
2015-06-17 15:25:27
阅读次数:
148
1. affluent 富裕的 // influent影响
2. ascribe √
3. assume √
4. conserve √
5. convey √
6. derive √
7. accelerate √
8. dominate 支配
9. accustom √ /...
分类:
其他好文 时间:
2015-06-17 15:25:11
阅读次数:
106
解决SSH自动断线,无响应的问题
在连接远程SSH服务的时候,经常会发生长时间后的断线,或者无响应(无法再键盘输入)。
总体来说有两个方法:
1、依赖ssh客户端定时发送心跳。
putty、SecureCRT、XShell都有这个功能,但是目测不太好用。
此外在Linux下:...
分类:
其他好文 时间:
2015-06-17 15:23:11
阅读次数:
190
译自ES官方对于JVM参数的建议,原文见:
https://www.elastic.co/guide/en/elasticsearch/guide/current/heap-sizing.html
目录
1
堆空间的配置方法2
把内存留一半给Lucene3
别超过32GB!4
swap(交换区)是性能终结者...
分类:
其他好文 时间:
2015-06-17 15:24:50
阅读次数:
403
关于asm上使用filesystemio_options初始化参数的问题...
分类:
其他好文 时间:
2015-06-17 15:23:29
阅读次数:
148
电子采购系统应用已有一段时间了,主要的模块都已应用,近期软件公司一直在做计划审批模块的开发工作。这个模块如果有ERP系统的话,可以直接从ERP中导入采购计划到采购系统中,而我们现有应用的系统中并没有这样的审批模块,所以才有下文。如果说没有ERP的审批模块,那么要采购的计划单要么由集团采购部统一进行导入,这样就会对采购部门增加很多工作量,这样来看显然是不行的。要么就需要开发一个这样的计划审批系统,而...
分类:
其他好文 时间:
2015-06-17 15:21:54
阅读次数:
133
字典树,顾名思义,就是一种对字母等字符串进行处理的一种特殊数据结构。说白了,就是二十六叉树。定义一个头指针,每次从头指针开始操作。
有两种常用的操作:
1.查询某个字符串的出现次数。
每个节点的count置为0,直到这个字符串结束,在末尾处count++.这样,就记录了该字符串的出现次数。
2.查询某个字符串特定序列出现的次数。
每个节点的count初始化为0,当读入...
分类:
其他好文 时间:
2015-06-17 15:21:18
阅读次数:
100
svn作为我们经常使用的版本管理服务器,在使用过程中经常需要通过clean up操作来完成本地文件与服务器文件信息及版本信息同步,然而有时会在执行清理命令时提示“清理失败,请执行清理”,并且提示的中文路径显示乱码。此问题大多是由于工作队列还有未执行完成的任务。
使用sqlLite客户端打开wc.db(这个一般在.svn目录下)数据库,清空表work_queue的数据即可。...
分类:
其他好文 时间:
2015-06-17 15:21:17
阅读次数:
400
现场报有一个功能走不下去,后台日志报错:java.sql.SQLException: ORA-01591: 锁被未决分布式事务处理 657.7.39336 持有。
解决方案:
rollback force '657.7.39336'; 执行可能会比较慢
或者
delete from sys.pending_trans$ where local_tran_id = '...
分类:
其他好文 时间:
2015-06-17 15:20:46
阅读次数:
449
已知strcpy函数的原型是:
char *strcpy(char *dst, const char *src);
实现strcpy函数解释为什么要返回char *假如考虑dst和src内存重叠的情况,strcpy该怎么实现
1.strcpy的实现代码
char * strcpy(char *dst,const char *src) //[1]
{
...
分类:
其他好文 时间:
2015-06-17 15:20:03
阅读次数:
120
本文分析的Kafka代码为kafka-0.8.2.1。另外,由于Kafka目前提供了两套Producer代码,一套是Scala版的旧版本;一套是Java版的新版本。虽然Kafka社区极力推荐大家使用Java版本的producer,但目前很多已有的程序还是调用了Scala版的API。今天我们就分析一下...
分类:
其他好文 时间:
2015-06-17 15:20:57
阅读次数:
145
正如Html需要CSS一样,我们的POI生成的Excel同样需要样式才能更完美的表现我们的数据。下面还是从简单的例子出发,学习和了解POI的样式设计。 一、我的位置。package com.myjava.poi;import java.io.FileOutputStream;import jav.....
分类:
其他好文 时间:
2015-06-17 15:21:04
阅读次数:
126
介于老师特别推荐的浪潮之巅,特地去看了看,写了点自己的看法。首先对全书有个比较简要的介绍好了:本书通过介绍AT&T、IBM、微软、苹果、google等IT公司的发展历史,揭示科技工业的胜败规律,说明这些公司是如何在每一次科技革命浪潮到来时站在浪尖,实现跨越式发展的。一共23章,给我印象最深的是第3章...
分类:
其他好文 时间:
2015-06-17 15:19:25
阅读次数:
115
下面是3台机子在同一时间段的网络带宽使用情况,从下面的三个图中可以看出,机器A的带宽使用情况很不稳定,忽高忽低,前一秒带宽使用1M,下一秒可能就达到20M,机器B和机器C的带宽使用情况明显就比较稳定,先看下面的截图:机器 - A机器 - B机器 - C关于机器A这种情况,我一开始以为硬盘问题,硬盘用...
分类:
其他好文 时间:
2015-06-17 15:17:53
阅读次数:
173