This is an automated email from the ASF dual-hosted git repository.
rzo1 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/storm.git
commit 3aa254e1fd52bfdf3e06db2879157e570942bbca
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>>();
