Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -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<? super Task<?>> out, @Nonnull ConnectorArguments arguments)
throws Exception {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -43,6 +43,8 @@ enum HadoopRpcProtection {
}
}

static void test() {}

static Optional<String> convert(String value) throws MetadataDumperUsageException {
return optionallyIfNotEmpty(value).map(HadoopSaslQopConverter::convertInternal);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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";
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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 =
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -102,6 +102,8 @@ private TaskDescription(
}
}

static void test() {}

@Override
protected final void validateForConnector(@Nonnull ConnectorArguments arguments) {
if (arguments.isAssessment() && arguments.hasQueryLogEarliestTimestamp()) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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. */
Expand Down