Package org.apache.iceberg.util

Class Tasks

java.lang.Object

org.apache.iceberg.util.Tasks

public class Tasks
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Tasks.Builder<I>
static interface	Tasks.FailureTask<I,E extends java.lang.Exception>
static interface	Tasks.Task<I,E extends java.lang.Exception>
static class	Tasks.UnrecoverableException

Method Summary

Modifier and Type	Method	Description
static <I> Tasks.Builder<I>	foreach(I... items)
static <I> Tasks.Builder<I>	foreach(java.lang.Iterable<I> items)
static <I> Tasks.Builder<I>	foreach(java.util.Iterator<I> items)
static <I> Tasks.Builder<I>	foreach(java.util.stream.Stream<I> items)
static Tasks.Builder<java.lang.Integer>	range(int upTo)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

range

public static Tasks.Builder<java.lang.Integer> range(int upTo)

foreach

public static <I> Tasks.Builder<I> foreach(java.util.Iterator<I> items)

foreach

public static <I> Tasks.Builder<I> foreach(java.lang.Iterable<I> items)

foreach

public static <I> Tasks.Builder<I> foreach(I... items)

foreach

public static <I> Tasks.Builder<I> foreach(java.util.stream.Stream<I> items)