R
- The type of the result from the unit of work.public static class Transaction.Workload<R> extends Object
Transaction.Workload
represents a unit of work constructed by the Transaction.submit(Function)
method on
the Transaction
interface. The unit of work is a Function
typically containing mutations to
the Graph
. The Transaction.Workload
is responsible for executing the unit of work in the context of a
retry strategy, such that a failed unit of work is rolled back and executed again until retries are exhausted
or the unit of work succeeds with a commit operation.Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_DELAY_MS |
static int |
DEFAULT_TRIES |
Constructor and Description |
---|
Workload(Graph g,
Function<Graph,R> work)
Creates a new
Transaction.Workload that will be tried to be executed within a transaction. |
Modifier and Type | Method and Description |
---|---|
R |
attempt(BiFunction<Graph,Function<Graph,R>,R> retryStrategy)
Try to execute a
Transaction.Workload with a mapper retry strategy. |
R |
exponentialBackoff()
Executes the
Transaction.Workload with the default number of retries and with a exponentially increasing
number of milliseconds between each retry using the default retry delay. |
R |
exponentialBackoff(int tries)
Executes the
Transaction.Workload with a number of retries and with a exponentially increasing number of
milliseconds between each retry using the default retry delay. |
R |
exponentialBackoff(int tries,
long initialDelay)
Executes the
Transaction.Workload with a number of retries and with a exponentially increasing number of
milliseconds between each retry. |
R |
exponentialBackoff(int tries,
long initialDelay,
Set<Class> exceptionsToRetryOn)
Executes the
Transaction.Workload with a number of retries and with a exponentially increasing number of
milliseconds between each retry. |
R |
fireAndForget()
Executes the
Transaction.Workload committing if possible and rolling back on failure. |
R |
oneAndDone()
Executes the
Transaction.Workload committing if possible and rolling back on failure. |
R |
retry()
Executes the
Transaction.Workload with the default number of retries and with the default number of
milliseconds delay between each try. |
R |
retry(int tries)
Executes the
Transaction.Workload with a number of retries and with the default number of milliseconds delay
between each try. |
R |
retry(int tries,
long delay)
Executes the
Transaction.Workload with a number of retries and with a number of milliseconds delay between
each try. |
R |
retry(int tries,
long delay,
Set<Class> exceptionsToRetryOn)
Executes the
Transaction.Workload with a number of retries and with a number of milliseconds delay between each
try and will only retry on the set of supplied exceptions. |
public static final long DEFAULT_DELAY_MS
public static final int DEFAULT_TRIES
public Workload(Graph g, Function<Graph,R> work)
Transaction.Workload
that will be tried to be executed within a transaction.g
- The Graph
instance on which the work will be performed.work
- The work to be executed on the Graph instance which will optionally return a value.public R attempt(BiFunction<Graph,Function<Graph,R>,R> retryStrategy)
Transaction.Workload
with a mapper retry strategy.retryStrategy
- The first argument to this function is the Graph instance and the second is
the encapsulated work to be performed. The function should ultimately return the
result of the encapsulated work function.public R oneAndDone()
Transaction.Workload
committing if possible and rolling back on failure. On failure, an exception
is reported.public R fireAndForget()
Transaction.Workload
committing if possible and rolling back on failure. On failure no exception
is reported.public R retry()
Transaction.Workload
with the default number of retries and with the default number of
milliseconds delay between each try.public R retry(int tries)
Transaction.Workload
with a number of retries and with the default number of milliseconds delay
between each try.public R retry(int tries, long delay)
Transaction.Workload
with a number of retries and with a number of milliseconds delay between
each try.public R retry(int tries, long delay, Set<Class> exceptionsToRetryOn)
Transaction.Workload
with a number of retries and with a number of milliseconds delay between each
try and will only retry on the set of supplied exceptions. Exceptions outside of that set will generate a
RuntimeException and immediately fail.public R exponentialBackoff()
Transaction.Workload
with the default number of retries and with a exponentially increasing
number of milliseconds between each retry using the default retry delay.public R exponentialBackoff(int tries)
Transaction.Workload
with a number of retries and with a exponentially increasing number of
milliseconds between each retry using the default retry delay.public R exponentialBackoff(int tries, long initialDelay)
Transaction.Workload
with a number of retries and with a exponentially increasing number of
milliseconds between each retry.public R exponentialBackoff(int tries, long initialDelay, Set<Class> exceptionsToRetryOn)
Transaction.Workload
with a number of retries and with a exponentially increasing number of
milliseconds between each retry. It will only retry on the set of supplied exceptions. Exceptions outside
of that set will generate a RuntimeException
and immediately fail.Copyright © 2013–2016 Apache Software Foundation. All rights reserved.