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
All Methods Static Methods Concrete Methods 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)
-
-
-
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
@SafeVarargs public static <I> Tasks.Builder<I> foreach(I... items)
-
foreach
public static <I> Tasks.Builder<I> foreach(java.util.stream.Stream<I> items)
-
-