This is an automated email from the ASF dual-hosted git repository.
stevel pushed a change to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/hadoop.git.
from 8945268 HDFS-15672.
TestBalancerWithMultipleNameNodes#testBalancingBlockpoolsWithBlockPoolPolicy
fails on trunk. (#2475)
new 57abfae HADOOP-17450. Add Public IOStatistics API. (#2577)
new 5be4503 MAPREDUCE-7315. LocatedFileStatusFetcher to collect/publish
IOStatistics. (#2579)
new 240b253 HADOOP-17271. S3A connector to support IOStatistics. (#2580)
new 56576f0 HADOOP-17451. IOStatistics test failures in S3A code. (#2594)
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/hadoop/crypto/CryptoInputStream.java | 14 +-
.../apache/hadoop/crypto/CryptoOutputStream.java | 11 +-
.../apache/hadoop/fs/BufferedFSInputStream.java | 29 +-
.../org/apache/hadoop/fs/ChecksumFileSystem.java | 42 +-
.../org/apache/hadoop/fs/FSDataInputStream.java | 16 +-
.../org/apache/hadoop/fs/FSDataOutputStream.java | 17 +-
.../java/org/apache/hadoop/fs/FSInputStream.java | 22 +
.../org/apache/hadoop/fs/MultipartUploader.java | 8 +-
.../org/apache/hadoop/fs/RawLocalFileSystem.java | 96 +-
.../org/apache/hadoop/fs/StorageStatistics.java | 71 +-
.../org/apache/hadoop/fs/StreamCapabilities.java | 5 +
.../apache/hadoop/fs/impl/FunctionsRaisingIOE.java | 6 +-
.../org/apache/hadoop/fs/impl/FutureIOSupport.java | 67 +-
.../apache/hadoop/fs/impl/WrappedIOException.java | 5 +-
.../BufferedIOStatisticsInputStream.java | 85 ++
.../BufferedIOStatisticsOutputStream.java | 157 ++
.../fs/statistics/DurationStatisticSummary.java | 154 ++
.../hadoop/fs/statistics/DurationTracker.java | 54 +
.../fs/statistics/DurationTrackerFactory.java | 57 +
.../apache/hadoop/fs/statistics/IOStatistics.java | 78 +
.../fs/statistics/IOStatisticsAggregator.java | 42 +-
.../hadoop/fs/statistics/IOStatisticsLogging.java | 301 ++++
.../hadoop/fs/statistics/IOStatisticsSnapshot.java | 285 ++++
.../hadoop/fs/statistics/IOStatisticsSource.java | 35 +-
.../hadoop/fs/statistics/IOStatisticsSupport.java | 107 ++
.../apache/hadoop/fs/statistics/MeanStatistic.java | 290 ++++
.../hadoop/fs/statistics/StoreStatisticNames.java | 337 +++++
.../hadoop/fs/statistics/StreamStatisticNames.java | 292 ++++
.../statistics/impl/AbstractIOStatisticsImpl.java | 19 +-
.../fs/statistics/impl/DynamicIOStatistics.java | 132 ++
.../impl/DynamicIOStatisticsBuilder.java | 248 ++++
.../fs/statistics/impl/EmptyIOStatistics.java | 74 +
.../statistics/impl/EvaluatingStatisticsMap.java | 202 +++
.../fs/statistics/impl/IOStatisticsBinding.java | 616 ++++++++
.../fs/statistics/impl/IOStatisticsStore.java | 258 ++++
.../statistics/impl/IOStatisticsStoreBuilder.java | 75 +
.../impl/IOStatisticsStoreBuilderImpl.java | 100 ++
.../fs/statistics/impl/IOStatisticsStoreImpl.java | 469 ++++++
.../impl/PairedDurationTrackerFactory.java | 93 ++
.../statistics/impl/SourceWrappedStatistics.java | 30 +-
.../statistics/impl/StatisticDurationTracker.java | 106 ++
.../impl/StorageStatisticsFromIOStatistics.java | 121 ++
.../fs/statistics/impl/StubDurationTracker.java | 37 +-
.../impl/StubDurationTrackerFactory.java | 30 +-
.../fs/statistics/impl/WrappedIOStatistics.java | 108 ++
.../hadoop/fs/statistics/impl/package-info.java | 26 +-
.../apache/hadoop/fs/statistics/package-info.java | 134 ++
.../hadoop/io/compress/CompressionInputStream.java | 18 +-
.../io/compress/CompressionOutputStream.java | 14 +-
.../java/org/apache/hadoop/util/LineReader.java | 16 +-
.../org/apache/hadoop/util/OperationDuration.java | 52 +-
.../util/functional/BiFunctionRaisingIOE.java | 33 +-
.../hadoop/util/functional/CallableRaisingIOE.java | 29 +-
.../hadoop/util/functional/ConsumerRaisingIOE.java | 39 +-
.../hadoop/util/functional/FunctionRaisingIOE.java | 31 +-
.../functional/FutureIO.java} | 167 +--
.../util/functional/InvocationRaisingIOE.java | 31 +-
.../hadoop/util/functional/RemoteIterators.java | 698 +++++++++
.../hadoop/util/functional/package-info.java | 41 +
.../src/site/markdown/filesystem/index.md | 1 +
.../src/site/markdown/filesystem/iostatistics.md | 432 ++++++
.../AbstractContractMultipartUploaderTest.java | 3 +
.../AbstractContractStreamIOStatisticsTest.java | 313 ++++
.../TestLocalFSContractStreamIOStatistics.java | 80 ++
.../fs/statistics/IOStatisticAssertions.java | 528 +++++++
.../hadoop/fs/statistics/TestDurationTracking.java | 361 +++++
.../fs/statistics/TestDynamicIOStatistics.java | 311 ++++
.../fs/statistics/TestEmptyIOStatistics.java | 110 ++
.../fs/statistics/TestIOStatisticsSnapshot.java | 147 ++
.../fs/statistics/TestIOStatisticsStore.java | 177 +++
.../hadoop/fs/statistics/TestMeanStatistic.java | 219 +++
.../util/functional/TestRemoteIterators.java | 469 ++++++
.../hadoop/mapred/LocatedFileStatusFetcher.java | 60 +-
.../hadoop-aws/dev-support/findbugs-exclude.xml | 10 +
hadoop-tools/hadoop-aws/pom.xml | 4 +
.../java/org/apache/hadoop/fs/s3a/Constants.java | 7 +
.../hadoop/fs/s3a/DefaultS3ClientFactory.java | 207 ++-
.../hadoop/fs/s3a/InconsistentS3ClientFactory.java | 14 +-
.../java/org/apache/hadoop/fs/s3a/Invoker.java | 48 +-
.../java/org/apache/hadoop/fs/s3a/Listing.java | 288 ++--
.../apache/hadoop/fs/s3a/S3ABlockOutputStream.java | 64 +-
.../org/apache/hadoop/fs/s3a/S3ADataBlocks.java | 23 +-
.../org/apache/hadoop/fs/s3a/S3AFileSystem.java | 305 ++--
.../org/apache/hadoop/fs/s3a/S3AInputStream.java | 61 +-
.../apache/hadoop/fs/s3a/S3AInstrumentation.java | 1514 +++++++++++++-------
.../org/apache/hadoop/fs/s3a/S3AOpContext.java | 32 +-
.../org/apache/hadoop/fs/s3a/S3AReadOpContext.java | 10 +-
.../apache/hadoop/fs/s3a/S3AStorageStatistics.java | 99 +-
.../java/org/apache/hadoop/fs/s3a/S3AUtils.java | 8 +-
.../org/apache/hadoop/fs/s3a/S3ClientFactory.java | 5 +-
.../java/org/apache/hadoop/fs/s3a/Statistic.java | 640 ++++++---
.../apache/hadoop/fs/s3a/WriteOperationHelper.java | 17 +-
.../org/apache/hadoop/fs/s3a/WriteOperations.java | 5 +-
.../s3a/auth/delegation/S3ADelegationTokens.java | 14 +-
.../hadoop/fs/s3a/commit/AbstractS3ACommitter.java | 61 +-
.../hadoop/fs/s3a/commit/CommitOperations.java | 52 +-
.../fs/s3a/commit/MagicCommitIntegration.java | 10 +-
.../apache/hadoop/fs/s3a/commit/PutTracker.java | 5 +-
.../hadoop/fs/s3a/commit/files/PendingSet.java | 38 +-
.../fs/s3a/commit/files/SinglePendingCommit.java | 31 +-
.../hadoop/fs/s3a/commit/files/SuccessData.java | 31 +-
.../fs/s3a/commit/magic/MagicCommitTracker.java | 23 +-
.../fs/s3a/commit/magic/MagicS3GuardCommitter.java | 6 +
.../hadoop/fs/s3a/impl/ActiveOperationContext.java | 92 ++
.../hadoop/fs/s3a/impl/BulkDeleteRetryHandler.java | 5 +-
.../hadoop/fs/s3a/impl/CallableSupplier.java | 8 +-
.../apache/hadoop/fs/s3a/impl/ChangeTracker.java | 19 +-
.../hadoop/fs/s3a/impl/ErrorTranslation.java | 12 +
.../hadoop/fs/s3a/impl/InternalConstants.java | 7 +
.../fs/s3a/impl/ListingOperationCallbacks.java | 10 +-
.../apache/hadoop/fs/s3a/impl/NetworkBinding.java | 18 +-
.../hadoop/fs/s3a/impl/S3AMultipartUploader.java | 24 +-
.../fs/s3a/impl/S3AMultipartUploaderBuilder.java | 2 +-
.../apache/hadoop/fs/s3a/impl/StoreContext.java | 15 +-
.../hadoop/fs/s3a/impl/StoreContextBuilder.java | 6 +-
.../fs/s3a/s3guard/DynamoDBMetadataStore.java | 20 +-
.../hadoop/fs/s3a/s3guard/InternalIterators.java | 91 --
.../hadoop/fs/s3a/s3guard/RetryingCollection.java | 10 +-
.../hadoop/fs/s3a/select/SelectInputStream.java | 12 +-
.../statistics/BlockOutputStreamStatistics.java | 137 ++
.../ChangeTrackerStatistics.java} | 31 +-
.../fs/s3a/statistics/CommitterStatistics.java | 66 +
.../fs/s3a/statistics/CountersAndGauges.java | 72 +
.../DelegationTokenStatistics.java} | 21 +-
.../s3a/statistics/S3AInputStreamStatistics.java | 191 +++
.../statistics/S3AMultipartUploaderStatistics.java | 7 +-
.../S3AStatisticInterface.java} | 21 +-
.../fs/s3a/statistics/S3AStatisticsContext.java | 69 +
.../StatisticTypeEnum.java} | 31 +-
.../fs/s3a/statistics/StatisticsFromAwsSdk.java | 81 ++
.../impl/AbstractS3AStatisticsSource.java | 111 ++
.../statistics/impl/AwsStatisticsCollector.java | 129 ++
.../impl/BondedS3AStatisticsContext.java | 234 +++
.../statistics/impl/CountingChangeTracker.java} | 39 +-
.../statistics/impl/EmptyS3AStatisticsContext.java | 597 ++++++++
.../impl}/S3AMultipartUploaderStatisticsImpl.java | 46 +-
.../statistics/impl/StatisticsFromAwsSdkImpl.java | 88 ++
.../impl/package-info.java} | 24 +-
.../package-info.java} | 28 +-
.../org/apache/hadoop/fs/s3a/tools/MarkerTool.java | 12 +-
.../fs/contract/s3a/ITestS3AContractDistCp.java | 12 +-
.../apache/hadoop/fs/s3a/AbstractS3ATestBase.java | 23 +
.../fs/s3a/ITestLocatedFileStatusFetcher.java | 266 +++-
.../hadoop/fs/s3a/ITestS3ABlockOutputArray.java | 9 +-
.../org/apache/hadoop/fs/s3a/ITestS3AMetrics.java | 31 +-
.../hadoop/fs/s3a/ITestS3AMiscOperations.java | 8 +-
.../org/apache/hadoop/fs/s3a/ITestS3AUnbuffer.java | 105 +-
.../hadoop/fs/s3a/ITestS3GuardEmptyDirs.java | 2 +-
.../apache/hadoop/fs/s3a/MockS3AFileSystem.java | 20 +-
.../apache/hadoop/fs/s3a/MockS3ClientFactory.java | 5 +-
.../org/apache/hadoop/fs/s3a/S3ATestUtils.java | 11 +-
.../java/org/apache/hadoop/fs/s3a/TestListing.java | 54 +-
.../hadoop/fs/s3a/TestS3ABlockOutputStream.java | 8 +-
.../hadoop/fs/s3a/TestStreamChangeTracker.java | 7 +-
.../apache/hadoop/fs/s3a/auth/ITestAssumeRole.java | 13 +-
.../fs/s3a/auth/ITestRestrictedReadAccess.java | 2 +-
.../apache/hadoop/fs/s3a/auth/ProgressCounter.java | 8 +-
.../ITestSessionDelegationInFileystem.java | 17 +-
.../hadoop/fs/s3a/commit/AbstractCommitITest.java | 9 +-
.../fs/s3a/commit/AbstractITCommitProtocol.java | 25 +-
.../commit/integration/ITestS3ACommitterMRJob.java | 1 -
.../s3a/commit/staging/MockedStagingCommitter.java | 4 +-
.../fs/s3a/impl/ITestPartialRenamesDeletes.java | 21 +-
.../hadoop/fs/s3a/impl/TestNetworkBinding.java | 105 ++
.../hadoop/fs/s3a/impl/TestNeworkBinding.java | 61 -
.../fs/s3a/performance/AbstractS3ACostTest.java | 77 +-
.../fs/s3a/performance/ITestS3ADeleteCost.java | 47 +-
.../fs/s3a/performance/ITestS3ARenameCost.java | 30 +-
.../hadoop/fs/s3a/performance/OperationCost.java | 2 +
.../fs/s3a/performance/OperationCostValidator.java | 36 +-
...TestDynamoDBMetadataStoreAuthoritativeMode.java | 8 +-
.../s3guard/ITestDynamoDBMetadataStoreScale.java | 4 +-
.../fs/s3a/scale/AbstractSTestS3AHugeFiles.java | 52 +-
.../scale/ILoadTestS3ABulkDeleteThrottling.java | 11 -
.../fs/s3a/scale/ITestS3ADirectoryPerformance.java | 39 +-
.../s3a/scale/ITestS3AInputStreamPerformance.java | 94 +-
.../hadoop/fs/s3a/scale/S3AScaleTestBase.java | 16 +-
.../apache/hadoop/fs/s3a/select/ITestS3Select.java | 34 +-
.../hadoop/fs/s3a/select/ITestS3SelectLandsat.java | 6 +-
.../hadoop/fs/s3a/select/ITestS3SelectMRJob.java | 4 +-
.../s3a/statistics/ITestAggregateIOStatistics.java | 100 ++
.../ITestS3AContractStreamIOStatistics.java | 90 ++
.../s3a/test/MinimalListingOperationCallbacks.java | 12 +-
.../hadoop-aws/src/test/resources/log4j.properties | 8 +
184 files changed, 15217 insertions(+), 2239 deletions(-)
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/BufferedIOStatisticsInputStream.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/BufferedIOStatisticsOutputStream.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/DurationStatisticSummary.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/DurationTracker.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/DurationTrackerFactory.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/IOStatistics.java
copy
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/S3ClientFactory.java
=>
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/IOStatisticsAggregator.java
(53%)
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/IOStatisticsLogging.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/IOStatisticsSnapshot.java
copy
hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestLocatedFileStatusFetcher.java
=>
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/IOStatisticsSource.java
(52%)
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/IOStatisticsSupport.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/MeanStatistic.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/StoreStatisticNames.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/StreamStatisticNames.java
copy
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/impl/statistics/S3AMultipartUploaderStatistics.java
=>
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/AbstractIOStatisticsImpl.java
(69%)
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/DynamicIOStatistics.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/DynamicIOStatisticsBuilder.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/EmptyIOStatistics.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/EvaluatingStatisticsMap.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/IOStatisticsBinding.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/IOStatisticsStore.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/IOStatisticsStoreBuilder.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/IOStatisticsStoreBuilderImpl.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/IOStatisticsStoreImpl.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/PairedDurationTrackerFactory.java
copy
hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestLocatedFileStatusFetcher.java
=>
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/SourceWrappedStatistics.java
(56%)
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/StatisticDurationTracker.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/StorageStatisticsFromIOStatistics.java
copy
hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestLocatedFileStatusFetcher.java
=>
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/StubDurationTracker.java
(56%)
copy
hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestLocatedFileStatusFetcher.java
=>
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/StubDurationTrackerFactory.java
(53%)
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/WrappedIOStatistics.java
copy
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/impl/statistics/S3AMultipartUploaderStatistics.java
=>
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/impl/package-info.java
(63%)
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/fs/statistics/package-info.java
copy
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/impl/statistics/S3AMultipartUploaderStatistics.java
=>
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/functional/BiFunctionRaisingIOE.java
(63%)
copy
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/impl/statistics/S3AMultipartUploaderStatistics.java
=>
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/functional/CallableRaisingIOE.java
(69%)
copy
hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestLocatedFileStatusFetcher.java
=>
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/functional/ConsumerRaisingIOE.java
(54%)
copy
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/impl/statistics/S3AMultipartUploaderStatistics.java
=>
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/functional/FunctionRaisingIOE.java
(66%)
copy
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/{fs/impl/FutureIOSupport.java
=> util/functional/FutureIO.java} (52%)
copy
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/impl/statistics/S3AMultipartUploaderStatistics.java
=>
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/functional/InvocationRaisingIOE.java
(55%)
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/functional/RemoteIterators.java
create mode 100644
hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/util/functional/package-info.java
create mode 100644
hadoop-common-project/hadoop-common/src/site/markdown/filesystem/iostatistics.md
create mode 100644
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/contract/AbstractContractStreamIOStatisticsTest.java
create mode 100644
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/contract/localfs/TestLocalFSContractStreamIOStatistics.java
create mode 100644
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/statistics/IOStatisticAssertions.java
create mode 100644
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/statistics/TestDurationTracking.java
create mode 100644
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/statistics/TestDynamicIOStatistics.java
create mode 100644
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/statistics/TestEmptyIOStatistics.java
create mode 100644
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/statistics/TestIOStatisticsSnapshot.java
create mode 100644
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/statistics/TestIOStatisticsStore.java
create mode 100644
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/statistics/TestMeanStatistic.java
create mode 100644
hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/util/functional/TestRemoteIterators.java
create mode 100644
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/impl/ActiveOperationContext.java
delete mode 100644
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/s3guard/InternalIterators.java
create mode 100644
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/statistics/BlockOutputStreamStatistics.java
copy
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/{impl/statistics/S3AMultipartUploaderStatistics.java
=> statistics/ChangeTrackerStatistics.java} (69%)
create mode 100644
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/statistics/CommitterStatistics.java
create mode 100644
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/statistics/CountersAndGauges.java
copy
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/{impl/statistics/S3AMultipartUploaderStatistics.java
=> statistics/DelegationTokenStatistics.java} (69%)
create mode 100644
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/statistics/S3AInputStreamStatistics.java
copy hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/{impl =>
}/statistics/S3AMultipartUploaderStatistics.java (88%)
copy
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/{impl/statistics/S3AMultipartUploaderStatistics.java
=> statistics/S3AStatisticInterface.java} (69%)
create mode 100644
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/statistics/S3AStatisticsContext.java
copy
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/{impl/statistics/S3AMultipartUploaderStatistics.java
=> statistics/StatisticTypeEnum.java} (69%)
create mode 100644
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/statistics/StatisticsFromAwsSdk.java
create mode 100644
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/statistics/impl/AbstractS3AStatisticsSource.java
create mode 100644
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/statistics/impl/AwsStatisticsCollector.java
create mode 100644
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/statistics/impl/BondedS3AStatisticsContext.java
copy
hadoop-tools/hadoop-aws/src/{test/java/org/apache/hadoop/fs/s3a/ITestLocatedFileStatusFetcher.java
=>
main/java/org/apache/hadoop/fs/s3a/statistics/impl/CountingChangeTracker.java}
(53%)
create mode 100644
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/statistics/impl/EmptyS3AStatisticsContext.java
rename
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/{impl/statistics
=> statistics/impl}/S3AMultipartUploaderStatisticsImpl.java (60%)
create mode 100644
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/statistics/impl/StatisticsFromAwsSdkImpl.java
copy
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/{impl/statistics/S3AMultipartUploaderStatistics.java
=> statistics/impl/package-info.java} (68%)
rename
hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/{impl/statistics/S3AMultipartUploaderStatistics.java
=> statistics/package-info.java} (61%)
create mode 100644
hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/impl/TestNetworkBinding.java
delete mode 100644
hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/impl/TestNeworkBinding.java
create mode 100644
hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/statistics/ITestAggregateIOStatistics.java
create mode 100644
hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/statistics/ITestS3AContractStreamIOStatistics.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
