Replace DAT with AAL (#300)

## Description of change
This PR replaces all remaining references to DAT with AAL, reflecting
the current and accurate name of the project. These legacy references
have been updated for consistency and clarity.

#### Relevant issues
N/A

#### Does this contribution introduce any breaking changes to the
existing APIs or behaviors?
No

#### Does this contribution introduce any new public APIs or behaviors?
No

#### How was the contribution tested?
No need to test

#### Does this contribution need a changelog entry?
N/A

---

By submitting this pull request, I confirm that my contribution is made
under the terms of the Apache 2.0 license and I agree to the terms of
the [Developer Certificate of Origin
(DCO)](https://developercertificate.org/).

Author: ozkoca

input-stream/src/integrationTest/java/software/amazon/s3/analyticsaccelerator/access/ConcurrencyCorrectnessTest.java

@@ -25,7 +25,7 @@
 import org.junit.jupiter.params.provider.MethodSource;
 
 /**
- * This tests concurrency and thread safety of teh shared state. While the DAT InputStream itself is
+ * This tests concurrency and thread safety of teh shared state. While the AAL InputStream itself is
  * not thread-safe, the shared state that multiple streams access and manipulate should be.
  */
 public class ConcurrencyCorrectnessTest extends IntegrationTestBase {

input-stream/src/integrationTest/java/software/amazon/s3/analyticsaccelerator/access/IntegrationTestBase.java

@@ -77,7 +77,7 @@ protected S3ExecutionContext getS3ExecutionContext() {
   }
 
   /**
-   * Applies the same read stream pattern to both S3 based and DAT based streams Calculates the
+   * Applies the same read stream pattern to both S3 based and AAL based streams Calculates the
    * CRC32-C checksum on all bytes read and compares them at the end to verify the results are the
    * same
    *
@@ -136,7 +136,7 @@ protected void testChangingEtagMidStream(
     int bufferSize = (int) s3Object.getSize();
     byte[] buffer = new byte[bufferSize];
 
-    // Create the s3DATClientStreamReader - that creates the shared state
+    // Create the s3AALClientStreamReader - that creates the shared state
     try (S3AALClientStreamReader s3AALClientStreamReader =
         this.createS3AALClientStreamReader(s3ClientKind, AALInputStreamConfigurationKind)) {
 
@@ -214,7 +214,7 @@ protected void testChangingEtagAfterStreamPassesAndReturnsCachedObject(
       @NonNull AALInputStreamConfigurationKind AALInputStreamConfigurationKind)
       throws IOException {
     int bufferSize = (int) s3Object.getSize();
-    // Create the s3DATClientStreamReader - that creates the shared state
+    // Create the s3AALClientStreamReader - that creates the shared state
     try (S3AALClientStreamReader s3AALClientStreamReader =
         this.createS3AALClientStreamReader(s3ClientKind, AALInputStreamConfigurationKind)) {
       S3SeekableInputStream stream =
@@ -303,7 +303,7 @@ protected void testAALReadConcurrency(
         Optional.of(directChecksum),
         OpenStreamInformation.DEFAULT);
 
-    // Create the s3DATClientStreamReader - that creates the shared state
+    // Create the s3AALClientStreamReader - that creates the shared state
     try (S3AALClientStreamReader s3AALClientStreamReader =
         this.createS3AALClientStreamReader(s3ClientKind, AALInputStreamConfigurationKind)) {
       // Create the thread pool
@@ -317,7 +317,7 @@ protected void testAALReadConcurrency(
                   try {
                     // Run multiple iterations
                     for (int j = 0; j < iterations; j++) {
-                      // Run DAT on the thread
+                      // Run AAL on the thread
                       // This will create a new stream every time, but all streams will share state
                       Crc32CChecksum datChecksum = new Crc32CChecksum();
                       executeReadPatternOnAAL(

input-stream/src/jmh/java/software/amazon/s3/analyticsaccelerator/benchmarks/AALBenchmark.java

@@ -22,7 +22,7 @@
 import software.amazon.s3.analyticsaccelerator.access.StreamReadPatternKind;
 
 /**
- * Benchmarks that measure performance of DAT via CRT by replaying all patterns against multiple
+ * Benchmarks that measure performance of AAL via CRT by replaying all patterns against multiple
  * object sizes
  */
 public class AALBenchmark extends BenchmarkBase {
@@ -36,7 +36,7 @@ public class AALBenchmark extends BenchmarkBase {
    */
   @Override
   protected void executeBenchmark() throws IOException {
-    executeReadPatternOnDAT();
+    executeReadPatternOnAAL();
   }
 
   /**

input-stream/src/jmh/java/software/amazon/s3/analyticsaccelerator/benchmarks/BenchmarkBase.java

@@ -100,7 +100,7 @@ public S3ExecutionContext getS3ExecutionContext() {
    *
    * @return {@link AALInputStreamConfigurationKind}
    */
-  protected AALInputStreamConfigurationKind getDATInputStreamConfigurationKind() {
+  protected AALInputStreamConfigurationKind getAALInputStreamConfigurationKind() {
     return AALInputStreamConfigurationKind.DEFAULT;
   }
 
@@ -117,18 +117,18 @@ public void execute() throws Exception {
   protected abstract void executeBenchmark() throws Exception;
 
   /**
-   * Executes the pattern on DAT based on the contextual parameters.
+   * Executes the pattern on AAL based on the contextual parameters.
    *
    * @throws IOException if IO error is thrown
    */
-  protected void executeReadPatternOnDAT() throws IOException {
+  protected void executeReadPatternOnAAL() throws IOException {
     S3Object s3Object = this.getObject();
     executeReadPatternOnAAL(
         this.getClientKind(),
         s3Object,
         this.getReadPatternKind().getStreamReadPattern(s3Object),
         // Use default configuration
-        this.getDATInputStreamConfigurationKind(),
+        this.getAALInputStreamConfigurationKind(),
         Optional.empty(),
         OpenStreamInformation.DEFAULT);
   }

input-stream/src/jmh/java/software/amazon/s3/analyticsaccelerator/benchmarks/ComparisonBenchmarkBase.java

@@ -35,8 +35,8 @@ public abstract class ComparisonBenchmarkBase extends BenchmarkBase {
   @Override
   protected void executeBenchmark() throws IOException {
     switch (this.getS3InputStreamKind()) {
-      case S3_DAT_GET:
-        this.executeReadPatternOnDAT();
+      case S3_AAL_GET:
+        this.executeReadPatternOnAAL();
         break;
       case S3_SDK_GET:
         this.executeReadPatternDirectly();

input-stream/src/jmh/java/software/amazon/s3/analyticsaccelerator/benchmarks/S3ClientAndStreamKind.java

@@ -25,9 +25,9 @@
 @Getter
 public enum S3ClientAndStreamKind {
   SDK_ASYNC_JAVA(S3ClientKind.SDK_V2_JAVA_ASYNC, S3InputStreamKind.S3_SDK_GET),
-  SDK_DAT_JAVA(S3ClientKind.SDK_V2_JAVA_ASYNC, S3InputStreamKind.S3_DAT_GET),
+  SDK_AAL_JAVA(S3ClientKind.SDK_V2_JAVA_ASYNC, S3InputStreamKind.S3_AAL_GET),
   SDK_ASYNC_CRT(S3ClientKind.SDK_V2_CRT_ASYNC, S3InputStreamKind.S3_SDK_GET),
-  SDK_DAT_CRT(S3ClientKind.SDK_V2_CRT_ASYNC, S3InputStreamKind.S3_DAT_GET);
+  SDK_AAL_CRT(S3ClientKind.SDK_V2_CRT_ASYNC, S3InputStreamKind.S3_AAL_GET);
 
   private final S3ClientKind clientKind;
   private final S3InputStreamKind inputStreamKind;

input-stream/src/jmh/java/software/amazon/s3/analyticsaccelerator/benchmarks/StreamPatternComparisonBenchmark.java

@@ -24,7 +24,7 @@
 
 /**
  * This benchmarks fixes the ReadPattern, and then, for each object size, replays the pattern on
- * "raw" clients as well as "DAT" streams that sit on the clients The main point here is to
+ * "raw" clients as well as "AAL" streams that sit on the clients The main point here is to
  * determine which combo is the fastest for each pattern.
  */
 public abstract class StreamPatternComparisonBenchmark extends ComparisonBenchmarkBase {

input-stream/src/testFixtures/java/software/amazon/s3/analyticsaccelerator/access/ExecutionBase.java

@@ -118,7 +118,7 @@ protected void executeReadPatternDirectly(
    *
    * @param s3ClientKind S3 client kind to use
    * @param s3Object {@link S3Object} S3 Object to run the pattern on
-   * @param AALInputStreamConfigurationKind DAT configuration
+   * @param AALInputStreamConfigurationKind AAL configuration
    * @param streamReadPattern the read pattern
    * @param checksum checksum to update, if specified
    * @param openStreamInformation contains the open stream information
@@ -143,7 +143,7 @@ protected void executeReadPatternOnAAL(
    * Executes a pattern on AAL
    *
    * @param s3Object {@link S3Object} S3 Object to run the pattern on
-   * @param s3AALClientStreamReader DAT stream reader
+   * @param s3AALClientStreamReader AAL stream reader
    * @param streamReadPattern the read pattern
    * @param checksum checksum to update, if specified
    * @param openStreamInformation contains the open stream information

input-stream/src/testFixtures/java/software/amazon/s3/analyticsaccelerator/access/S3AALClientStreamReader.java

@@ -28,7 +28,7 @@
 import software.amazon.s3.analyticsaccelerator.util.OpenStreamInformation;
 import software.amazon.s3.analyticsaccelerator.util.S3URI;
 
-/** Client stream reader based on DAT */
+/** Client stream reader based on AAL */
 public class S3AALClientStreamReader extends S3StreamReaderBase {
   @NonNull @Getter private final S3SdkObjectClient sdkObjectClient;
   @NonNull @Getter private final S3SeekableInputStreamFactory s3SeekableInputStreamFactory;

input-stream/src/testFixtures/java/software/amazon/s3/analyticsaccelerator/access/S3InputStreamKind.java

@@ -25,6 +25,6 @@ public enum S3InputStreamKind {
   // SDK backed
   S3_SDK_GET("SDK"),
   // Ours
-  S3_DAT_GET("DAT");
+  S3_AAL_GET("AAL");
   private final String value;
 }