(storm) branch STORM-4005---ElasticSearch-7.17.13- updated: STORM-4005 - Checkstyle

[rzo1]

This is an automated email from the ASF dual-hosted git repository.

rzo1 pushed a commit to branch STORM-4005---ElasticSearch-7.17.13-
in repository https://gitbox.apache.org/repos/asf/storm.git


The following commit(s) were added to 
refs/heads/STORM-4005---ElasticSearch-7.17.13- by this push:
     new fa6a74057 STORM-4005 - Checkstyle
fa6a74057 is described below

commit fa6a74057a2df8b9eb3c73cc8ae7560da39a51a0
Author: Richard Zowalla <richard.zowa...@hs-heilbronn.de>
AuthorDate: Wed Nov 29 16:42:42 2023 +0100

    STORM-4005 - Checkstyle
---
 .../org/apache/storm/elasticsearch/bolt/EsIndexTopology.java | 12 +++++++-----
 .../org/apache/storm/elasticsearch/common/EsConstants.java   |  2 +-
 .../storm/elasticsearch/trident/TridentEsTopology.java       | 10 ++++++----
 3 files changed, 14 insertions(+), 10 deletions(-)

diff --git 
a/examples/storm-elasticsearch-examples/src/main/java/org/apache/storm/elasticsearch/bolt/EsIndexTopology.java
 
b/examples/storm-elasticsearch-examples/src/main/java/org/apache/storm/elasticsearch/bolt/EsIndexTopology.java
index 3c3e8565a..c8e9c8948 100644
--- 
a/examples/storm-elasticsearch-examples/src/main/java/org/apache/storm/elasticsearch/bolt/EsIndexTopology.java
+++ 
b/examples/storm-elasticsearch-examples/src/main/java/org/apache/storm/elasticsearch/bolt/EsIndexTopology.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
@@ -24,7 +24,9 @@ import java.util.concurrent.ConcurrentHashMap;
 
 import org.apache.storm.Config;
 import org.apache.storm.StormSubmitter;
-import org.apache.storm.elasticsearch.common.*;
+import org.apache.storm.elasticsearch.common.DefaultEsTupleMapper;
+import org.apache.storm.elasticsearch.common.EsConfig;
+import org.apache.storm.elasticsearch.common.EsTupleMapper;
 import org.apache.storm.generated.AlreadyAliveException;
 import org.apache.storm.generated.AuthorizationException;
 import org.apache.storm.generated.InvalidTopologyException;
@@ -73,7 +75,7 @@ public final class EsIndexTopology {
         TopologyBuilder builder = new TopologyBuilder();
         UserDataSpout spout = new UserDataSpout();
         builder.setSpout(SPOUT_ID, spout, 1);
-        EsTupleMapper tupleMapper =new DefaultEsTupleMapper();
+        EsTupleMapper tupleMapper = new DefaultEsTupleMapper();
         EsConfig esConfig = new EsConfig("http://localhost:9300";);
         builder.setBolt(BOLT_ID, new EsIndexBolt(esConfig, tupleMapper), 1)
                 .shuffleGrouping(SPOUT_ID);
@@ -127,8 +129,8 @@ public final class EsIndexTopology {
          */
         @Override
         public void open(final Map<String, Object> config,
-                final TopologyContext context,
-                final SpoutOutputCollector collectorArg) {
+                         final TopologyContext context,
+                         final SpoutOutputCollector collectorArg) {
             this.collector = collectorArg;
             this.pending = new ConcurrentHashMap<>();
         }
diff --git 
a/examples/storm-elasticsearch-examples/src/main/java/org/apache/storm/elasticsearch/common/EsConstants.java
 
b/examples/storm-elasticsearch-examples/src/main/java/org/apache/storm/elasticsearch/common/EsConstants.java
index 7f7c38a0f..fd513d144 100644
--- 
a/examples/storm-elasticsearch-examples/src/main/java/org/apache/storm/elasticsearch/common/EsConstants.java
+++ 
b/examples/storm-elasticsearch-examples/src/main/java/org/apache/storm/elasticsearch/common/EsConstants.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
diff --git 
a/examples/storm-elasticsearch-examples/src/main/java/org/apache/storm/elasticsearch/trident/TridentEsTopology.java
 
b/examples/storm-elasticsearch-examples/src/main/java/org/apache/storm/elasticsearch/trident/TridentEsTopology.java
index 311c816b7..d1a059f3c 100644
--- 
a/examples/storm-elasticsearch-examples/src/main/java/org/apache/storm/elasticsearch/trident/TridentEsTopology.java
+++ 
b/examples/storm-elasticsearch-examples/src/main/java/org/apache/storm/elasticsearch/trident/TridentEsTopology.java
@@ -1,4 +1,4 @@
-/**
+/*
  * Licensed to the Apache Software Foundation (ASF) under one
  * or more contributor license agreements.  See the NOTICE file
  * distributed with this work for additional information
@@ -26,7 +26,9 @@ import java.util.UUID;
 
 import org.apache.storm.Config;
 import org.apache.storm.StormSubmitter;
-import org.apache.storm.elasticsearch.common.*;
+import org.apache.storm.elasticsearch.common.DefaultEsTupleMapper;
+import org.apache.storm.elasticsearch.common.EsConfig;
+import org.apache.storm.elasticsearch.common.EsTupleMapper;
 import org.apache.storm.generated.AlreadyAliveException;
 import org.apache.storm.generated.AuthorizationException;
 import org.apache.storm.generated.InvalidTopologyException;
@@ -141,7 +143,7 @@ public final class TridentEsTopology {
          */
         @Override
         public void open(final Map<String, Object> conf,
-                final TopologyContext context) {
+                         final TopologyContext context) {
             index = 0;
         }
 
@@ -152,7 +154,7 @@ public final class TridentEsTopology {
          */
         @Override
         public void emitBatch(final long batchId,
-                final TridentCollector collector) {
+                              final TridentCollector collector) {
             List<List<Object>> batch = this.batches.get(batchId);
             if (batch == null) {
                 batch = new ArrayList<List<Object>>();