Uses of Interface
org.apache.hadoop.fs.statistics.DurationTrackerFactory
Packages that use DurationTrackerFactory
Package
Description
block caching for use in object store clients.
This package contains support for statistic collection and reporting.
Implementation support for statistics.
Common utilities.
-
Uses of DurationTrackerFactory in org.apache.hadoop.fs.impl.prefetch
Methods in org.apache.hadoop.fs.impl.prefetch that return DurationTrackerFactoryMethods in org.apache.hadoop.fs.impl.prefetch with parameters of type DurationTrackerFactoryModifier and TypeMethodDescriptionprotected BlockCacheCachingBlockManager.createCache(int maxBlocksCount, DurationTrackerFactory trackerFactory) BlockManagerParameters.withTrackerFactory(DurationTrackerFactory factory) Sets the duration tracker with statistics to update.Constructors in org.apache.hadoop.fs.impl.prefetch with parameters of type DurationTrackerFactoryModifierConstructorDescriptionSingleFilePerBlockCache(PrefetchingStatistics prefetchingStatistics, int maxBlocksCount, DurationTrackerFactory trackerFactory) Constructs an instance of aSingleFilePerBlockCache. -
Uses of DurationTrackerFactory in org.apache.hadoop.fs.statistics
Methods in org.apache.hadoop.fs.statistics that return DurationTrackerFactoryModifier and TypeMethodDescriptionstatic DurationTrackerFactoryIOStatisticsSupport.stubDurationTrackerFactory()Return a stub duration tracker factory whose returned trackers are always no-ops. -
Uses of DurationTrackerFactory in org.apache.hadoop.fs.statistics.impl
Subinterfaces of DurationTrackerFactory in org.apache.hadoop.fs.statistics.implModifier and TypeInterfaceDescriptioninterfaceInterface of an IOStatistics store intended for use in classes which track statistics for reporting.Classes in org.apache.hadoop.fs.statistics.impl that implement DurationTrackerFactoryModifier and TypeClassDescriptionclassThis may seem odd having an IOStatisticsStore which does nothing but forward to a wrapped store, but it's designed to assist in subclassing of selective methods, such as those to increment counters, get durations etc.final classThis is a stub factory which always returns no-op duration trackers.Methods in org.apache.hadoop.fs.statistics.impl that return DurationTrackerFactoryModifier and TypeMethodDescriptionstatic DurationTrackerFactoryIOStatisticsBinding.pairedTrackerFactory(DurationTrackerFactory first, DurationTrackerFactory second) Create a DurationTrackerFactory which aggregates the tracking of two other factories.Methods in org.apache.hadoop.fs.statistics.impl with parameters of type DurationTrackerFactoryModifier and TypeMethodDescriptionstatic DurationTrackerIOStatisticsBinding.createTracker(DurationTrackerFactory factory, String statistic) Create the tracker.static DurationIOStatisticsBinding.measureDurationOfInvocation(DurationTrackerFactory factory, String statistic, InvocationRaisingIOE input) Given an IOException raising callable/lambda expression, execute it and update the relevant statistic, returning the measured duration.static DurationTrackerFactoryIOStatisticsBinding.pairedTrackerFactory(DurationTrackerFactory first, DurationTrackerFactory second) Create a DurationTrackerFactory which aggregates the tracking of two other factories.static <B> BIOStatisticsBinding.trackDuration(DurationTrackerFactory factory, String statistic, CallableRaisingIOE<B> input) Given an IOException raising callable/lambda expression, execute it and update the relevant statistic.static <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.static <B> Callable<B>IOStatisticsBinding.trackDurationOfCallable(DurationTrackerFactory factory, String statistic, Callable<B> input) Given a callable/lambda expression, return a new one which wraps the inner and tracks the duration of the operation, including whether it passes/fails.static voidIOStatisticsBinding.trackDurationOfInvocation(DurationTrackerFactory factory, String statistic, InvocationRaisingIOE 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.static <B> BIOStatisticsBinding.trackDurationOfSupplier(DurationTrackerFactory factory, String statistic, Supplier<B> input) Given a Java supplier, evaluate it while tracking the duration of the operation and success/failure.static <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.static <A,B> Function<A, B> IOStatisticsBinding.trackJavaFunctionDuration(DurationTrackerFactory factory, String statistic, Function<A, B> inputFn) Given a java 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 DurationTrackerFactory in org.apache.hadoop.util
Constructors in org.apache.hadoop.util with parameters of type DurationTrackerFactoryModifierConstructorDescriptionSemaphoredDelegatingExecutor(ExecutorService executorDelegatee, int permitCount, boolean fair, DurationTrackerFactory trackerFactory) Instantiate.