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

Yielder.isDone介绍

[英]Returns true if this is the last Yielder in the chain. A Yielder that isDone() may return anything from both get() and next(), there is no contract and depending on those return values will likely lead to bugs. It will probably break your code to call next() on a Yielder that is done and expect something good from it. Once next() is called on this Yielder object, all further operations on this object are undefined.
[中]

代码示例

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

@Override
public boolean hasNext()
{
 return !yielder.isDone() && count < limit;
}

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

@Override
public boolean hasMore()
{
 return !rowYielder.isDone();
}

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

@Override
public boolean isDone()
{
 return baseYielder.isDone();
}

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

@Override
public boolean isDone()
{
 return baseYielder.isDone();
}

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

@Override
public boolean isDone()
{
 return baseYielder.isDone();
}

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

@Override
public boolean isDone()
{
 return !accumulator.didSomething() || yielder.isDone();
}

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

@Override
 public void serialize(Yielder yielder, final JsonGenerator jgen, SerializerProvider provider)
   throws IOException
 {
  try {
   jgen.writeStartArray();
   while (!yielder.isDone()) {
    final Object o = yielder.get();
    jgen.writeObject(o);
    yielder = yielder.next(null);
   }
   jgen.writeEndArray();
  }
  finally {
   yielder.close();
  }
 }
}

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

public Meta.Frame nextFrame(final long fetchOffset, final int fetchMaxRowCount)
{
 synchronized (lock) {
  ensure(State.RUNNING);
  Preconditions.checkState(fetchOffset == offset, "fetchOffset[%,d] != offset[%,d]", fetchOffset, offset);
  try {
   final List<Object> rows = new ArrayList<>();
   while (!yielder.isDone() && (fetchMaxRowCount < 0 || offset < fetchOffset + fetchMaxRowCount)) {
    rows.add(yielder.get());
    yielder = yielder.next(null);
    offset++;
   }
   final boolean done = yielder.isDone();
   if (done) {
    close();
   }
   return new Meta.Frame(fetchOffset, done, rows);
  }
  catch (Throwable t) {
   this.throwable = t;
   try {
    close();
   }
   catch (Throwable t1) {
    t.addSuppressed(t1);
   }
   throw t;
  }
 }
}

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

@Override
 public Yielder<T> accumulate(Yielder<T> accumulated, Sequence<T> in)
 {
  final Yielder<T> retVal = in.toYielder(
    null,
    new YieldingAccumulator<T, T>()
    {
     @Override
     public T accumulate(T accumulated, T in)
     {
      yield();
      return in;
     }
    }
  );
  if (retVal.isDone()) {
   try {
    retVal.close();
   }
   catch (IOException e) {
    throw Throwables.propagate(e);
   }
   return null;
  } else {
   yield();
  }
  return retVal;
 }
}

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

if (!yielder.isDone()) {
 queue.add(yielder);
} else {

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

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

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

while (!accumulator.yielded() && (!pQueue.isEmpty() || !oldDudeAtCrosswalk.isDone())) {
 Yielder<T> yielder;
 if (oldDudeAtCrosswalk.isDone()) {
  yielder = pQueue.remove();
 } else if (pQueue.isEmpty()) {
 if (yielder.isDone()) {
  try {
   yielder.close();

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

while (!yielder.isDone()) {
 final Object[] row = yielder.get();
 writer.writeRowStart();

代码示例来源：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: apache/incubator-druid

Assert.assertFalse(prefix, yielder.isDone());
  Assert.assertEquals(prefix, expectedSum, yielder.get().intValue());
Assert.assertTrue(prefix, yielder.isDone());
yielder.close();

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

while (!yielder.isDone()) {
 final SegmentAnalysis analysis = yielder.get();
 final DataSegment segment = segmentMap.get(analysis.getId());

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

private void check(String expected, Sequence<Integer> complex)
{
 List<Integer> combined = complex.toList();
 Assert.assertEquals(expected, combined.toString());
 Yielder<Integer> yielder = complex.toYielder(
   null,
   new YieldingAccumulator<Integer, Integer>()
   {
    @Override
    public Integer accumulate(Integer accumulated, Integer in)
    {
     yield();
     return in;
    }
   }
 );
 List<Integer> combinedByYielder = new ArrayList<>();
 while (!yielder.isDone()) {
  combinedByYielder.add(yielder.get());
  yielder = yielder.next(null);
 }
 Assert.assertEquals(expected, combinedByYielder.toString());
}

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

while (!yielder.isDone()) {
 result.add(yielder.get());
 yielder = yielder.next(null);

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

while (!yielder.isDone()) {
  final Pair<Integer, Integer> expectedVal = expectedVals.next();
  final Pair<Integer, Integer> actual = yielder.get();
Assert.assertTrue(yielder.isDone());
Assert.assertFalse(expectedVals.hasNext());
yielder.close();

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

final boolean finalFinalValue;
if (!yielder.isDone()) {
 retVal = combiningAccumulator.getRetVal();
 finalYielder = null;