Repository: nifi Updated Branches: refs/heads/master 0831059d2 -> 4349a8e07
NIFI-5231: CalculateRecordCount should use 'record.count' This closes #2792 Signed-off-by: Mike Thomsen <mikerthom...@gmail.com> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/4349a8e0 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/4349a8e0 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/4349a8e0 Branch: refs/heads/master Commit: 4349a8e07873e44dccfd42ca33b2a9b25587bc3c Parents: 0831059 Author: Koji Kawamura <ijokaruma...@apache.org> Authored: Thu Jun 14 11:26:20 2018 +0900 Committer: Mike Thomsen <mikerthom...@gmail.com> Committed: Thu Jun 14 07:02:47 2018 -0400 ---------------------------------------------------------------------- .../nifi/processors/standard/CalculateRecordStats.java | 2 +- .../nifi/processors/standard/TestCalculateRecordStats.groovy | 8 ++++---- 2 files changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/4349a8e0/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CalculateRecordStats.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CalculateRecordStats.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CalculateRecordStats.java index 93029a9..80627e9 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CalculateRecordStats.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CalculateRecordStats.java @@ -64,7 +64,7 @@ import java.util.stream.Collectors; "Total number of top N value counts to be added is defined by the limit configuration.") }) public class CalculateRecordStats extends AbstractProcessor { - static final String RECORD_COUNT_ATTR = "record_count"; + static final String RECORD_COUNT_ATTR = "record.count"; static final PropertyDescriptor RECORD_READER = new PropertyDescriptor.Builder() .name("record-stats-reader") http://git-wip-us.apache.org/repos/asf/nifi/blob/4349a8e0/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/groovy/org/apache/nifi/processors/standard/TestCalculateRecordStats.groovy ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/groovy/org/apache/nifi/processors/standard/TestCalculateRecordStats.groovy b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/groovy/org/apache/nifi/processors/standard/TestCalculateRecordStats.groovy index 6e3b1fc..9f6b5a0 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/groovy/org/apache/nifi/processors/standard/TestCalculateRecordStats.groovy +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/groovy/org/apache/nifi/processors/standard/TestCalculateRecordStats.groovy @@ -63,7 +63,7 @@ class TestCalculateRecordStats { "recordStats.sport.Football": "2", "recordStats.sport.Basketball": "1", "recordStats.sport": "6", - "record_count": "6" + "record.count": "6" ] commonTest([ "sport": "/person/sport"], sports, expectedAttributes) @@ -77,7 +77,7 @@ class TestCalculateRecordStats { "recordStats.sport.Football": "1", "recordStats.sport.Basketball": "1", "recordStats.sport": "3", - "record_count": "6" + "record.count": "6" ] commonTest([ "sport": "/person/sport"], sports, expectedAttributes) @@ -90,7 +90,7 @@ class TestCalculateRecordStats { "recordStats.sport.Soccer": "3", "recordStats.sport.Basketball": "1", "recordStats.sport": "4", - "record_count": "6" + "record.count": "6" ] def propz = [ @@ -112,7 +112,7 @@ class TestCalculateRecordStats { "recordStats.sport.Soccer": "3", "recordStats.sport.Baseball": "4", "recordStats.sport": String.valueOf(sports.size()), - "record_count": String.valueOf(sports.size()) + "record.count": String.valueOf(sports.size()) ] def propz = [
