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

Yielders介绍

暂无

代码示例

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

@Override
 public <OutType> Yielder<OutType> toYielder(OutType initValue, YieldingAccumulator<OutType, Object> accumulator)
 {
  return Yielders.done(initValue, null);
 }
}

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

public DruidStatement execute()
{
 synchronized (lock) {
  ensure(State.PREPARED);
  try {
   final Sequence<Object[]> baseSequence = yielderOpenCloseExecutor.submit(
     sqlLifecycle::execute
   ).get();
   // We can't apply limits greater than Integer.MAX_VALUE, ignore them.
   final Sequence<Object[]> retSequence =
     maxRowCount >= 0 && maxRowCount <= Integer.MAX_VALUE
     ? baseSequence.limit((int) maxRowCount)
     : baseSequence;
   yielder = Yielders.each(retSequence);
   state = State.RUNNING;
  }
  catch (Throwable t) {
   this.throwable = t;
   try {
    close();
   }
   catch (Throwable t1) {
    t.addSuppressed(t1);
   }
   throw Throwables.propagate(t);
  }
  return this;
 }
}

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

@Override
public <OutType> Yielder<OutType> toYielder(
  final OutType initValue,
  final YieldingAccumulator<OutType, T> accumulator
)
{
 try {
  return makeYielder(baseSequence.toYielder(initValue, accumulator));
 }
 catch (SegmentMissingException e) {
  appendMissingSegment(responseContext);
  return Yielders.done(initValue, null);
 }
}

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

rowYielder = Yielders.each(rows);

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

return Yielders.done(
  retVal,
  new Closeable()

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

final Yielder<Object[]> yielder0 = Yielders.each(lifecycle.execute());

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

return Yielders.done(retVal, yielder);
} else {
 finalYielder = Yielders.done(null, yielder);
return Yielders.done(combiningAccumulator.getRetVal(), yielder);

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

final Yielder<?> yielder = Yielders.each(results);

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

return Yielders.done(retVal, null);

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

);
Yielder<SegmentAnalysis> yielder = Yielders.each(sequence);

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

public <OutType> Yielder<OutType> makeYielder(
  Yielder<Sequence<T>> yielderYielder,
  OutType initValue,
  YieldingAccumulator<OutType, T> accumulator
)
{
 while (!yielderYielder.isDone()) {
  Yielder<OutType> yielder = yielderYielder.get().toYielder(initValue, accumulator);
  if (accumulator.yielded()) {
   return wrapYielder(yielder, yielderYielder, accumulator);
  }
  initValue = yielder.get();
  try {
   yielder.close();
  }
  catch (IOException e) {
   throw Throwables.propagate(e);
  }
  yielderYielder = yielderYielder.next(null);
 }
 return Yielders.done(initValue, yielderYielder);
}

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

public DruidStatement execute()
{
 synchronized (lock) {
  ensure(State.PREPARED);
  try {
   final Sequence<Object[]> baseSequence = yielderOpenCloseExecutor.submit(
     () -> plannerResult.run()
   ).get();
   // We can't apply limits greater than Integer.MAX_VALUE, ignore them.
   final Sequence<Object[]> retSequence =
     maxRowCount >= 0 && maxRowCount <= Integer.MAX_VALUE
     ? baseSequence.limit((int) maxRowCount)
     : baseSequence;
   yielder = Yielders.each(retSequence);
   state = State.RUNNING;
  }
  catch (Throwable t) {
   try {
    close();
   }
   catch (Throwable t1) {
    t.addSuppressed(t1);
   }
   throw Throwables.propagate(t);
  }
  return this;
 }
}

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

return Yielders.done(retVal, oldDudeAtCrosswalk);

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

rowYielder = Yielders.each(rows);

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

@Override
 public <OutType> Yielder<OutType> toYielder(OutType initValue, YieldingAccumulator<OutType, Object> accumulator)
 {
  return Yielders.done(initValue, null);
 }
}

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

final Yielder<Object[]> yielder0 = Yielders.each(plannerResult.run());

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

@Override
public <OutType> Yielder<OutType> toYielder(
  final OutType initValue,
  final YieldingAccumulator<OutType, T> accumulator
)
{
 try {
  return makeYielder(baseSequence.toYielder(initValue, accumulator));
 }
 catch (SegmentMissingException e) {
  appendMissingSegment(responseContext);
  return Yielders.done(initValue, null);
 }
}

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

final Yielder<?> yielder = Yielders.each(results);

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

return Yielders.done(
  retVal,
  new Closeable()

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

);
Yielder<SegmentAnalysis> yielder = Yielders.each(sequence);