add timestamp to datalake connectors (#838)

Author: vladislav-sidorovich

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/hadoop/HadoopMetadataConnector.java

@@ -31,8 +31,10 @@
 import com.google.edwmigration.dumper.application.dumper.task.DumpMetadataTask;
 import com.google.edwmigration.dumper.application.dumper.task.FormatTask;
 import com.google.edwmigration.dumper.application.dumper.task.Task;
+import com.google.edwmigration.dumper.application.dumper.utils.ArchiveNameUtil;
 import com.google.edwmigration.dumper.plugin.ext.jdk.annotation.Description;
 import java.io.IOException;
+import java.time.Clock;
 import java.util.List;
 import java.util.stream.Stream;
 import javax.annotation.Nonnull;
@@ -96,6 +98,12 @@ public String getName() {
     return CONNECTOR_NAME;
   }
 
+  @Nonnull
+  @Override
+  public String getDefaultFileName(boolean isAssessment, Clock clock) {
+    return ArchiveNameUtil.getFileNameWithTimestamp(getName() + "-metadata", clock);
+  }
+
   @Override
   public void addTasksTo(@Nonnull List<? super Task<?>> out, @Nonnull ConnectorArguments arguments)
       throws Exception {

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/hdfs/HdfsExtractionConnector.java

@@ -50,16 +50,14 @@
 @Description("Dumps files and directories from the HDFS.")
 public class HdfsExtractionConnector extends AbstractConnector implements HdfsExtractionDumpFormat {
 
-  public static final String CONNECTOR_NAME = "hdfs";
-
   public HdfsExtractionConnector() {
-    super(CONNECTOR_NAME);
+    super("hdfs");
   }
 
   @Nonnull
   @Override
   public String getDefaultFileName(boolean isAssessment, Clock clock) {
-    return ArchiveNameUtil.getFileName(getName());
+    return ArchiveNameUtil.getFileNameWithTimestamp(getName(), clock);
   }
 
   @Override

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/hive/HiveMetadataConnector.java

@@ -42,6 +42,7 @@
 import com.google.edwmigration.dumper.application.dumper.task.Task;
 import com.google.edwmigration.dumper.application.dumper.task.TaskCategory;
 import com.google.edwmigration.dumper.application.dumper.task.TaskRunContext;
+import com.google.edwmigration.dumper.application.dumper.utils.ArchiveNameUtil;
 import com.google.edwmigration.dumper.ext.hive.metastore.Database;
 import com.google.edwmigration.dumper.ext.hive.metastore.DelegationToken;
 import com.google.edwmigration.dumper.ext.hive.metastore.Field;
@@ -57,6 +58,7 @@
 import com.google.edwmigration.dumper.plugin.lib.dumper.spi.HiveMetadataDumpFormat;
 import java.io.Writer;
 import java.nio.charset.StandardCharsets;
+import java.time.Clock;
 import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
@@ -678,10 +680,14 @@ protected String toCallDescription() {
     }
   }
 
-  public static final String CONNECTOR_NAME = "hiveql";
-
   public HiveMetadataConnector() {
-    super(CONNECTOR_NAME);
+    super("hiveql");
+  }
+
+  @Nonnull
+  @Override
+  public String getDefaultFileName(boolean isAssessment, Clock clock) {
+    return ArchiveNameUtil.getFileNameWithTimestamp(getName() + "-metadata", clock);
   }
 
   @Override

dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/ranger/RangerConnector.java

@@ -83,7 +83,7 @@ public RangerConnector() {
   @Nonnull
   @Override
   public String getDefaultFileName(boolean isAssessment, Clock clock) {
-    return ArchiveNameUtil.getFileName(getName());
+    return ArchiveNameUtil.getFileNameWithTimestamp(getName(), clock);
   }
 
   @Override