Package | Description |
---|---|
org.apache.hadoop.fs |
Implementations of
AbstractFileSystem for hdfs
over rpc and hdfs over web. |
org.apache.hadoop.fs.statistics |
This package contains support for statistic collection and reporting.
|
org.apache.hadoop.io.compress | |
org.apache.hadoop.mapreduce.lib.output | |
org.apache.hadoop.mapreduce.lib.output.committer.manifest.files |
Persistence formats.
|
Modifier and Type | Method and Description |
---|---|
IOStatistics |
FSDataOutputStream.getIOStatistics()
Get the IO Statistics of the nested stream, falling back to
empty statistics if the stream does not implement the interface
IOStatisticsSource . |
IOStatistics |
FSDataInputStream.getIOStatistics()
Get the IO Statistics of the nested stream, falling back to
null if the stream does not implement the interface
IOStatisticsSource . |
Modifier and Type | Class and Description |
---|---|
class |
IOStatisticsSnapshot
Snapshot of statistics from a different source.
|
Modifier and Type | Method and Description |
---|---|
static IOStatistics |
IOStatisticsSupport.retrieveIOStatistics(Object source)
Get the IOStatistics of the source, casting it
if it is of the relevant type, otherwise,
if it implements
IOStatisticsSource
extracting the value. |
Modifier and Type | Method and Description |
---|---|
boolean |
IOStatisticsSnapshot.aggregate(IOStatistics source)
Aggregate the current statistics with the
source reference passed in.
|
boolean |
IOStatisticsAggregator.aggregate(IOStatistics statistics)
Aggregate the supplied statistics into the current
set.
|
static Object |
IOStatisticsLogging.demandStringifyIOStatistics(IOStatistics statistics)
On demand stringifier of an IOStatistics instance.
|
static DurationStatisticSummary |
DurationStatisticSummary.fetchDurationSummary(IOStatistics source,
String key,
boolean success)
Fetch the duration timing summary of success or failure operations
from an IO Statistics source.
|
static DurationStatisticSummary |
DurationStatisticSummary.fetchSuccessSummary(IOStatistics source,
String key)
Fetch the duration timing summary from an IOStatistics source.
|
static String |
IOStatisticsLogging.ioStatisticsToPrettyString(IOStatistics statistics)
Convert IOStatistics to a string form, with all the metrics sorted
and empty value stripped.
|
static String |
IOStatisticsLogging.ioStatisticsToString(IOStatistics statistics)
Convert IOStatistics to a string form.
|
void |
IOStatisticsSnapshot.snapshot(IOStatistics source)
Take a snapshot.
|
static IOStatisticsSnapshot |
IOStatisticsSupport.snapshotIOStatistics(IOStatistics statistics)
Take a snapshot of the current statistics state.
|
Constructor and Description |
---|
IOStatisticsSnapshot(IOStatistics source)
Construct, taking a snapshot of the source statistics data
if the source is non-null.
|
Modifier and Type | Method and Description |
---|---|
IOStatistics |
CompressionOutputStream.getIOStatistics()
Return any IOStatistics provided by the underlying stream.
|
IOStatistics |
CompressionInputStream.getIOStatistics()
Return any IOStatistics provided by the underlying stream.
|
Modifier and Type | Method and Description |
---|---|
IOStatistics |
BindingPathOutputCommitter.getIOStatistics() |
Modifier and Type | Method and Description |
---|---|
void |
ManifestSuccessData.snapshotIOStatistics(IOStatistics iostats)
Set the IOStatistics to a snapshot of the source.
|
Copyright © 2023 Apache Software Foundation. All rights reserved.