Revert changes to getOverrideWhere

Author: misolt

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/snowflake/SnowflakeLogsConnector.java

@@ -290,6 +290,8 @@ private String createExtendedQueryFromAccountUsage(ConnectorArguments arguments)
     String overrideQuery = getOverrideQuery(arguments);
     if (overrideQuery != null) return overrideQuery;
 
+    String overrideWhere = getOverrideWhere(arguments);
+
     @SuppressWarnings("OrphanedFormatString")
     StringBuilder queryBuilder =
         new StringBuilder(
@@ -341,7 +343,12 @@ private String createExtendedQueryFromAccountUsage(ConnectorArguments arguments)
                 + "AND end_time <= to_timestamp_ltz('%s')\n"
                 + "AND is_client_generated_statement = FALSE\n");
 
-    queryBuilder.append(getOverrideWhere(arguments));
+    if (!StringUtils.isBlank(arguments.getQueryLogEarliestTimestamp()))
+      queryBuilder
+          .append("AND start_time >= ")
+          .append(arguments.getQueryLogEarliestTimestamp())
+          .append("\n");
+    if (overrideWhere != null) queryBuilder.append(" AND ").append(overrideWhere);
     return queryBuilder.toString().replace('\n', ' ');
   }
 
@@ -359,16 +366,10 @@ private String getOverrideQuery(@Nonnull ConnectorArguments arguments)
     return null;
   }
 
-  @Nonnull
+  @CheckForNull
   private String getOverrideWhere(@Nonnull ConnectorArguments arguments)
       throws MetadataDumperUsageException {
-    ConnectorProperty property = SnowflakeLogConnectorProperties.OVERRIDE_WHERE;
-    String overrideWhere = arguments.getDefinition(property);
-    if (overrideWhere != null) {
-      return String.format(" AND %s", overrideWhere);
-    } else {
-      return "";
-    }
+    return arguments.getDefinition(SnowflakeLogConnectorProperties.OVERRIDE_WHERE);
   }
 
   @Override