diff --git a/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-json-record-utils/src/main/java/org/apache/nifi/json/AbstractJsonRowRecordReader.java b/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-json-record-utils/src/main/java/org/apache/nifi/json/AbstractJsonRowRecordReader.java index 58a41cdfb8..c43cfd190f 100644 --- a/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-json-record-utils/src/main/java/org/apache/nifi/json/AbstractJsonRowRecordReader.java +++ b/nifi-extension-bundles/nifi-extension-utils/nifi-record-utils/nifi-json-record-utils/src/main/java/org/apache/nifi/json/AbstractJsonRowRecordReader.java @@ -144,7 +144,7 @@ public abstract class AbstractJsonRowRecordReader implements RecordReader { if (strategy == StartingFieldStrategy.NESTED_FIELD) { while (jsonParser.nextToken() != null) { - if (nestedFieldName.equals(jsonParser.getCurrentName())) { + if (nestedFieldName.equals(jsonParser.currentName())) { logger.debug("Parsing starting at nested field [{}]", nestedFieldName); break; } @@ -306,7 +306,7 @@ public abstract class AbstractJsonRowRecordReader implements RecordReader { if (jsonParser.getCurrentToken() == JsonToken.FIELD_NAME) { jsonParser.nextToken(); - final String fieldName = jsonParser.getCurrentName(); + final String fieldName = jsonParser.currentName(); final String fieldValue = jsonParser.getValueAsString(); if (captureFieldPredicate.test(fieldName, fieldValue)) { diff --git a/nifi-extension-bundles/nifi-hubspot-bundle/nifi-hubspot-processors/src/main/java/org/apache/nifi/processors/hubspot/GetHubSpot.java b/nifi-extension-bundles/nifi-hubspot-bundle/nifi-hubspot-processors/src/main/java/org/apache/nifi/processors/hubspot/GetHubSpot.java index a37a0b4354..9ab01fb2f8 100644 --- a/nifi-extension-bundles/nifi-hubspot-bundle/nifi-hubspot-processors/src/main/java/org/apache/nifi/processors/hubspot/GetHubSpot.java +++ b/nifi-extension-bundles/nifi-hubspot-bundle/nifi-hubspot-processors/src/main/java/org/apache/nifi/processors/hubspot/GetHubSpot.java @@ -271,17 +271,17 @@ public class GetHubSpot extends AbstractProcessor { final JsonGenerator jsonGenerator = JSON_FACTORY.createGenerator(out, JsonEncoding.UTF8)) { boolean isCursorAvailable = false; while (jsonParser.nextToken() != null) { - if (jsonParser.getCurrentToken() == JsonToken.FIELD_NAME && jsonParser.getCurrentName() + if (jsonParser.getCurrentToken() == JsonToken.FIELD_NAME && jsonParser.currentName() .equals("total")) { jsonParser.nextToken(); total.set(jsonParser.getIntValue()); } - if (jsonParser.getCurrentToken() == JsonToken.FIELD_NAME && jsonParser.getCurrentName() + if (jsonParser.getCurrentToken() == JsonToken.FIELD_NAME && jsonParser.currentName() .equals("results")) { jsonParser.nextToken(); jsonGenerator.copyCurrentStructure(jsonParser); } - final String fieldName = jsonParser.getCurrentName(); + final String fieldName = jsonParser.currentName(); if (PAGING_CURSOR.equals(fieldName)) { isCursorAvailable = true; jsonParser.nextToken(); diff --git a/nifi-extension-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/java/org/apache/nifi/processors/salesforce/QuerySalesforceObject.java b/nifi-extension-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/java/org/apache/nifi/processors/salesforce/QuerySalesforceObject.java index 7e8957cd90..1a538d367e 100644 --- a/nifi-extension-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/java/org/apache/nifi/processors/salesforce/QuerySalesforceObject.java +++ b/nifi-extension-bundles/nifi-salesforce-bundle/nifi-salesforce-processors/src/main/java/org/apache/nifi/processors/salesforce/QuerySalesforceObject.java @@ -570,7 +570,7 @@ public class QuerySalesforceObject extends AbstractProcessor { } private boolean nextTokenIs(JsonParser jsonParser, String value) throws IOException { - return jsonParser.getCurrentToken() == JsonToken.FIELD_NAME && jsonParser.getCurrentName() + return jsonParser.getCurrentToken() == JsonToken.FIELD_NAME && jsonParser.currentName() .equals(value) && jsonParser.nextToken() != null; } diff --git a/nifi-extension-bundles/nifi-shopify-bundle/nifi-shopify-processors/src/main/java/org/apache/nifi/processors/shopify/GetShopify.java b/nifi-extension-bundles/nifi-shopify-bundle/nifi-shopify-processors/src/main/java/org/apache/nifi/processors/shopify/GetShopify.java index 24bf246711..e53a921393 100644 --- a/nifi-extension-bundles/nifi-shopify-bundle/nifi-shopify-processors/src/main/java/org/apache/nifi/processors/shopify/GetShopify.java +++ b/nifi-extension-bundles/nifi-shopify-bundle/nifi-shopify-processors/src/main/java/org/apache/nifi/processors/shopify/GetShopify.java @@ -376,7 +376,7 @@ public class GetShopify extends AbstractProcessor { try (JsonParser jsonParser = JSON_FACTORY.createParser(response.body()); final JsonGenerator jsonGenerator = JSON_FACTORY.createGenerator(out, JsonEncoding.UTF8)) { while (jsonParser.nextToken() != null) { - if (jsonParser.getCurrentToken() == JsonToken.FIELD_NAME && jsonParser.getCurrentName() + if (jsonParser.getCurrentToken() == JsonToken.FIELD_NAME && jsonParser.currentName() .equals(resourceName)) { jsonParser.nextToken(); jsonGenerator.writeStartArray(); diff --git a/nifi-extension-bundles/nifi-zendesk-bundle/nifi-zendesk-processors/src/main/java/org/apache/nifi/processors/zendesk/GetZendesk.java b/nifi-extension-bundles/nifi-zendesk-bundle/nifi-zendesk-processors/src/main/java/org/apache/nifi/processors/zendesk/GetZendesk.java index 58cd021df6..8db539f434 100644 --- a/nifi-extension-bundles/nifi-zendesk-bundle/nifi-zendesk-processors/src/main/java/org/apache/nifi/processors/zendesk/GetZendesk.java +++ b/nifi-extension-bundles/nifi-zendesk-bundle/nifi-zendesk-processors/src/main/java/org/apache/nifi/processors/zendesk/GetZendesk.java @@ -217,7 +217,7 @@ public class GetZendesk extends AbstractZendesk { JsonGenerator generator = JSON_FACTORY.createGenerator(out, UTF8)) { while (parser.nextToken() != null) { if (parser.getCurrentToken() == FIELD_NAME) { - String fieldName = parser.getCurrentName(); + String fieldName = parser.currentName(); parser.nextToken(); if (zendeskResource.getResponseFieldName().equals(fieldName)) { int numberOfExtractedRecords = extractZendeskResourceData(parser, generator);