[GitHub] nifi pull request #2666: NIFI-5130 ExecuteInfluxDBQuery processor chunking s...

[MikeThomsen]

Github user MikeThomsen commented on a diff in the pull request:

    https://github.com/apache/nifi/pull/2666#discussion_r186126226
  
    --- Diff: 
nifi-nar-bundles/nifi-influxdb-bundle/nifi-influxdb-processors/src/main/java/org/apache/nifi/processors/influxdb/ExecuteInfluxDBQuery.java
 ---
    @@ -189,9 +209,10 @@ public void onTrigger(final ProcessContext context, 
final ProcessSession session
     
             try {
                 long startTimeMillis = System.currentTimeMillis();
    -            QueryResult result = executeQuery(context, database, query, 
queryResultTimeunit);
    +            int chunkSize = 
Integer.valueOf(context.getProperty(INFLUX_DB_QUERY_CHUNK_SIZE).evaluateAttributeExpressions(outgoingFlowFile).getValue());
    --- End diff --
    
    You can use `asInteger()` or `asLong()` here instead of using 
`Integer.valueOf` and `getValue()`


---