Package org.apache.iceberg.util

Class Tasks.Builder<I>

java.lang.Object

org.apache.iceberg.util.Tasks.Builder<I>

Enclosing class:

Tasks

public static class Tasks.Builder<I>
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder(Iterable<I> items)

Method Summary

Modifier and Type	Method	Description
Tasks.Builder<I>	abortWith(Tasks.Task<I,?> task)
Tasks.Builder<I>	countAttempts(Counter counter)
Tasks.Builder<I>	executeWith(ExecutorService svc)
Tasks.Builder<I>	exponentialBackoff(long backoffMinSleepTimeMs, long backoffMaxSleepTimeMs, long backoffMaxRetryTimeMs, double backoffScaleFactor)
Tasks.Builder<I>	noRetry()
Tasks.Builder<I>	onFailure(Tasks.FailureTask<I,?> task)
Tasks.Builder<I>	onlyRetryOn(Class<? extends Exception> exception)
final Tasks.Builder<I>	onlyRetryOn(Class<? extends Exception>... exceptions)
Tasks.Builder<I>	retry(int nTimes)
Tasks.Builder<I>	revertWith(Tasks.Task<I,?> task)
<E extends Exception> boolean	run(Tasks.Task<I,E> task, Class<E> exceptionClass)
boolean	run(Tasks.Task<I,RuntimeException> task)
Tasks.Builder<I>	shouldRetryTest(Predicate<Exception> shouldRetry)
Tasks.Builder<I>	stopAbortsOnFailure()
Tasks.Builder<I>	stopOnFailure()
final Tasks.Builder<I>	stopRetryOn(Class<? extends Exception>... exceptions)
Tasks.Builder<I>	stopRevertsOnFailure()
Tasks.Builder<I>	suppressFailureWhenFinished()
Tasks.Builder<I>	throwFailureWhenFinished()
Tasks.Builder<I>	throwFailureWhenFinished(boolean throwWhenFinished)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder(Iterable<I> items)

Method Details

executeWith

public Tasks.Builder<I> executeWith(ExecutorService svc)

onFailure

public Tasks.Builder<I> onFailure(Tasks.FailureTask<I,?> task)

stopOnFailure

public Tasks.Builder<I> stopOnFailure()

throwFailureWhenFinished

public Tasks.Builder<I> throwFailureWhenFinished()

throwFailureWhenFinished

public Tasks.Builder<I> throwFailureWhenFinished(boolean throwWhenFinished)

suppressFailureWhenFinished

public Tasks.Builder<I> suppressFailureWhenFinished()

revertWith

public Tasks.Builder<I> revertWith(Tasks.Task<I,?> task)

stopRevertsOnFailure

public Tasks.Builder<I> stopRevertsOnFailure()

abortWith

public Tasks.Builder<I> abortWith(Tasks.Task<I,?> task)

stopAbortsOnFailure

public Tasks.Builder<I> stopAbortsOnFailure()

stopRetryOn

@SafeVarargs
public final Tasks.Builder<I> stopRetryOn(Class<? extends Exception>... exceptions)

shouldRetryTest

public Tasks.Builder<I> shouldRetryTest(Predicate<Exception> shouldRetry)

noRetry

public Tasks.Builder<I> noRetry()

retry

public Tasks.Builder<I> retry(int nTimes)

onlyRetryOn

public Tasks.Builder<I> onlyRetryOn(Class<? extends Exception> exception)

onlyRetryOn

@SafeVarargs
public final Tasks.Builder<I> onlyRetryOn(Class<? extends Exception>... exceptions)

countAttempts

public Tasks.Builder<I> countAttempts(Counter counter)

exponentialBackoff

public Tasks.Builder<I> exponentialBackoff(long backoffMinSleepTimeMs,
 long backoffMaxSleepTimeMs,
 long backoffMaxRetryTimeMs,
 double backoffScaleFactor)

run

public boolean run(Tasks.Task<I,RuntimeException> task)

run

public <E extends Exception> boolean run(Tasks.Task<I,E> task,
 Class<E> exceptionClass)
                                  throws E

Throws:

E extends Exception