3838import static org .apache .hadoop .fs .s3a .Constants .PREFETCH_ENABLED_KEY ;
3939import static org .apache .hadoop .fs .statistics .IOStatisticAssertions .verifyStatisticCounterValue ;
4040
41+ /**
42+ * Test the prefetching input stream, validates that the underlying S3CachingInputStream and
43+ * S3InMemoryInputStream are working as expected.
44+ */
4145public class ITestS3PrefetchingInputStream extends AbstractS3ACostTest {
4246
4347 public ITestS3PrefetchingInputStream () {
@@ -77,7 +81,7 @@ private void openFS() throws IOException {
7781
7882 @ Test
7983 public void testReadLargeFileFully () throws Throwable {
80- describe ("read a large file fully" );
84+ describe ("read a large file fully, uses S3CachingInputStream " );
8185 openFS ();
8286
8387 try (FSDataInputStream in = fs .open (largeFile )) {
@@ -94,7 +98,7 @@ public void testReadLargeFileFully() throws Throwable {
9498
9599 @ Test
96100 public void testRandomReadLargeFile () throws Throwable {
97- describe ("read a large file fully " );
101+ describe ("random read on a large file, uses S3CachingInputStream " );
98102 openFS ();
99103
100104 try (FSDataInputStream in = fs .open (largeFile )) {
@@ -116,7 +120,7 @@ public void testRandomReadLargeFile() throws Throwable {
116120
117121 @ Test
118122 public void testRandomReadSmallFile () throws Throwable {
119- describe ("random read on a small file" );
123+ describe ("random read on a small file, uses S3InMemoryInputStream " );
120124
121125 byte [] data = ContractTestUtils .dataset (smallFileSize , 'a' , 26 );
122126 Path smallFile = path ("randomReadSmallFile" );
0 commit comments