Uses of Interface
org.apache.hadoop.util.functional.CallableRaisingIOE

Packages that use CallableRaisingIOE

Package	Description
org.apache.hadoop.fs.impl	This package contains implementation classes for use inside filesystems.
org.apache.hadoop.fs.statistics.impl	Implementation support for statistics.
org.apache.hadoop.fs.store.audit	Auditing classes for internal use within the hadoop-* modules only.
org.apache.hadoop.util.functional	Support for functional programming within the Hadoop APIs.

Uses of CallableRaisingIOE in org.apache.hadoop.fs.impl

Methods in org.apache.hadoop.fs.impl with parameters of type CallableRaisingIOE

Modifier and Type	Method	Description
static <T> CompletableFuture<T>	FutureIOSupport.eval(CallableRaisingIOE<T> callable)	Deprecated. Evaluate a CallableRaisingIOE in the current thread, converting IOEs to RTEs and propagating.

Uses of CallableRaisingIOE in org.apache.hadoop.fs.statistics.impl

Methods in org.apache.hadoop.fs.statistics.impl that return CallableRaisingIOE

Modifier and Type	Method	Description
static <B> CallableRaisingIOE<B>	IOStatisticsBinding.trackDurationOfOperation(DurationTrackerFactory factory, String statistic, CallableRaisingIOE<B> input)	Given an IOException raising callable/lambda expression, return a new one which wraps the inner and tracks the duration of the operation, including whether it passes/fails.

Methods in org.apache.hadoop.fs.statistics.impl with parameters of type CallableRaisingIOE

Modifier and Type	Method	Description
static <B> B	IOStatisticsBinding.invokeTrackingDuration(DurationTracker tracker, CallableRaisingIOE<B> input)	Given an IOException raising callable/lambda expression, execute it, updating the tracker on success/failure.
static <B> B	IOStatisticsBinding.trackDuration(DurationTrackerFactory factory, String statistic, CallableRaisingIOE<B> input)	Given an IOException raising callable/lambda expression, execute it and update the relevant statistic.
static <B> CallableRaisingIOE<B>	IOStatisticsBinding.trackDurationOfOperation(DurationTrackerFactory factory, String statistic, CallableRaisingIOE<B> input)	Given an IOException raising callable/lambda expression, return a new one which wraps the inner and tracks the duration of the operation, including whether it passes/fails.

Uses of CallableRaisingIOE in org.apache.hadoop.fs.store.audit

Methods in org.apache.hadoop.fs.store.audit that return CallableRaisingIOE

Modifier and Type	Method	Description
static <T> CallableRaisingIOE<T>	AuditingFunctions.withinAuditSpan(AuditSpan auditSpan, CallableRaisingIOE<T> operation)	Given a callable, return a new callable which activates and deactivates the span around the inner invocation.

Methods in org.apache.hadoop.fs.store.audit with parameters of type CallableRaisingIOE

Modifier and Type	Method	Description
static <T> CallableRaisingIOE<T>	AuditingFunctions.withinAuditSpan(AuditSpan auditSpan, CallableRaisingIOE<T> operation)	Given a callable, return a new callable which activates and deactivates the span around the inner invocation.

Uses of CallableRaisingIOE in org.apache.hadoop.util.functional

Classes in org.apache.hadoop.util.functional that implement CallableRaisingIOE

Modifier and Type	Class	Description
class	LazyAtomicReference<T>	A lazily constructed reference, whose reference constructor is a CallableRaisingIOE so may raise IOExceptions.
class	LazyAutoCloseableReference<T extends AutoCloseable>	A subclass of LazyAtomicReference which holds an AutoCloseable reference and calls close() when it itself is closed.

Methods in org.apache.hadoop.util.functional that return CallableRaisingIOE

Modifier and Type	Method	Description
protected CallableRaisingIOE<? extends T>	LazyAtomicReference.getConstructor()	Getter for the constructor.

Methods in org.apache.hadoop.util.functional with parameters of type CallableRaisingIOE

Modifier and Type	Method	Description
static <T> CompletableFuture<T>	FutureIO.eval(CallableRaisingIOE<T> callable)	Evaluate a CallableRaisingIOE in the current thread, converting IOEs to RTEs and propagating.
static <S> RemoteIterator<S>	RemoteIterators.haltableRemoteIterator(RemoteIterator<S> iterator, CallableRaisingIOE<Boolean> continueWork)	Wrap an iterator with one which adds a continuation probe.
static <T> Supplier<T>	FunctionalIO.toUncheckedIOExceptionSupplier(CallableRaisingIOE<T> call)	Wrap a CallableRaisingIOE as a Supplier.
static <T> T	FunctionalIO.uncheckIOExceptions(CallableRaisingIOE<T> call)	Invoke any operation, wrapping IOExceptions with UncheckedIOException.

Constructors in org.apache.hadoop.util.functional with parameters of type CallableRaisingIOE

Modifier	Constructor	Description
	LazyAtomicReference(CallableRaisingIOE<? extends T> constructor)	Constructor for this instance.
	LazyAutoCloseableReference(CallableRaisingIOE<? extends T> constructor)	Constructor for this instance.