diff --git a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/airflow/AirflowConnector.java b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/airflow/AirflowConnector.java index 60f801591..29f54100f 100644 --- a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/airflow/AirflowConnector.java +++ b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/airflow/AirflowConnector.java @@ -109,6 +109,8 @@ public String getDefaultFileName(boolean isAssessment, Clock clock) { return ArchiveNameUtil.getFileNameWithTimestamp(getName(), clock); } + static void test() {} + @Override public void addTasksTo(@Nonnull List> out, @Nonnull ConnectorArguments arguments) throws Exception { diff --git a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/cloudera/manager/ClouderaHostRAMChartTask.java b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/cloudera/manager/ClouderaHostRAMChartTask.java index 702d96b56..5e37e08ca 100644 --- a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/cloudera/manager/ClouderaHostRAMChartTask.java +++ b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/cloudera/manager/ClouderaHostRAMChartTask.java @@ -50,6 +50,8 @@ public ClouderaHostRAMChartTask( super("host-ram.jsonl", startDate, endDate, tsAggregation); } + static void test() {} + @Override protected void doRun( TaskRunContext context, @Nonnull ByteSink sink, @Nonnull ClouderaManagerHandle handle) diff --git a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/hive/HadoopSaslQopConverter.java b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/hive/HadoopSaslQopConverter.java index 9ba570b13..587985a9f 100644 --- a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/hive/HadoopSaslQopConverter.java +++ b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/hive/HadoopSaslQopConverter.java @@ -43,6 +43,8 @@ enum HadoopRpcProtection { } } + static void test() {} + static Optional convert(String value) throws MetadataDumperUsageException { return optionallyIfNotEmpty(value).map(HadoopSaslQopConverter::convertInternal); } diff --git a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/oracle/OracleLogsConnector.java b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/oracle/OracleLogsConnector.java index 45bfca061..fe4780abf 100644 --- a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/oracle/OracleLogsConnector.java +++ b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/oracle/OracleLogsConnector.java @@ -45,6 +45,8 @@ private static class QueryHistoryTask extends JdbcSelectTask { super(ZIP_ENTRY_FILENAME, sql()); } + static void test() {} + private static String sql() { return "SELECT sql_fulltext, cpu_time, elapsed_time, disk_reads, runtime_mem FROM v$sql"; } diff --git a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/redshift/RedshiftMetadataConnector.java b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/redshift/RedshiftMetadataConnector.java index bcb805a4f..ab2ec82a6 100644 --- a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/redshift/RedshiftMetadataConnector.java +++ b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/redshift/RedshiftMetadataConnector.java @@ -54,6 +54,8 @@ private static void selStar(@Nonnull ParallelTaskGroup.Builder out, @Nonnull Str new JdbcSelectTask(name.toLowerCase() + ".csv", "SELECT * FROM " + name.toLowerCase())); } + static void test() {} + private static JdbcSelectTask createPgDatabaseSelect() { String outputFile = "pg_database.csv"; String selectList = diff --git a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/snowflake/SnowflakeLogsConnector.java b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/snowflake/SnowflakeLogsConnector.java index e7e2b97a0..cf13fc23e 100644 --- a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/snowflake/SnowflakeLogsConnector.java +++ b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/snowflake/SnowflakeLogsConnector.java @@ -102,6 +102,8 @@ private TaskDescription( } } + static void test() {} + @Override protected final void validateForConnector(@Nonnull ConnectorArguments arguments) { if (arguments.isAssessment() && arguments.hasQueryLogEarliestTimestamp()) { diff --git a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/teradata/AbstractTeradataConnector.java b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/teradata/AbstractTeradataConnector.java index e78dba5ae..c619e07f3 100644 --- a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/teradata/AbstractTeradataConnector.java +++ b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/teradata/AbstractTeradataConnector.java @@ -72,9 +72,9 @@ */ @RespectsArgumentHostUnlessUrl @RespectsInput( - order = ConnectorArguments.OPT_PORT_ORDER, arg = ConnectorArguments.OPT_PORT, - description = "The port of the server.", + description = "The port number of the server.", + order = ConnectorArguments.OPT_PORT_ORDER, required = ConnectorArguments.OPT_REQUIRED_IF_NOT_URL, defaultValue = "" + AbstractTeradataConnector.OPT_PORT_DEFAULT) @RespectsArgumentUser diff --git a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/teradata/TeradataMetadataConnector.java b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/teradata/TeradataMetadataConnector.java index f7fe82f03..341589b37 100644 --- a/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/teradata/TeradataMetadataConnector.java +++ b/dumper/app/src/main/java/com/google/edwmigration/dumper/application/dumper/connector/teradata/TeradataMetadataConnector.java @@ -116,6 +116,8 @@ public TeradataMetadataConnector() { super("teradata"); } + static void test() {} + /* The sql here are passed to teradata as well as postgresql acting as teradata for testing. * QuotedIdentifiers are needed to make the queries work in PG. * It looks like quoted teradata identifiers are also case insensitive, so this should be ok. */