in core/src/main/java/org/apache/stormcrawler/parse/filter/CollectionTagger.java [79:107]
public void configure(@NotNull Map<String, Object> stormConf, @NotNull JsonNode filterParams) {
if (filterParams != null) {
JsonNode node = filterParams.get("key");
if (node != null && node.isTextual()) {
this.key = node.asText("collections");
}
node = filterParams.get("file");
if (node != null && node.isTextual()) {
this.resourceFile = node.asText("collections.json");
}
}
// config via json failed - trying from global config
if (this.key == null) {
this.key = ConfUtils.getString(stormConf, "collections.key", "collections");
}
if (this.resourceFile == null) {
this.resourceFile =
ConfUtils.getString(stormConf, "collections.file", "collections.json");
}
try {
loadJSONResources();
} catch (Exception e) {
LOG.error("Exception while loading JSON resources from jar", e);
throw new RuntimeException(e);
}
}