You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stormcrawler.apache.org by rz...@apache.org on 2024/10/28 12:20:42 UTC
(incubator-stormcrawler) 02/02: Fix formatting
This is an automated email from the ASF dual-hosted git repository.
rzo1 pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-stormcrawler.git
commit cc020af370946eb8d480d4ec778c38d5a61f4211
Author: Julien Nioche <ju...@digitalpebble.com>
AuthorDate: Fri Oct 25 12:27:21 2024 +0100
Fix formatting
Signed-off-by: Julien Nioche <ju...@digitalpebble.com>
---
.../opensearch/filtering/JSONURLFilterWrapper.java | 12 +++++++-----
.../stormcrawler/opensearch/metrics/MetricsConsumer.java | 4 ++--
.../opensearch/persistence/AggregationSpout.java | 8 ++++----
3 files changed, 13 insertions(+), 11 deletions(-)
diff --git a/external/opensearch/src/main/java/org/apache/stormcrawler/opensearch/filtering/JSONURLFilterWrapper.java b/external/opensearch/src/main/java/org/apache/stormcrawler/opensearch/filtering/JSONURLFilterWrapper.java
index 17977b9b..693b00df 100644
--- a/external/opensearch/src/main/java/org/apache/stormcrawler/opensearch/filtering/JSONURLFilterWrapper.java
+++ b/external/opensearch/src/main/java/org/apache/stormcrawler/opensearch/filtering/JSONURLFilterWrapper.java
@@ -36,10 +36,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Wraps a URLFilter whose resources are in a JSON file that can be stored in OpenSearch. The benefit of
- * doing this is that the resources can be refreshed automatically and modified without having to
- * recompile the jar and restart the topology. The connection to OpenSearch is done via the config and uses
- * a new bolt type 'config'.
+ * Wraps a URLFilter whose resources are in a JSON file that can be stored in OpenSearch. The
+ * benefit of doing this is that the resources can be refreshed automatically and modified without
+ * having to recompile the jar and restart the topology. The connection to OpenSearch is done via
+ * the config and uses a new bolt type 'config'.
*
* <p>The configuration of the delegate is done in the urlfilters.json as usual.
*
@@ -137,7 +137,9 @@ public class JSONURLFilterWrapper extends URLFilter {
osClient =
OpenSearchConnection.getClient(stormConf, "config");
} catch (Exception e) {
- LOG.error("Exception while creating OpenSearch connection", e);
+ LOG.error(
+ "Exception while creating OpenSearch connection",
+ e);
}
}
if (osClient != null) {
diff --git a/external/opensearch/src/main/java/org/apache/stormcrawler/opensearch/metrics/MetricsConsumer.java b/external/opensearch/src/main/java/org/apache/stormcrawler/opensearch/metrics/MetricsConsumer.java
index f806487d..2fc7058f 100644
--- a/external/opensearch/src/main/java/org/apache/stormcrawler/opensearch/metrics/MetricsConsumer.java
+++ b/external/opensearch/src/main/java/org/apache/stormcrawler/opensearch/metrics/MetricsConsumer.java
@@ -38,8 +38,8 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Sends metrics to an OpenSearch index. The OpenSearch details are set in the configuration; an optional
- * argument sets a date format to append to the index name.
+ * Sends metrics to an OpenSearch index. The OpenSearch details are set in the configuration; an
+ * optional argument sets a date format to append to the index name.
*
* <pre>
* topology.metrics.consumer.register:
diff --git a/external/opensearch/src/main/java/org/apache/stormcrawler/opensearch/persistence/AggregationSpout.java b/external/opensearch/src/main/java/org/apache/stormcrawler/opensearch/persistence/AggregationSpout.java
index 2df2e116..f7fea25b 100644
--- a/external/opensearch/src/main/java/org/apache/stormcrawler/opensearch/persistence/AggregationSpout.java
+++ b/external/opensearch/src/main/java/org/apache/stormcrawler/opensearch/persistence/AggregationSpout.java
@@ -59,10 +59,10 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
/**
- * Spout which pulls URL from an OpenSearch index. Use a single instance unless you use 'es.status.routing'
- * with the StatusUpdaterBolt, in which case you need to have exactly the same number of spout
- * instances as OpenSearch shards. Guarantees a good mix of URLs by aggregating them by an arbitrary field
- * e.g. key.
+ * Spout which pulls URL from an OpenSearch index. Use a single instance unless you use
+ * 'opensearch.status.routing' with the StatusUpdaterBolt, in which case you need to have exactly
+ * the same number of spout instances as OpenSearch shards. Guarantees a good mix of URLs by
+ * aggregating them by an arbitrary field e.g. key.
*/
public class AggregationSpout extends AbstractSpout implements ActionListener<SearchResponse> {