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

hansva pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-hop.git


The following commit(s) were added to refs/heads/master by this push:
     new 6571485  Private fields only used as local variables in methods should 
become local variables
     new 0b856ef  Merge pull request #636 from 
nanthakumar1305/sonorqube_20210220
6571485 is described below

commit 65714856e3a3a2924d351cde701834182791549f
Author: nanthakumar1305 <[email protected]>
AuthorDate: Sat Feb 20 08:21:52 2021 +0000

    Private fields only used as local variables in methods should become local 
variables
---
 .../org/apache/hop/beam/core/transform/BeamPublishTransform.java | 9 +++------
 1 file changed, 3 insertions(+), 6 deletions(-)

diff --git 
a/plugins/engines/beam/src/main/java/org/apache/hop/beam/core/transform/BeamPublishTransform.java
 
b/plugins/engines/beam/src/main/java/org/apache/hop/beam/core/transform/BeamPublishTransform.java
index eb9d9ca..8e47ab7 100644
--- 
a/plugins/engines/beam/src/main/java/org/apache/hop/beam/core/transform/BeamPublishTransform.java
+++ 
b/plugins/engines/beam/src/main/java/org/apache/hop/beam/core/transform/BeamPublishTransform.java
@@ -54,9 +54,6 @@ public class BeamPublishTransform extends 
PTransform<PCollection<HopRow>, PDone>
   private static final Logger LOG = LoggerFactory.getLogger( 
BeamPublishTransform.class );
 
   private transient IRowMeta rowMeta;
-  private transient Counter initCounter;
-  private transient Counter readCounter;
-  private transient Counter outputCounter;
   private transient Counter errorCounter;
   private transient int fieldIndex;
 
@@ -88,9 +85,9 @@ public class BeamPublishTransform extends 
PTransform<PCollection<HopRow>, PDone>
 
         rowMeta = JsonRowMeta.fromJson( rowMetaJson );
 
-        initCounter = Metrics.counter( Pipeline.METRIC_NAME_INIT, 
transformName );
-        readCounter = Metrics.counter( Pipeline.METRIC_NAME_READ, 
transformName );
-        outputCounter = Metrics.counter( Pipeline.METRIC_NAME_OUTPUT, 
transformName );
+        Counter initCounter = Metrics.counter( Pipeline.METRIC_NAME_INIT, 
transformName );
+        Counter readCounter = Metrics.counter( Pipeline.METRIC_NAME_READ, 
transformName );
+        Counter outputCounter = Metrics.counter( Pipeline.METRIC_NAME_OUTPUT, 
transformName );
         errorCounter = Metrics.counter( Pipeline.METRIC_NAME_ERROR, 
transformName );
 
         fieldIndex = rowMeta.indexOfValue( messageField );

Reply via email to