@Test public void testBuildDatasetUriHdfsHostPortIgnored() { String expected = "dataset:hdfs: String actual = ConfigUtil.buildDatasetUri("namenode:8020", expected); assertEquals(expected, actual); }
public static String buildDatasetUri(String authority, String uri) { if (!Strings.isNullOrEmpty(authority) && !uri.contains(": URIBuilder builder = new URIBuilder(uri); String[] parts = authority.split(":"); if (parts.length > 0) { builder.with("auth:host", parts[0]); } if (parts.length > 1) { builder.with("auth:port", parts[1]); } return builder.build().toString().replaceFirst("view:", "dataset:"); } return uri; }
ConfigUtil { public static String buildDatasetUri(String authority, String uri) { if (!Strings.isNullOrEmpty(authority) && !uri.contains(": URIBuilder builder = new URIBuilder(uri); String[] parts = authority.split(":"); if (parts.length > 0) { builder.with("auth:host", parts[0]); } if (parts.length > 1) { builder.with("auth:port", parts[1]); } return builder.build().toString().replaceFirst("view:", "dataset:"); } return uri; } }
ConfigUtil { public static String buildDatasetUri(String authority, String uri) { if (!Strings.isNullOrEmpty(authority) && !uri.contains(": URIBuilder builder = new URIBuilder(uri); String[] parts = authority.split(":"); if (parts.length > 0) { builder.with("auth:host", parts[0]); } if (parts.length > 1) { builder.with("auth:port", parts[1]); } return builder.build().toString().replaceFirst("view:", "dataset:"); } return uri; }  }
ConfigUtil { public static String buildDatasetUri(String authority, String uri) { if (!Strings.isNullOrEmpty(authority) && !uri.contains(": URIBuilder builder = new URIBuilder(uri); String[] parts = authority.split(":"); if (parts.length > 0) { builder.with("auth:host", parts[0]); } if (parts.length > 1) { builder.with("auth:port", parts[1]); } return builder.build().toString().replaceFirst("view:", "dataset:"); } return uri; }  static String buildDatasetUri(String authority, String uri); static String buildDatasetUri(LinkConfig linkConfig, String uri); static String buildDatasetUri(LinkConfig linkConfig,
      ToJobConfig toJobConfig); static boolean isHBaseJob(ToJobConfig toJobConfig); }
ConfigUtil { public static String buildDatasetUri(String authority, String uri) { if (!Strings.isNullOrEmpty(authority) && !uri.contains(": URIBuilder builder = new URIBuilder(uri); String[] parts = authority.split(":"); if (parts.length > 0) { builder.with("auth:host", parts[0]); } if (parts.length > 1) { builder.with("auth:port", parts[1]); } return builder.build().toString().replaceFirst("view:", "dataset:"); } return uri; }  static String buildDatasetUri(String authority, String uri); static String buildDatasetUri(LinkConfig linkConfig, String uri); static String buildDatasetUri(LinkConfig linkConfig,
      ToJobConfig toJobConfig); static boolean isHBaseJob(ToJobConfig toJobConfig);  }