CsvBulkLoadTool extends Configured implements Tool { String getJdbcUrl(String zkQuorum) { if (zkQuorum == null) { LOG.warn("Defaulting to localhost for ZooKeeper quorum"); zkQuorum = "localhost:2181"; } return PhoenixRuntime.JDBC_PROTOCOL + PhoenixRuntime.JDBC_PROTOCOL_SEPARATOR + zkQuorum; }  static void main(String[] args); @Override int run(String[] args);  }
@Test public void testGetJdbcUrl_WithQuorumSupplied() { assertEquals("jdbc:phoenix:myzkhost:2181", bulkLoadTool.getJdbcUrl("myzkhost:2181")); }
@Test public void testGetJdbcUrl_NoQuorumSupplied() { assertEquals("jdbc:phoenix:localhost:2181", bulkLoadTool.getJdbcUrl(null)); }