萝卜地里的兔子 2016-10-26 03:06 采纳率: 50%
浏览 872
已采纳

stoem trident中无法理解的一段代码

源码是这样的
我看的是package storm.trident.state.map中的TransactionalMap

在更新方法中有这么一段代码
@Override
public List multiUpdate(List> keys, List updaters) {
List> curr = _backing.multiGet(keys);
List newVals = new ArrayList(curr.size());
List> newKeys = new ArrayList();
List ret = new ArrayList();
for(int i=0; i CachedBatchReadsMap.RetVal retval = curr.get(i);
TransactionalValue val = retval.val;
ValueUpdater updater = updaters.get(i);
TransactionalValue newVal;
boolean changed = false;
if(val==null) {
newVal = new TransactionalValue(_currTx, updater.update(null));
changed = true;
} else {

if(_currTx!=null && _currTx.equals(val.getTxid()) && !retval.cached) {

newVal = val;

}** else {

                newVal = new TransactionalValue<T>(_currTx, updater.update(val.getVal()));
                changed = true;
            }
        }
        ret.add(newVal.getVal());
        if(changed) {
            newVals.add(newVal);
            newKeys.add(keys.get(i));
        }
    }
    if(!newKeys.isEmpty()) {
        _backing.multiPut(newKeys, newVals);
    }
    return ret;
}

加黑的部分
if(_currTx!=null && _currTx.equals(val.getTxid()) && !retval.cached) {
newVal = val;
}
也就是上面的这一段,明明是事务性的,只要判断事务id不同就可以了,为什么还要去判断 !retval.cached呢?这个是有什么用

                        从而想问另外一个问题
                        CachedBatchReadsMap的作用是什么呢
  • 写回答

2条回答 默认 最新

  • 萝卜地里的兔子 2016-10-28 07:47
    关注

    哈哈,在我的朋友的帮助以及自己的努力下,已经获得了解答。谢谢大家了

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

悬赏问题

  • ¥15 ELGamal和paillier计算效率谁快?
  • ¥15 file converter 转换格式失败 报错 Error marking filters as finished,如何解决?
  • ¥15 ubuntu系统下挂载磁盘上执行./提示权限不够
  • ¥15 Arcgis相交分析无法绘制一个或多个图形
  • ¥15 关于#r语言#的问题:差异分析前数据准备,报错Error in data[, sampleName1] : subscript out of bounds请问怎么解决呀以下是全部代码:
  • ¥15 seatunnel-web使用SQL组件时候后台报错,无法找到表格
  • ¥15 fpga自动售货机数码管(相关搜索:数字时钟)
  • ¥15 用前端向数据库插入数据,通过debug发现数据能走到后端,但是放行之后就会提示错误
  • ¥30 3天&7天&&15天&销量如何统计同一行
  • ¥30 帮我写一段可以读取LD2450数据并计算距离的Arduino代码