From c8928ce3509facbf4b6501295273849de2288fab Mon Sep 17 00:00:00 2001 From: rednikotin Date: Fri, 19 Oct 2018 14:22:33 +0300 Subject: [PATCH] NIFI-5727: Added replace unnecessary row count with -1 stub value when paging is used Signed-off-by: Matthew Burgess This closes #3094 --- .../nifi/processors/standard/GenerateTableFetch.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GenerateTableFetch.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GenerateTableFetch.java index dd001a67c4..49779e9c44 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GenerateTableFetch.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/GenerateTableFetch.java @@ -290,7 +290,13 @@ public class GenerateTableFetch extends AbstractDatabaseFetchProcessor { String columnsClause = null; List maxValueSelectColumns = new ArrayList<>(numMaxValueColumns + 1); - maxValueSelectColumns.add("COUNT(*)"); + + // replace unnecessary row count with -1 stub value when paging is used + if (useColumnValsForPaging) { + maxValueSelectColumns.add("-1"); + } else { + maxValueSelectColumns.add("COUNT(*)"); + } // For each maximum-value column, get a WHERE filter and a MAX(column) alias IntStream.range(0, numMaxValueColumns).forEach((index) -> {