Skip to content

Commit d933951

Browse files
committed
updated java docs
1 parent ec9c9b0 commit d933951

File tree

2 files changed

+8
-1
lines changed

2 files changed

+8
-1
lines changed

hadoop-tools/hadoop-aws/src/main/java/org/apache/hadoop/fs/s3a/audit/impl/LoggingAuditor.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -271,7 +271,13 @@ private class LoggingAuditSpan extends AbstractAuditSpanImpl {
271271

272272
private HttpReferrerAuditHeader referrer;
273273

274+
/**
275+
* Builder for the referrer header. Requests that execute outside S3A, such as in AAL, will initially have SpanId
276+
* of the outside-span operation. For such requests, the spanId and operation name in this builder is overwritten
277+
* in the modifyHttpRequest execution interceptor.
278+
*/
274279
private final HttpReferrerAuditHeader.Builder headerBuilder;
280+
275281
/**
276282
* Attach Range of data for GetObject Request.
277283
* @param request the sdk request to be modified
@@ -414,7 +420,6 @@ public SdkHttpRequest modifyHttpRequest(Context.ModifyHttpRequest context,
414420
// for delete op, attach the number of files to delete
415421
attachDeleteKeySizeAttribute(sdkRequest);
416422

417-
418423
// build the referrer header
419424
final String header = referrer.buildHttpReferrer();
420425
// update the outer class's field.

hadoop-tools/hadoop-aws/src/test/java/org/apache/hadoop/fs/s3a/ITestS3AAnalyticsAcceleratorStreamReading.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -182,6 +182,8 @@ public void testMultiRowGroupParquet() throws Throwable {
182182
}
183183

184184
verifyStatisticCounterValue(ioStats, STREAM_READ_ANALYTICS_OPENED, 1);
185+
186+
verifyStatisticCounterValue(getFileSystem().getIOStatistics(), AUDIT_REQUEST_EXECUTION, 4);
185187
}
186188

187189
@Test

0 commit comments

Comments
 (0)