一：函数操作 1.介绍 Tuple本身是不可变的 Function只是在原有的基础上追加新的tuple 2.说明 如果原来的字段是log，flag 新增之后的tuple可以访问这些字段，log,flag,orderId,orderAmt,memberId 3.先写驱动类 增加了解析 然后再将解析的日 ...
分类：
其他好文 时间：
2018-06-10 15:02:09
阅读次数：
170
1.过滤操作 只是判断某个tuple是否保留 无需跨网络，无需跨分区 不会改变tuple的结构，只是改变tuple的数量 2.需求 过滤掉不是订单的tuple。 其中订单中包含“IBEIfeng.gif”。 3.主驱动类 先过滤 后打印 4.过滤类 5.效果 ...
分类：
其他好文 时间：
2018-06-09 23:13:38
阅读次数：
180
1.项目结构 · 2.启动的服务 无 3.驱动程序 4.打印程序 5.效果 ...
分类：
其他好文 时间：
2018-06-09 22:12:13
阅读次数：
209
主流浏览器 内核 IE微软 trident Chrome谷歌 webkit/blink firefox火狐 Gecko Opera欧朋 presto Safari苹果 webkit ...
分类：
其他好文 时间：
2018-05-31 19:27:05
阅读次数：
157
Splitting a stream has no effect on the batch. If you join the stream back together, then yes, it will be the same batch. Tuples are passed between pa ...
分类：
其他好文 时间：
2018-05-27 10:43:15
阅读次数：
158
首先spout有三种：这些关系到相同的batchid里面是否包含相同的tuple 事务性：相同 模糊事务性：如果取不到原来的，则拿新的 无事务：不一定 所以只有事务性才能做到一个tuple唯一一次处理 模糊事务性 才能做到 最多处理一次 而无事务，则可能处理多次 ———————— 而在State这里 ...
分类：
其他好文 时间：
2018-05-27 00:59:15
阅读次数：
241
You can increase the batch size by changing "tridentKafkaConfig.fetchSizeBytes" property. Also, batch size is related with number of brokers and numbe ...
分类：
其他好文 时间：
2018-05-27 00:20:13
阅读次数：
199
trident里面 batch会被缓存，这样失败了可以重新发送 多个batch可以并行被process，但是commit是严格按照txid顺序来执行 一个batch的状态会存在zk里 只要batch在timeout时间内commit就算完成了，应该同时会清缓存 如果异常或超时了，就会replay 在 ...
分类：
其他好文 时间：
2018-05-24 12:00:30
阅读次数：
238
一、web标准 w3c：万维网联盟组织，用来制定web标准的组织 结构标准：html就是用来制作网页的 表现标准：css就是对网页进行美化的 行为标准：JS让网页动起来 二、浏览器介绍 IE浏览器的内核为 trident chrome浏览器的内核 blink 火狐浏览器内核 gecko safari ...
分类：
Web程序 时间：
2018-05-21 19:29:06
阅读次数：
235
1. 什么是浏览器内核? * 支持浏览器运行的最核心的程序 2. 不同的浏览器可能不太一样 * Chrome, Safari: webkit * firefox: Gecko * IE: Trident * 360,搜狗等国内浏览器: Trident + webkit 3. 内核由很多模块组成 * ...
分类：
其他好文 时间：
2018-05-20 14:07:12
阅读次数：
197
