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 <[email protected]> AuthorDate: Fri Oct 25 12:27:21 2024 +0100 Fix formatting Signed-off-by: Julien Nioche <[email protected]> --- .../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> {
