Arrow, AWS, Azure, Core, GCP, Hive, Kafka, Snowflake: Rename test classes to use Test as prefix instead of suffix (apache#12879)

It appears that we have some tests that use `Test` as a suffix in the test class name, while all other
modules use it in their prefix.

Author: nastra

arrow/src/test/java/org/apache/iceberg/arrow/ArrowSchemaUtilTest.java renamed to arrow/src/test/java/org/apache/iceberg/arrow/TestArrowSchemaUtil.java

@@ -38,7 +38,7 @@
 import org.apache.iceberg.types.Types.TimestampType;
 import org.junit.jupiter.api.Test;
 
-public class ArrowSchemaUtilTest {
+public class TestArrowSchemaUtil {
 
   private static final String INTEGER_FIELD = "i";
   private static final String BOOLEAN_FIELD = "b";

arrow/src/test/java/org/apache/iceberg/arrow/vectorized/ArrowReaderTest.java renamed to arrow/src/test/java/org/apache/iceberg/arrow/vectorized/TestArrowReader.java

@@ -93,7 +93,7 @@
  *
  * <p>All tests create a table with monthly partitions and write 1 year of data to the table.
  */
-public class ArrowReaderTest {
+public class TestArrowReader {
 
   private static final int NUM_ROWS_PER_MONTH = 20;
   private static final ImmutableList<String> ALL_COLUMNS =

arrow/src/test/java/org/apache/iceberg/arrow/vectorized/parquet/DecimalVectorUtilTest.java renamed to arrow/src/test/java/org/apache/iceberg/arrow/vectorized/parquet/TestDecimalVectorUtil.java

@@ -24,7 +24,7 @@
 import java.math.BigInteger;
 import org.junit.jupiter.api.Test;
 
-public class DecimalVectorUtilTest {
+public class TestDecimalVectorUtil {
 
   @Test
   public void testPadBigEndianBytes() {

aws/src/test/java/org/apache/iceberg/aws/HttpClientPropertiesTest.java

@@ -37,7 +37,7 @@
 import software.amazon.awssdk.regions.Region;
 import software.amazon.awssdk.services.s3.S3ClientBuilder;
 
-public class AwsClientPropertiesTest {
+public class TestAwsClientProperties {
 
   @Test
   public void testApplyClientRegion() {

aws/src/test/java/org/apache/iceberg/aws/AwsClientPropertiesTest.java renamed to aws/src/test/java/org/apache/iceberg/aws/TestAwsClientProperties.java

@@ -29,7 +29,7 @@
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.BeforeEach;
 
-public class BaseAzuriteTest {
+public class AzuriteTestBase {
   protected static final AzuriteContainer AZURITE_CONTAINER = new AzuriteContainer();
 
   @BeforeAll

azure/src/integration/java/org/apache/iceberg/azure/adlsv2/BaseAzuriteTest.java renamed to azure/src/integration/java/org/apache/iceberg/azure/adlsv2/AzuriteTestBase.java

@@ -52,7 +52,7 @@
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.MethodSource;
 
-public class ADLSFileIOTest extends BaseAzuriteTest {
+public class TestADLSFileIO extends AzuriteTestBase {
 
   @Test
   public void testFileOperations() throws IOException {

azure/src/integration/java/org/apache/iceberg/azure/adlsv2/ADLSFileIOTest.java renamed to azure/src/integration/java/org/apache/iceberg/azure/adlsv2/TestADLSFileIO.java

@@ -32,7 +32,7 @@
 import org.apache.iceberg.metrics.MetricsContext;
 import org.junit.jupiter.api.Test;
 
-public class ADLSInputStreamTest extends BaseAzuriteTest {
+public class TestADLSInputStream extends AzuriteTestBase {
 
   private static final String FILE_PATH = "path/to/file";
 

azure/src/integration/java/org/apache/iceberg/azure/adlsv2/ADLSInputStreamTest.java renamed to azure/src/integration/java/org/apache/iceberg/azure/adlsv2/TestADLSInputStream.java

@@ -33,7 +33,7 @@
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;
 
-public class ADLSOutputStreamTest extends BaseAzuriteTest {
+public class TestADLSOutputStream extends AzuriteTestBase {
 
   private final Random random = new Random(1);
   private final AzureProperties azureProperties = new AzureProperties();

azure/src/integration/java/org/apache/iceberg/azure/adlsv2/ADLSOutputStreamTest.java renamed to azure/src/integration/java/org/apache/iceberg/azure/adlsv2/TestADLSOutputStream.java

@@ -49,7 +49,7 @@
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.MethodSource;
 
-public class AzurePropertiesTest {
+public class TestAzureProperties {
 
   @ParameterizedTest
   @MethodSource("org.apache.iceberg.TestHelpers#serializers")

azure/src/test/java/org/apache/iceberg/azure/AzurePropertiesTest.java renamed to azure/src/test/java/org/apache/iceberg/azure/TestAzureProperties.java

@@ -27,7 +27,7 @@
 import org.junit.jupiter.params.provider.CsvSource;
 import org.junit.jupiter.params.provider.ValueSource;
 
-public class ADLSLocationTest {
+public class TestADLSLocation {
   @ParameterizedTest
   @ValueSource(strings = {"abfs", "abfss"})
   public void testLocationParsing(String scheme) {

azure/src/test/java/org/apache/iceberg/azure/adlsv2/ADLSLocationTest.java renamed to azure/src/test/java/org/apache/iceberg/azure/adlsv2/TestADLSLocation.java

@@ -46,7 +46,7 @@
 import org.mockserver.model.HttpResponse;
 import org.mockserver.verify.VerificationTimes;
 
-public class VendedAdlsCredentialProviderTest extends BaseVendedCredentialsTest {
+public class TestVendedAdlsCredentialProvider extends VendedCredentialsTestBase {
   private static final String CREDENTIALS_URI = String.format("%s%s", baseUri, "/v1/credentials");
   private static final String CATALOG_URI = String.format("%s%s", baseUri, "/v1/");
   private static final String STORAGE_ACCOUNT = "account1";

azure/src/test/java/org/apache/iceberg/azure/adlsv2/VendedAdlsCredentialProviderTest.java renamed to azure/src/test/java/org/apache/iceberg/azure/adlsv2/TestVendedAdlsCredentialProvider.java

@@ -34,7 +34,7 @@
 import org.mockserver.model.HttpResponse;
 import org.mockserver.verify.VerificationTimes;
 
-public class VendedAzureSasCredentialPolicyTest extends BaseVendedCredentialsTest {
+public class TestVendedAzureSasCredentialPolicy extends VendedCredentialsTestBase {
 
   private static final String STORAGE_ACCOUNT = "account1";
   private static final String ACCOUNT_ENDPOINT = String.format("%s/%s", baseUri, STORAGE_ACCOUNT);

azure/src/test/java/org/apache/iceberg/azure/adlsv2/VendedAzureSasCredentialPolicyTest.java renamed to azure/src/test/java/org/apache/iceberg/azure/adlsv2/TestVendedAzureSasCredentialPolicy.java

@@ -25,7 +25,7 @@
 import org.junit.jupiter.api.BeforeEach;
 import org.mockserver.integration.ClientAndServer;
 
-public class BaseVendedCredentialsTest {
+public class VendedCredentialsTestBase {
   protected static String baseUri;
   protected static ClientAndServer mockServer;
 

azure/src/test/java/org/apache/iceberg/azure/adlsv2/BaseVendedCredentialsTest.java renamed to azure/src/test/java/org/apache/iceberg/azure/adlsv2/VendedCredentialsTestBase.java

@@ -44,7 +44,7 @@
 import org.junit.jupiter.api.extension.ExtendWith;
 
 @ExtendWith(ParameterizedTestExtension.class)
-public class TableMetadataParserTest {
+public class TestTableMetadataParser {
 
   private static final Schema SCHEMA = new Schema(optional(1, "b", BooleanType.get()));
 

core/src/test/java/org/apache/iceberg/TableMetadataParserTest.java renamed to core/src/test/java/org/apache/iceberg/TestTableMetadataParser.java

@@ -24,7 +24,7 @@
 import org.apache.iceberg.TableMetadataParser.Codec;
 import org.junit.jupiter.api.Test;
 
-public class TableMetadataParserCodecTest {
+public class TestTableMetadataParserCodec {
 
   @Test
   public void testCompressionCodec() {

core/src/test/java/org/apache/iceberg/TableMetadataParserCodecTest.java renamed to core/src/test/java/org/apache/iceberg/TestTableMetadataParserCodec.java

@@ -48,7 +48,7 @@
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.MethodSource;
 
-public class HadoopFileIOTest {
+public class TestHadoopFileIO {
   private final Random random = new Random(1);
 
   private FileSystem fs;

core/src/test/java/org/apache/iceberg/hadoop/HadoopFileIOTest.java renamed to core/src/test/java/org/apache/iceberg/hadoop/TestHadoopFileIO.java

@@ -28,7 +28,7 @@
 import org.apache.iceberg.relocated.com.google.common.collect.ImmutableMap;
 import org.junit.jupiter.api.Test;
 
-public class GCPPropertiesTest {
+public class TestGCPProperties {
 
   @Test
   public void testOAuthWithNoAuth() {

gcp/src/test/java/org/apache/iceberg/gcp/GCPPropertiesTest.java renamed to gcp/src/test/java/org/apache/iceberg/gcp/TestGCPProperties.java

@@ -65,7 +65,7 @@
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.MethodSource;
 
-public class GCSFileIOTest {
+public class TestGCSFileIO {
   private static final String TEST_BUCKET = "TEST_BUCKET";
   private final Random random = new Random(1);
 

gcp/src/test/java/org/apache/iceberg/gcp/gcs/GCSFileIOTest.java renamed to gcp/src/test/java/org/apache/iceberg/gcp/gcs/TestGCSFileIO.java

@@ -36,7 +36,7 @@
 import org.apache.iceberg.metrics.MetricsContext;
 import org.junit.jupiter.api.Test;
 
-public class GCSInputStreamTest {
+public class TestGCSInputStream {
 
   private final Random random = new Random(1);
 

gcp/src/test/java/org/apache/iceberg/gcp/gcs/GCSInputStreamTest.java renamed to gcp/src/test/java/org/apache/iceberg/gcp/gcs/TestGCSInputStream.java

@@ -24,7 +24,7 @@
 import org.apache.iceberg.exceptions.ValidationException;
 import org.junit.jupiter.api.Test;
 
-public class GCSLocationTest {
+public class TestGCSLocation {
   @Test
   public void testLocationParsing() {
     String p1 = "gs://bucket/path/to/prefix";

gcp/src/test/java/org/apache/iceberg/gcp/gcs/GCSLocationTest.java renamed to gcp/src/test/java/org/apache/iceberg/gcp/gcs/TestGCSLocation.java

@@ -34,8 +34,8 @@
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-public class GCSOutputStreamTest {
-  private static final Logger LOG = LoggerFactory.getLogger(GCSOutputStreamTest.class);
+public class TestGCSOutputStream {
+  private static final Logger LOG = LoggerFactory.getLogger(TestGCSOutputStream.class);
   private static final String BUCKET = "test-bucket";
 
   private final GCPProperties properties = new GCPProperties();

gcp/src/test/java/org/apache/iceberg/gcp/gcs/GCSOutputStreamTest.java renamed to gcp/src/test/java/org/apache/iceberg/gcp/gcs/TestGCSOutputStream.java

@@ -45,7 +45,7 @@
 import org.mockserver.model.HttpResponse;
 import org.mockserver.verify.VerificationTimes;
 
-public class OAuth2RefreshCredentialsHandlerTest {
+public class TestOAuth2RefreshCredentialsHandler {
   private static final int PORT = 3333;
   private static final String CREDENTIALS_URI =
       String.format("http://127.0.0.1:%d/v1/credentials", PORT);

gcp/src/test/java/org/apache/iceberg/gcp/gcs/OAuth2RefreshCredentialsHandlerTest.java renamed to gcp/src/test/java/org/apache/iceberg/gcp/gcs/TestOAuth2RefreshCredentialsHandler.java

@@ -43,7 +43,7 @@
 import org.junit.jupiter.api.BeforeEach;
 import org.junit.jupiter.api.extension.RegisterExtension;
 
-public class HiveTableBaseTest {
+public class HiveTableTestBase {
 
   static final String TABLE_NAME = "tbl";
   static final String DB_NAME = "hivedb";

hive-metastore/src/test/java/org/apache/iceberg/hive/HiveTableBaseTest.java renamed to hive-metastore/src/test/java/org/apache/iceberg/hive/HiveTableTestBase.java

@@ -47,7 +47,7 @@
 import org.junit.jupiter.api.Test;
 import org.junit.platform.commons.support.ReflectionSupport;
 
-public class TestHiveCommits extends HiveTableBaseTest {
+public class TestHiveCommits extends HiveTableTestBase {
 
   @Test
   public void testSuppressUnlockExceptions() {

hive-metastore/src/test/java/org/apache/iceberg/hive/TestHiveCommits.java

@@ -51,7 +51,7 @@
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.ValueSource;
 
-public class HiveCreateReplaceTableTest {
+public class TestHiveCreateReplaceTable {
 
   private static final String DB_NAME = "hivedb";
   private static final String TABLE_NAME = "tbl";

hive-metastore/src/test/java/org/apache/iceberg/hive/HiveCreateReplaceTableTest.java renamed to hive-metastore/src/test/java/org/apache/iceberg/hive/TestHiveCreateReplaceTable.java

@@ -83,7 +83,7 @@
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.EnumSource;
 
-public class HiveTableTest extends HiveTableBaseTest {
+public class TestHiveTable extends HiveTableTestBase {
   static final String NON_DEFAULT_DATABASE = "nondefault";
 
   @TempDir private Path tempFolder;

hive-metastore/src/test/java/org/apache/iceberg/hive/HiveTableTest.java renamed to hive-metastore/src/test/java/org/apache/iceberg/hive/TestHiveTable.java

@@ -39,7 +39,7 @@
 import org.awaitility.Awaitility;
 import org.junit.jupiter.api.Test;
 
-public class TestHiveTableConcurrency extends HiveTableBaseTest {
+public class TestHiveTableConcurrency extends HiveTableTestBase {
 
   @Test
   public synchronized void testConcurrentFastAppends() {

hive-metastore/src/test/java/org/apache/iceberg/hive/TestHiveTableConcurrency.java

@@ -25,7 +25,7 @@
 import java.util.UUID;
 import org.junit.jupiter.api.Test;
 
-public class EventSerializationTest {
+public class TestEventSerialization {
 
   @Test
   public void testStartCommitSerialization() {

kafka-connect/kafka-connect-events/src/test/java/org/apache/iceberg/connect/events/EventSerializationTest.java renamed to kafka-connect/kafka-connect-events/src/test/java/org/apache/iceberg/connect/events/TestEventSerialization.java

@@ -29,7 +29,7 @@
 import org.junit.jupiter.params.provider.NullSource;
 import org.junit.jupiter.params.provider.ValueSource;
 
-public class IntegrationDynamicTableTest extends IntegrationTestBase {
+public class TestIntegrationDynamicTable extends IntegrationTestBase {
 
   private static final String TEST_TABLE1 = "tbl1";
   private static final String TEST_TABLE2 = "tbl2";

kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/IntegrationDynamicTableTest.java renamed to kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/TestIntegrationDynamicTable.java

@@ -29,7 +29,7 @@
 import org.junit.jupiter.params.provider.NullSource;
 import org.junit.jupiter.params.provider.ValueSource;
 
-public class IntegrationMultiTableTest extends IntegrationTestBase {
+public class TestIntegrationMultiTable extends IntegrationTestBase {
 
   private static final String TEST_TABLE1 = "foobar1";
   private static final String TEST_TABLE2 = "foobar2";

kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/IntegrationMultiTableTest.java renamed to kafka-connect/kafka-connect-runtime/src/integration/java/org/apache/iceberg/connect/TestIntegrationMultiTable.java

@@ -29,7 +29,7 @@
 import org.apache.kafka.connect.sink.SinkRecord;
 import org.junit.jupiter.api.Test;
 
-public class CopyValueTest {
+public class TestCopyValue {
 
   @Test
   public void testCopyValueNull() {

kafka-connect/kafka-connect-transforms/src/test/java/org/apache/iceberg/connect/transforms/CopyValueTest.java renamed to kafka-connect/kafka-connect-transforms/src/test/java/org/apache/iceberg/connect/transforms/TestCopyValue.java

@@ -31,7 +31,7 @@
 import org.apache.kafka.connect.sink.SinkRecord;
 import org.junit.jupiter.api.Test;
 
-public class DebeziumTransformTest {
+public class TestDebeziumTransform {
 
   private static final Schema KEY_SCHEMA =
       SchemaBuilder.struct().field("account_id", Schema.INT64_SCHEMA).build();

kafka-connect/kafka-connect-transforms/src/test/java/org/apache/iceberg/connect/transforms/DebeziumTransformTest.java renamed to kafka-connect/kafka-connect-transforms/src/test/java/org/apache/iceberg/connect/transforms/TestDebeziumTransform.java

@@ -26,7 +26,7 @@
 import org.apache.kafka.connect.sink.SinkRecord;
 import org.junit.jupiter.api.Test;
 
-public class DmsTransformTest {
+public class TestDmsTransform {
 
   @Test
   @SuppressWarnings("unchecked")

kafka-connect/kafka-connect-transforms/src/test/java/org/apache/iceberg/connect/transforms/DmsTransformTest.java renamed to kafka-connect/kafka-connect-transforms/src/test/java/org/apache/iceberg/connect/transforms/TestDmsTransform.java

@@ -32,7 +32,7 @@
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Test;
 
-public class JsonToMapTransformTest extends FileLoads {
+public class TestJsonToMapTransform extends FileLoads {
 
   private String loadJson() {
     try {