@Test public void testGetUriStringForTopic() throws Exception { String commonPath = "/data/tracking"; URI topic1URI = ConfigStoreUtils.getUriStringForTopic("Topic1", commonPath, configStoreUri); URI expectedTopic1URI = new URI("simple-file", "", new URI(configStoreUri).getPath() + "/data/tracking/Topic1", null, null); Assert.assertEquals(topic1URI, expectedTopic1URI); URI topic2URI = ConfigStoreUtils.getUriStringForTopic("Topic2", commonPath, configStoreUri); URI expectedTopic2URI = new URI("simple-file", "", new URI(configStoreUri).getPath() + "/data/tracking/Topic2", null, null); Assert.assertEquals(topic2URI, expectedTopic2URI); }
public static URI getUriStringForTopic(String topicName, String commonPath, String configStoreUri) throws URISyntaxException { Path fullTopicPathInConfigStore = PathUtils.mergePaths(new Path(commonPath), new Path(topicName)); URI topicUri = getUriFromPath(fullTopicPathInConfigStore, configStoreUri); log.info("URI for topic is : " + topicUri.toString()); return topicUri; }
ConfigStoreUtils { public static URI getUriStringForTopic(String topicName, String commonPath, String configStoreUri) throws URISyntaxException { Path fullTopicPathInConfigStore = PathUtils.mergePaths(new Path(commonPath), new Path(topicName)); URI topicUri = getUriFromPath(fullTopicPathInConfigStore, configStoreUri); log.info("URI for topic is : " + topicUri.toString()); return topicUri; } }
ConfigStoreUtils { public static URI getUriStringForTopic(String topicName, String commonPath, String configStoreUri) throws URISyntaxException { Path fullTopicPathInConfigStore = PathUtils.mergePaths(new Path(commonPath), new Path(topicName)); URI topicUri = getUriFromPath(fullTopicPathInConfigStore, configStoreUri); log.info("URI for topic is : " + topicUri.toString()); return topicUri; }  }
ConfigStoreUtils { public static URI getUriStringForTopic(String topicName, String commonPath, String configStoreUri) throws URISyntaxException { Path fullTopicPathInConfigStore = PathUtils.mergePaths(new Path(commonPath), new Path(topicName)); URI topicUri = getUriFromPath(fullTopicPathInConfigStore, configStoreUri); log.info("URI for topic is : " + topicUri.toString()); return topicUri; }  static Collection<URI> getTopicsURIFromConfigStore(ConfigClient configClient, Path tagUri, String filterString,
      Optional<Config> runtimeConfig); static Optional<String> getConfigStoreUri(Properties properties); static String getTopicNameFromURI(URI uri); static URI getUriStringForTopic(String topicName, String commonPath, String configStoreUri); static Optional<Config> getConfigForTopic(Properties properties, String topicKey, ConfigClient configClient); static Optional<Config> getConfigForTopicWithName(Properties properties, String topicName, ConfigClient configClient); static Config getConfig(ConfigClient client, URI u, Optional<Config> runtimeConfig); static List<KafkaTopic> getTopicsFromConfigStore(Properties properties, String configStoreUri,
      GobblinKafkaConsumerClient kafkaConsumerClient); static List<String> getListOfTopicNamesByFilteringTag(Properties properties, ConfigClient configClient,
      Optional<Config> runtimeConfig, String configStoreUri, String tagConfName); @Deprecated static void setTopicsFromConfigStore(Properties properties, Set<String> blacklist, Set<String> whitelist,
      final String _blacklistTopicKey, final String _whitelistTopicKey); }
ConfigStoreUtils { public static URI getUriStringForTopic(String topicName, String commonPath, String configStoreUri) throws URISyntaxException { Path fullTopicPathInConfigStore = PathUtils.mergePaths(new Path(commonPath), new Path(topicName)); URI topicUri = getUriFromPath(fullTopicPathInConfigStore, configStoreUri); log.info("URI for topic is : " + topicUri.toString()); return topicUri; }  static Collection<URI> getTopicsURIFromConfigStore(ConfigClient configClient, Path tagUri, String filterString,
      Optional<Config> runtimeConfig); static Optional<String> getConfigStoreUri(Properties properties); static String getTopicNameFromURI(URI uri); static URI getUriStringForTopic(String topicName, String commonPath, String configStoreUri); static Optional<Config> getConfigForTopic(Properties properties, String topicKey, ConfigClient configClient); static Optional<Config> getConfigForTopicWithName(Properties properties, String topicName, ConfigClient configClient); static Config getConfig(ConfigClient client, URI u, Optional<Config> runtimeConfig); static List<KafkaTopic> getTopicsFromConfigStore(Properties properties, String configStoreUri,
      GobblinKafkaConsumerClient kafkaConsumerClient); static List<String> getListOfTopicNamesByFilteringTag(Properties properties, ConfigClient configClient,
      Optional<Config> runtimeConfig, String configStoreUri, String tagConfName); @Deprecated static void setTopicsFromConfigStore(Properties properties, Set<String> blacklist, Set<String> whitelist,
      final String _blacklistTopicKey, final String _whitelistTopicKey); static final String GOBBLIN_CONFIG_TAGS_WHITELIST; static final String GOBBLIN_CONFIG_TAGS_BLACKLIST; static final String GOBBLIN_CONFIG_FILTER; static final String GOBBLIN_CONFIG_COMMONPATH; }