Uses of Interface
org.apache.hadoop.util.functional.ConsumerRaisingIOE
Packages that use ConsumerRaisingIOE
Package
Description
Implementation support for statistics.
Support for functional programming within the Hadoop APIs.
-
Uses of ConsumerRaisingIOE in org.apache.hadoop.fs.statistics.impl
Methods in org.apache.hadoop.fs.statistics.impl that return ConsumerRaisingIOEModifier and TypeMethodDescriptionstatic <B> ConsumerRaisingIOE<B>IOStatisticsBinding.trackDurationConsumer(DurationTrackerFactory factory, String statistic, ConsumerRaisingIOE<B> input) Given an IOException raising Consumer, 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 ConsumerRaisingIOEModifier and TypeMethodDescriptionstatic <B> ConsumerRaisingIOE<B>IOStatisticsBinding.trackDurationConsumer(DurationTrackerFactory factory, String statistic, ConsumerRaisingIOE<B> input) Given an IOException raising Consumer, return a new one which wraps the inner and tracks the duration of the operation, including whether it passes/fails. -
Uses of ConsumerRaisingIOE in org.apache.hadoop.util.functional
Methods in org.apache.hadoop.util.functional that return ConsumerRaisingIOEModifier and TypeMethodDescriptiondefault ConsumerRaisingIOE<T>ConsumerRaisingIOE.andThen(ConsumerRaisingIOE<? super T> next) after callingaccept(Object), invoke the next consumer in the chain.Methods in org.apache.hadoop.util.functional with parameters of type ConsumerRaisingIOEModifier and TypeMethodDescriptiondefault ConsumerRaisingIOE<T>ConsumerRaisingIOE.andThen(ConsumerRaisingIOE<? super T> next) after callingaccept(Object), invoke the next consumer in the chain.static <T> longRemoteIterators.foreach(RemoteIterator<T> source, ConsumerRaisingIOE<? super T> consumer) Apply an operation to all values of a RemoteIterator.