Uses of Interface
org.apache.hadoop.util.functional.FunctionRaisingIOE
Packages that use FunctionRaisingIOE
Package
Description
Implementation support for statistics.
Auditing classes for internal
use within the hadoop-* modules only.
Support for dynamic access to filesystem operations which are not available
in older hadoop releases.
Support for functional programming within the Hadoop APIs.
-
Uses of FunctionRaisingIOE in org.apache.hadoop.fs.statistics.impl
Methods in org.apache.hadoop.fs.statistics.impl that return FunctionRaisingIOEModifier and TypeMethodDescriptionstatic <A,B> FunctionRaisingIOE<A, B> IOStatisticsBinding.trackFunctionDuration(DurationTrackerFactory factory, String statistic, FunctionRaisingIOE<A, B> inputFn) Given an IOException raising function/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 FunctionRaisingIOEModifier and TypeMethodDescriptionstatic <A,B> FunctionRaisingIOE<A, B> IOStatisticsBinding.trackFunctionDuration(DurationTrackerFactory factory, String statistic, FunctionRaisingIOE<A, B> inputFn) Given an IOException raising function/lambda expression, return a new one which wraps the inner and tracks the duration of the operation, including whether it passes/fails. -
Uses of FunctionRaisingIOE in org.apache.hadoop.fs.store.audit
Methods in org.apache.hadoop.fs.store.audit that return FunctionRaisingIOEModifier and TypeMethodDescriptionstatic <T,R> FunctionRaisingIOE<T, R> AuditingFunctions.withinAuditSpan(AuditSpan auditSpan, FunctionRaisingIOE<T, R> operation) Given a function, return a new function which activates and deactivates the span around the inner one.Methods in org.apache.hadoop.fs.store.audit with parameters of type FunctionRaisingIOEModifier and TypeMethodDescriptionstatic <T,R> FunctionRaisingIOE<T, R> AuditingFunctions.withinAuditSpan(AuditSpan auditSpan, FunctionRaisingIOE<T, R> operation) Given a function, return a new function which activates and deactivates the span around the inner one. -
Uses of FunctionRaisingIOE in org.apache.hadoop.io.wrappedio
Methods in org.apache.hadoop.io.wrappedio with parameters of type FunctionRaisingIOEModifier and TypeMethodDescriptionstatic <T> TWrappedStatistics.applyToIOStatisticsSnapshot(Serializable source, FunctionRaisingIOE<IOStatisticsSnapshot, T> fun) Apply a function to an object which may be an IOStatisticsSnapshot. -
Uses of FunctionRaisingIOE in org.apache.hadoop.util.functional
Methods in org.apache.hadoop.util.functional with parameters of type FunctionRaisingIOEModifier and TypeMethodDescriptionstatic <S> RemoteIterator<S>RemoteIterators.filteringRemoteIterator(RemoteIterator<S> iterator, FunctionRaisingIOE<? super S, Boolean> filter) Create a RemoteIterator from a RemoteIterator and a filter function which returns true for every element to be passed through.static <S,T> RemoteIterator<T> RemoteIterators.mappingRemoteIterator(RemoteIterator<S> iterator, FunctionRaisingIOE<? super S, T> mapper) Create an iterator from an iterator and a transformation function.static <T,R> Function<T, R> FunctionalIO.toUncheckedFunction(FunctionRaisingIOE<T, R> fun) Convert aFunctionRaisingIOEas aSupplier.