FLOW-7496 Remove code related to schema evolution and schema validation (#1233)

FLOW-7496 Remove code related to schema evolution and schema validation (#1233)

Author: sfc-gh-lkucharski

src/main/java/com/snowflake/ingest/streaming/internal/TimestampWrapper.java

@@ -49,20 +49,4 @@ public BigInteger toBinary(boolean includeTimezone) {
     }
     return fcpInt;
   }
-
-  public long getEpochSecond() {
-    return epoch;
-  }
-
-  public int getFraction() {
-    return fraction;
-  }
-
-  public int getTimezoneOffsetSeconds() {
-    return timezoneOffsetSeconds;
-  }
-
-  public int getTimeZoneIndex() {
-    return timezoneOffsetSeconds / 60 + 1440;
-  }
 }

src/main/java/com/snowflake/kafka/connector/internal/CachingSnowflakeConnectionService.java

@@ -5,11 +5,9 @@
 import com.google.common.cache.Cache;
 import com.google.common.cache.CacheBuilder;
 import com.google.common.cache.CacheStats;
-import com.snowflake.kafka.connector.internal.streaming.schemaevolution.ColumnInfos;
 import com.snowflake.kafka.connector.internal.telemetry.SnowflakeTelemetryService;
 import java.sql.Connection;
 import java.util.List;
-import java.util.Map;
 import java.util.Optional;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicLong;
@@ -170,23 +168,6 @@ public boolean isTableCompatible(String tableName) {
     return delegate.isTableCompatible(tableName);
   }
 
-  @Override
-  public boolean hasSchemaEvolutionPermission(String tableName, String role) {
-    return delegate.hasSchemaEvolutionPermission(tableName, role);
-  }
-
-  @Override
-  public void alterColumnsDataTypeIcebergTable(
-      String tableName, Map<String, ColumnInfos> columnInfosMap) {
-    delegate.alterColumnsDataTypeIcebergTable(tableName, columnInfosMap);
-  }
-
-  @Override
-  public void appendColumnsToIcebergTable(
-      String tableName, Map<String, ColumnInfos> columnInfosMap) {
-    delegate.appendColumnsToIcebergTable(tableName, columnInfosMap);
-  }
-
   @Override
   public void databaseExists(String databaseName) {
     delegate.databaseExists(databaseName);

src/main/java/com/snowflake/kafka/connector/internal/DescribeTableRow.java

@@ -15,24 +15,6 @@ public DescribeTableRow(String column, String type, String comment) {
     this.comment = comment;
   }
 
-  public DescribeTableRow(String column, String type) {
-    this.column = column;
-    this.type = type;
-    this.comment = null;
-  }
-
-  public String getColumn() {
-    return column;
-  }
-
-  public String getType() {
-    return type;
-  }
-
-  public String getComment() {
-    return comment;
-  }
-
   @Override
   public boolean equals(Object o) {
     if (this == o) return true;

src/main/java/com/snowflake/kafka/connector/internal/OAuthConstants.java

@@ -1,10 +1,8 @@
 package com.snowflake.kafka.connector.internal;
 
-import com.snowflake.kafka.connector.internal.streaming.schemaevolution.ColumnInfos;
 import com.snowflake.kafka.connector.internal.telemetry.SnowflakeTelemetryService;
 import java.sql.Connection;
 import java.util.List;
-import java.util.Map;
 import java.util.Optional;
 
 public interface SnowflakeConnectionService {
@@ -48,32 +46,6 @@ public interface SnowflakeConnectionService {
    */
   boolean isTableCompatible(String tableName);
 
-  /**
-   * Check whether the user has the role privilege to do schema evolution and whether the schema
-   * evolution option is enabled on the table
-   *
-   * @param tableName the name of the table
-   * @param role the role of the user
-   * @return whether table and role has the required permission to perform schema evolution
-   */
-  boolean hasSchemaEvolutionPermission(String tableName, String role);
-
-  /**
-   * Alter iceberg table to modify columns datatype
-   *
-   * @param tableName the name of the table
-   * @param columnInfosMap the mapping from the columnNames to their columnInfos
-   */
-  void alterColumnsDataTypeIcebergTable(String tableName, Map<String, ColumnInfos> columnInfosMap);
-
-  /**
-   * Alter iceberg table to add columns according to a map from columnNames to their types
-   *
-   * @param tableName the name of the table
-   * @param columnInfosMap the mapping from the columnNames to their columnInfos
-   */
-  void appendColumnsToIcebergTable(String tableName, Map<String, ColumnInfos> columnInfosMap);
-
   /**
    * check if a given database exists
    *