CsvBulkLoadTool extends Configured implements Tool { @VisibleForTesting static String getQualifiedTableName(String schemaName, String tableName) { if (schemaName != null) { return String.format("%s.%s", SchemaUtil.normalizeIdentifier(schemaName), SchemaUtil.normalizeIdentifier(tableName)); } else { return SchemaUtil.normalizeIdentifier(tableName); } }  static void main(String[] args); @Override int run(String[] args);  }
@Test public void testGetQualifiedTableName() { assertEquals("MYSCHEMA.MYTABLE", CsvBulkLoadTool.getQualifiedTableName("mySchema", "myTable")); }
@Test public void testGetQualifiedTableName_NullSchema() { assertEquals("MYTABLE", CsvBulkLoadTool.getQualifiedTableName(null, "myTable")); }