io.druid.java.util.common.guava.Yielder.close()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-16 15:49:31 27 4

@Override
 public void close() throws IOException
 {
  yielder.close();
 }
};

@Override
public void close() throws IOException
{
 rowYielder.close();
}

@Override
 public void close() throws IOException
 {
  yielder.close();
 }
}

@Override
 public void close() throws IOException
 {
  try (Closeable toClose = yielderYielder) {
   yielder.close();
  }
 }
};

@Override
 public void close() throws IOException
 {
  boolean done = isDone();
  Throwable thrown = null;
  try {
   baseYielder.close();
  }
  catch (Throwable t) {
   thrown = t;
   throw t;
  }
  finally {
   if (done) {
    if (thrown != null) {
     try {
      executor.execute(runnable);
     }
     catch (Throwable t) {
      thrown.addSuppressed(t);
     }
    } else {
     executor.execute(runnable);
    }
   }
  }
 }
}

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

yielderYielder.close();

@Override
 public void close() throws IOException
 {
  boolean isDone;
  try {
   isDone = isDone();
   baseYielder.close();
  }
  catch (Throwable t) {
   // Close on failure
   try {
    wrapper.after(false, t);
   }
   catch (Exception e) {
    t.addSuppressed(e);
   }
   Throwables.propagateIfInstanceOf(t, IOException.class);
   throw Throwables.propagate(t);
  }
  // "Normal" close
  try {
   wrapper.after(isDone, null);
  }
  catch (Exception e) {
   Throwables.propagateIfInstanceOf(e, IOException.class);
   throw Throwables.propagate(e);
  }
 }
}

} else {
 try {
  yielder.close();

if (yielder.isDone()) {
 try {
  yielder.close();

OutType nextInit = yielder.get();
try {
 yielder.close();

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);
}

yielder.close();
throw Throwables.propagate(e);

27 4 0

• guava - Guava 是否带有命令行参数解析器

  这个问题不太可能帮助任何 future 的访客；它只与一个小地理区域、一个特定时刻或一个非常狭窄的情况相关，而这些情况通常不适用于互联网的全局受众。如需帮助使这个问题更广泛地适用，visit the

• guava - Guava TreeMultimap的Kotlin类型推断失败

  我有: data class Edge(val spec: String, val weight: Int) private val graph: SortedSetMultimap = TreeMu

• guava - Google Guava 缓存的默认最大大小是多少？

  鉴于使用以下代码创建的 Guava 缓存，如果未设置，是否有最大缓存大小？ LoadingCache loadingCache = CacheBuilder.newBuilder().build(ne

• guava - 将具有空值的键添加到 Guava Multimap

  我需要向 Guava Multimap 添加一个键，其中一个空集合作为值。我该如何做到这一点？ 我试过这个: map.put( "my key", null ); 但是调用 get() 会返回一个包含

• guava - 何时使用 Guava SameThreadExecutor

  我刚刚遇到这样的代码: ExecutorService executorService = MoreExecutors.sameThreadExecutor(); for (int i = 0; i

• guava - 我在哪里可以找到 Guava 中的原始数组？

  我使用的是来自 Google Collections 的 com.google.common.collect.PrimitiveArrays，但是我在 Guava 中找不到它，是否已重命名？我在哪里可

• guava - 使用 Google Guava 进行不区分大小写的过滤

  当前，我正在使用以下代码在映射中创建过滤器以匹配并提供过滤后的结果集列表。 final Map filteredMap = Maps.filterKeys(mymap, Predicates.cont

• android - 在模块 guava-20.0.jar (com.google.guava :guava:20. 0) 中找到重复的类 com.google.common.util.concurrent.ListenableFuture

  当我在 app/build.gradle 中使用 implementation 'com.google.firebase:firebase-inappmessaging-display:17.2.0'

• guava - 如何处理 Google Guava Cache 刷新异常？

  Google Guava Cache 文档指出: Refreshing is not quite the same as eviction. As specified in LoadingCache.

• guava - Guava 的 ImmutableList.Builder 线程安全吗？

  Guava 的 ImmutableList.Builder 的线程安全保证是什么？ javadocs 没有说。 最佳答案 虽然 Guava Immutable 类是线程安全的，但它们的构建器不是。对于

• guava - EventBus google guava 关闭 Hook

  目前我在我的应用程序中使用 guava EventBus 方法。监听器尝试做一些工作，如果失败，事件应该回到总线并重新发送。 我的问题是:如果我的应用程序出现故障(执行关闭)怎么办？它会在总线上发送剩

• guava - Kotlin:使用 google-guava 静态方法作为扩展

  是否可以使用现有的 java 静态方法作为开箱即用的扩展？ 让我们考虑 com.google.common.collect.Iterables.transform。现在，因为我不知道如何处理这个问题，

• java - Guava - map 支持的 Guava 功能

  我想创建一个由 Guava 函数支持的只读 map 。我有一个提供值的函数，给定一个键。 Function f = new Function() { public Object apply(f

• guava - 无法在 Eclipse 中导入 Guava 的 MoreAsserts

  我最近将 Google Guava 作为库添加到我的 Eclipse 项目中(我从 http://code.google.com/p/guava-libraries/ 下载了“guava-16.0.j

• maven - Drools 6 sisu-guava 与 Guava 冲突

  我们最近从 Drools 5 升级到 Drools 6 并遇到了令人不安的冲突问题。 我们有kie-ci导入到项目中。 kie-ci引进 sisu-guava . sisu-guava改变了谷歌 Gu

• guava - 为什么 Guava 会发出错误 "missing event handler for an > annotated method"？

  尝试取消注册时，我在我的一个类(class)中收到以下错误。 java.lang.IllegalArgumentException: missing event handler for an anno

• Gradle transient 依赖解析 : How to generically prefer `guava-jre` over `guava-android` ?

  我的项目传递依赖于 Google Guava lib。突然(使用新版本的 Guava ？)应用程序在启动时崩溃java.lang.NoSuchMethodError: 'java.util.strea

• guava - 为什么 Guava 中的 Iterables.find() 会抛出 NoSuchElementException，而不是返回 null？

  我喜欢 Google Guava 并且经常使用它，但是我总是发现我在写一种方法。 public static T tryFind(Iterable iterable, Predicate pred

• guava - Netflix 的 RxJava Observables 和 Guava 的 ListenableFutures 有区别吗？

  我使用的是普通的旧 Java 1.6，并且对这两个库都感兴趣。 阅读文档后，我不确定是否存在差异(如果有的话)。任何人都可以解释一下，或者指出一些相关信息吗？提前致谢! 最佳答案 RxJava 比 L

• java - 如何从 Guava 17 替换 Guava new MapMaker().softValues().makeMap()

  我用的是 Guava 17.0 private static final ConcurrentMap imageMap = new MapMaker().softValues().ma