发布时间：2015-07-21 12:03:12

有关Storm的ack机制，详情大家可以参考&nbsp; <a target="_blank" href="http://blog.csdn.net/xeseo/article/details/17754825">http://blog.csdn.net/xeseo/article/details/17754825<br /><br /><span style="color:#000000;">在这里只说一下ack的具体实现（当然在这里继承的父类（storm API中的类 如IRichSpout）中不.........【阅读全文】

发布时间：2015-05-08 20:46:06

storm中要配置并行度，就必须要明白 workers、executors、tasks三个的区别：Workers (JVMs): 在一个节点上可以运行一个或多个独立的JVM 进程。一个Topology可以包含一个或多个worker(并行的跑在不同的machine上), 所以worker process就是执行一个topology的子集, 并且worker只能对应于一个topology;worker processes的数.........【阅读全文】

发布时间：2015-05-07 22:30:56

1.对storm中传递类型的解释（大家如果不想看也可以直接跳到第二部分，不过看看是很有好处的）大家知道在storm中传递的是tuple，而tuple是没有定义数据类型格式的，也就是tuple是dynamically（动态）类型的，下面解释一下tuple为什么 要定义成动态类型的:一是因为tuple如果定义为静态类型，一定需要定义大量的stormAPI.........【阅读全文】

发布时间：2015-05-06 22:21:04

storm有多种数据分组策略，但是fieldsGrouping是比较难理解的一种，在这里说一下我的理解fieldsGroup是可以对相同的词进行分组计算，比如有好多词语进行计数，可以用public void declareOutputFields(OutputFieldsDeclarer declarer) {    declarer.declare(new Fields("word"));}这个方法中的”word.........【阅读全文】

发布时间：2015-03-24 17:18:39

java时间是1970开始计时的，c#是从元年开始计时的，算了不多说了直接代码了c#转java时间：c#是18位长，但是java时间为13位长，如果知道一个十八位的c#时间变量为time（time-621355968000000000）/10000（但是java编程中621355968000000000太长了超出了范围，所以可以先除以9个零在进行运算）然后再用java的Date类转成时间.........【阅读全文】