本文整理了Java中com.metamx.common.guava.YieldingAccumulator.accumulate()方法的一些代码示例，展示了YieldingAccumulator.accumulate()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。YieldingAccumulator.accumulate()方法的具体详情如下：
包路径：com.metamx.common.guava.YieldingAccumulator
类名称：YieldingAccumulator
方法名：accumulate

YieldingAccumulator.accumulate介绍

暂无

代码示例

代码示例来源：origin: com.metamx/java-util

@Override
 public OutType accumulate(OutType accumulated, T in)
 {
  if (count < limit) {
   count++;
   return delegate.accumulate(accumulated, in);
  }
  return accumulated;
 }
}

代码示例来源：origin: com.metamx/java-util

@Override
 public OutType accumulate(OutType accumulated, T in)
 {
  return delegate.accumulate(accumulated, in);
 }
}

代码示例来源：origin: metamx/java-util

@Override
 public OutType accumulate(OutType accumulated, T in)
 {
  return delegate.accumulate(accumulated, in);
 }
}

代码示例来源：origin: metamx/java-util

@Override
 public OutType accumulate(OutType accumulated, T in)
 {
  if (count < limit) {
   count++;
   return delegate.accumulate(accumulated, in);
  }
  return accumulated;
 }
}

代码示例来源：origin: com.metamx/java-util

@Override
 public OutType accumulate(OutType accumulated, InType in)
 {
  return baseAccumulator.accumulate(accumulated, fn.apply(in));
 }
}

代码示例来源：origin: com.metamx/java-util

@Override
 public OutType accumulate(OutType accumulated, T in)
 {
  if (pred.apply(in)) {
   if (!didSomething) {
    didSomething = true;
   }
   return accumulator.accumulate(accumulated, in);
  }
  return accumulated;
 }
}

代码示例来源：origin: metamx/java-util

@Override
 public OutType accumulate(OutType accumulated, InType in)
 {
  return baseAccumulator.accumulate(accumulated, fn.apply(in));
 }
}

代码示例来源：origin: metamx/java-util

@Override
 public OutType accumulate(OutType accumulated, T in)
 {
  if (pred.apply(in)) {
   if (!didSomething) {
    didSomething = true;
   }
   return accumulator.accumulate(accumulated, in);
  }
  return accumulated;
 }
}

代码示例来源：origin: com.n3twork.druid/druid-common

@Override
 public T accumulate(T prevValue, T t)
 {
  if (prevValue == null) {
   return mergeFn.apply(t, null);
  }
  if (ordering.compare(prevValue, t) == 0) {
   return mergeFn.apply(prevValue, t);
  }
  retVal = accumulator.accumulate(retVal, prevValue);
  return t;
 }
}

代码示例来源：origin: com.metamx/java-util

retVal = accumulator.accumulate(retVal, iter.next());

代码示例来源：origin: metamx/java-util

retVal = accumulator.accumulate(retVal, iter.next());

代码示例来源：origin: com.n3twork.druid/druid-processing

@Override
 public <OutType> Yielder<OutType> toYielder(OutType initValue, YieldingAccumulator<OutType, T> accumulator)
 {
  List<T> results = Sequences.toList(baseSequence, Lists.<T>newArrayList());
  final OutType retVal = accumulator.accumulate(
    initValue,
    (T) new Result<BySegmentResultValueClass<T>>(
      timestamp,
      new BySegmentResultValueClass<T>(
        results,
        segmentIdentifier,
        query.getIntervals().get(0)
      )
    )
  );
  return Yielders.done(retVal, null);
 }
};

代码示例来源：origin: com.metamx/java-util

while (!accumulator.yielded() && !pQueue.isEmpty()) {
 Yielder<T> yielder = pQueue.remove();
 retVal = accumulator.accumulate(retVal, yielder.get());
 yielder = yielder.next(null);
 if (yielder.isDone()) {

代码示例来源：origin: metamx/java-util

while (!accumulator.yielded() && !pQueue.isEmpty()) {
 Yielder<T> yielder = pQueue.remove();
 retVal = accumulator.accumulate(retVal, yielder.get());
 yielder = yielder.next(null);
 if (yielder.isDone()) {

代码示例来源：origin: com.n3twork.druid/druid-common

@Override
public Yielder<OutType> next(OutType outType)
{
 T nextIn = yielder.get();
 combiningAccumulator.setRetVal(outType);
 final Yielder<T> baseYielder = yielder.next(nextIn);
 if (baseYielder.isDone()) {
  final OutType outValue = combiningAccumulator.getAccumulator().accumulate(outType, baseYielder.get());
  return Yielders.done(outValue, baseYielder);
 }
 return makeYielder(baseYielder, combiningAccumulator);
}

代码示例来源：origin: com.n3twork.druid/druid-common

retVal = accumulator.accumulate(retVal, yielder.get());
yielder = yielder.next(null);
if (yielder.isDone()) {