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 );