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

YieldingAccumulator.accumulate介绍

暂无

代码示例

代码示例来源：origin: apache/incubator-druid

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

代码示例来源：origin: apache/incubator-druid

void accumulateLastValue()
{
 retVal = accumulator.accumulate(retVal, lastMergedVal);
}

代码示例来源：origin: apache/incubator-druid

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

代码示例来源：origin: apache/incubator-druid

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

代码示例来源：origin: apache/incubator-druid

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

代码示例来源：origin: apache/incubator-druid

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

代码示例来源：origin: apache/incubator-druid

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

代码示例来源：origin: apache/incubator-druid

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

代码示例来源：origin: org.apache.druid/java-util

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

代码示例来源：origin: org.apache.druid/druid-common

void accumulateLastValue()
{
 retVal = accumulator.accumulate(retVal, lastMergedVal);
}

代码示例来源：origin: org.apache.druid/java-util

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

代码示例来源：origin: org.apache.druid/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: org.apache.druid/druid-common

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

代码示例来源：origin: org.apache.druid/java-util

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

代码示例来源：origin: org.apache.druid/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: org.apache.druid/druid-common

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