Package org.apache.iceberg.util

Class Tasks

java.lang.Object

org.apache.iceberg.util.Tasks

public class Tasks
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Tasks.Builder<I>
static interface	Tasks.FailureTask<I,E extends Exception>
static interface	Tasks.Task<I,E extends 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(Iterable<I> items)
static <I> Tasks.Builder<I>	foreach(Iterator<I> items)
static <I> Tasks.Builder<I>	foreach(Stream<I> items)
static Tasks.Builder<Integer>	range(int upTo)

Methods inherited from class java.lang.Object

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

Method Details

range

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

foreach

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

foreach

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

foreach

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

foreach

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