This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 6bee11633c8 NIFI-15881 Replaced non-standard spelling of FlowFile in
documentation (#11180)
6bee11633c8 is described below
commit 6bee11633c82ab20a15caf21a16ee54cdcc5fffa
Author: dan-s1 <[email protected]>
AuthorDate: Sat May 2 11:57:22 2026 -0400
NIFI-15881 Replaced non-standard spelling of FlowFile in documentation
(#11180)
Signed-off-by: David Handermann <[email protected]>
---
.../nifi/processors/aws/lambda/PutLambda.java | 6 ++--
.../org/apache/nifi/processors/aws/s3/ListS3.java | 4 +--
.../data/explorer/StandardKustoIngestService.java | 2 +-
.../AbstractByQueryElasticsearch.java | 4 +--
.../AbstractJsonQueryElasticsearch.java | 8 +++---
.../AbstractPaginatedJsonQueryElasticsearch.java | 4 +--
.../elasticsearch/ConsumeElasticsearch.java | 4 +--
.../elasticsearch/DeleteByQueryElasticsearch.java | 2 +-
.../elasticsearch/ElasticsearchRestProcessor.java | 6 ++--
.../elasticsearch/JsonQueryElasticsearch.java | 8 +++---
.../PaginatedJsonQueryElasticsearch.java | 10 +++----
.../elasticsearch/SearchElasticsearch.java | 8 +++---
.../elasticsearch/UpdateByQueryElasticsearch.java | 2 +-
.../elasticsearch/api/ResultOutputStrategy.java | 6 ++--
.../nifi/processors/email/ExtractEmailHeaders.java | 4 +--
.../apache/nifi/processors/GeoEnrichIPRecord.java | 6 ++--
.../processors/gcp/pubsub/PublishGCPubSub.java | 2 +-
.../processors/graph/AbstractGraphExecutor.java | 2 +-
.../apache/nifi/processors/hadoop/DeleteHDFS.java | 8 +++---
.../nifi/processors/hadoop/GetHDFSFileInfo.java | 14 +++++-----
.../processors/image/ExtractImageMetadata.java | 2 +-
.../processors/media/ExtractMediaMetadata.java | 8 +++---
.../processors/mongodb/AbstractMongoProcessor.java | 2 +-
.../nifi/processors/mongodb/DeleteMongo.java | 6 ++--
.../apache/nifi/processors/mongodb/PutMongo.java | 2 +-
.../nifi/processors/mongodb/PutMongoRecord.java | 2 +-
.../processors/mongodb/RunMongoAggregation.java | 6 ++--
.../mongodb/gridfs/AbstractGridFSProcessor.java | 4 +--
.../processors/mongodb/gridfs/FetchGridFS.java | 2 +-
.../nifi/processors/standard/AttributesToCSV.java | 16 +++++------
.../nifi/processors/standard/AttributesToJSON.java | 6 ++--
.../standard/CryptographicHashContent.java | 6 ++--
.../nifi/processors/standard/ExtractGrok.java | 10 +++----
.../apache/nifi/web/api/FlowFileQueueResource.java | 32 +++++++++++-----------
.../apache/nifi/web/api/ProvenanceResource.java | 10 +++----
35 files changed, 112 insertions(+), 112 deletions(-)
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/lambda/PutLambda.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/lambda/PutLambda.java
index 8d327c788d1..e53731037d0 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/lambda/PutLambda.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/lambda/PutLambda.java
@@ -201,11 +201,11 @@ public class PutLambda extends
AbstractAwsSyncProcessor<LambdaClient, LambdaClie
}
/**
- * Populate exception attributes in the flow file
+ * Populate exception attributes in the FlowFile
* @param session process session
- * @param flowFile the flow file
+ * @param flowFile the FlowFile
* @param exception exception thrown during invocation
- * @return FlowFile the updated flow file
+ * @return FlowFile the updated FlowFile
*/
private FlowFile populateExceptionAttributes(final ProcessSession session,
FlowFile flowFile,
final AwsServiceException exception) {
diff --git
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/ListS3.java
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/ListS3.java
index b81aac8822b..113fe88fe16 100644
---
a/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/ListS3.java
+++
b/nifi-extension-bundles/nifi-aws-bundle/nifi-aws-processors/src/main/java/org/apache/nifi/processors/aws/s3/ListS3.java
@@ -127,9 +127,9 @@ import static
org.apache.nifi.processors.aws.s3.util.S3Util.sanitizeETag;
@WritesAttribute(attribute = "s3.storeClass", description = "The
storage class of the object"),
@WritesAttribute(attribute = "s3.version", description = "The version
of the object, if applicable"),
@WritesAttribute(attribute = "s3.tag.___", description = "If 'Write
Object Tags' is set to 'True', the tags associated to the S3 object that is
being listed " +
- "will be written as part of the flowfile attributes"),
+ "will be written as part of the FlowFile attributes"),
@WritesAttribute(attribute = "s3.user.metadata.___", description = "If
'Write User Metadata' is set to 'True', the user defined metadata associated to
the S3 object that is being listed " +
- "will be written as part of the flowfile attributes")})
+ "will be written as part of the FlowFile attributes")})
@DefaultSchedule(strategy = SchedulingStrategy.TIMER_DRIVEN, period = "1 min")
public class ListS3 extends AbstractS3Processor implements VerifiableProcessor
{
diff --git
a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/services/azure/data/explorer/StandardKustoIngestService.java
b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/services/azure/data/explorer/StandardKustoIngestService.java
index d333a9f019b..3fe0249fecf 100644
---
a/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/services/azure/data/explorer/StandardKustoIngestService.java
+++
b/nifi-extension-bundles/nifi-azure-bundle/nifi-azure-processors/src/main/java/org/apache/nifi/services/azure/data/explorer/StandardKustoIngestService.java
@@ -59,7 +59,7 @@ import java.util.Objects;
import java.util.Optional;
@Tags({"Azure", "Data", "Explorer", "ADX", "Kusto", "ingest", "azure"})
-@CapabilityDescription("Sends batches of flowfile content or stream flowfile
content to an Azure ADX cluster.")
+@CapabilityDescription("Sends batches of FlowFile content or stream FlowFile
content to an Azure ADX cluster.")
public class StandardKustoIngestService extends AbstractControllerService
implements KustoIngestService {
public static final PropertyDescriptor AUTHENTICATION_STRATEGY = new
PropertyDescriptor.Builder()
diff --git
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractByQueryElasticsearch.java
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractByQueryElasticsearch.java
index bdcfab87626..4acffc518cc 100644
---
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractByQueryElasticsearch.java
+++
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractByQueryElasticsearch.java
@@ -43,11 +43,11 @@ import java.util.concurrent.atomic.AtomicReference;
public abstract class AbstractByQueryElasticsearch extends AbstractProcessor
implements ElasticsearchRestProcessor {
public static final Relationship REL_FAILURE = new
Relationship.Builder().name("failure")
- .description("If the \"by query\" operation fails, and a flowfile
was read, it will be sent to this relationship.")
+ .description("If the \"by query\" operation fails, and a FlowFile
was read, it will be sent to this relationship.")
.build();
public static final Relationship REL_SUCCESS = new
Relationship.Builder().name("success")
- .description("If the \"by query\" operation succeeds, and a
flowfile was read, it will be sent to this relationship.")
+ .description("If the \"by query\" operation succeeds, and a
FlowFile was read, it will be sent to this relationship.")
.build();
private static final Set<Relationship> relationships = Set.of(REL_SUCCESS,
REL_FAILURE, REL_RETRY);
diff --git
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractJsonQueryElasticsearch.java
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractJsonQueryElasticsearch.java
index 0bd447e78a0..304e6744c3c 100644
---
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractJsonQueryElasticsearch.java
+++
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractJsonQueryElasticsearch.java
@@ -63,7 +63,7 @@ public abstract class AbstractJsonQueryElasticsearch<Q
extends JsonQueryParamete
public static final PropertyDescriptor SEARCH_RESULTS_SPLIT = new
PropertyDescriptor.Builder()
.name("Search Results Split")
- .description("Output a flowfile containing all hits or one
flowfile for each individual hit.")
+ .description("Output a FlowFile containing all hits or one
FlowFile for each individual hit.")
.allowableValues(ResultOutputStrategy.getNonPaginatedResponseOutputStrategies())
.defaultValue(ResultOutputStrategy.PER_RESPONSE)
.required(true)
@@ -80,7 +80,7 @@ public abstract class AbstractJsonQueryElasticsearch<Q
extends JsonQueryParamete
.build();
public static final PropertyDescriptor AGGREGATION_RESULTS_SPLIT = new
PropertyDescriptor.Builder()
.name("Aggregation Results Split")
- .description("Output a flowfile containing all aggregations or one
flowfile for each individual aggregation.")
+ .description("Output a FlowFile containing all aggregations or one
FlowFile for each individual aggregation.")
.allowableValues(ResultOutputStrategy.getNonPaginatedResponseOutputStrategies())
.defaultValue(ResultOutputStrategy.PER_RESPONSE)
.required(true)
@@ -97,8 +97,8 @@ public abstract class AbstractJsonQueryElasticsearch<Q
extends JsonQueryParamete
.build();
public static final PropertyDescriptor OUTPUT_NO_HITS = new
PropertyDescriptor.Builder()
.name("Output No Hits")
- .description("Output a \"" + REL_HITS.getName() + "\" flowfile
even if no hits found for query. " +
- "If true, an empty \"" + REL_HITS.getName() + "\" flowfile
will be output even if \"" +
+ .description("Output a \"" + REL_HITS.getName() + "\" FlowFile
even if no hits found for query. " +
+ "If true, an empty \"" + REL_HITS.getName() + "\" FlowFile
will be output even if \"" +
REL_AGGREGATIONS.getName() + "\" are output.")
.allowableValues("true", "false")
.defaultValue("false")
diff --git
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractPaginatedJsonQueryElasticsearch.java
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractPaginatedJsonQueryElasticsearch.java
index 8c3b6d08947..b18e2856411 100644
---
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractPaginatedJsonQueryElasticsearch.java
+++
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/AbstractPaginatedJsonQueryElasticsearch.java
@@ -47,8 +47,8 @@ import java.util.stream.Stream;
public abstract class AbstractPaginatedJsonQueryElasticsearch extends
AbstractJsonQueryElasticsearch<PaginatedJsonQueryParameters> {
public static final PropertyDescriptor SEARCH_RESULTS_SPLIT = new
PropertyDescriptor.Builder()
.fromPropertyDescriptor(AbstractJsonQueryElasticsearch.SEARCH_RESULTS_SPLIT)
- .description("Output a flowfile containing all hits or one
flowfile for each individual hit " +
- "or one flowfile containing all hits from all paged
responses.")
+ .description("Output a FlowFile containing all hits or one
FlowFile for each individual hit " +
+ "or one FlowFile containing all hits from all paged
responses.")
.allowableValues(ResultOutputStrategy.class)
.build();
diff --git
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/ConsumeElasticsearch.java
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/ConsumeElasticsearch.java
index f2a914769d1..7c8934eb05c 100644
---
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/ConsumeElasticsearch.java
+++
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/ConsumeElasticsearch.java
@@ -59,8 +59,8 @@ import java.util.stream.Stream;
@WritesAttributes({
@WritesAttribute(attribute = "mime.type", description =
"application/json"),
- @WritesAttribute(attribute = "page.number", description = "The number
of the page (request), starting from 1, in which the results were returned that
are in the output flowfile"),
- @WritesAttribute(attribute = "hit.count", description = "The number of
hits that are in the output flowfile"),
+ @WritesAttribute(attribute = "page.number", description = "The number
of the page (request), starting from 1, in which the results were returned that
are in the output FlowFile"),
+ @WritesAttribute(attribute = "hit.count", description = "The number of
hits that are in the output FlowFile"),
@WritesAttribute(attribute = "elasticsearch.query.error", description
= "The error message provided by Elasticsearch if there is an error querying
the index.")
})
@InputRequirement(InputRequirement.Requirement.INPUT_FORBIDDEN)
diff --git
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/DeleteByQueryElasticsearch.java
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/DeleteByQueryElasticsearch.java
index 38c8080843d..da2dab74b28 100644
---
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/DeleteByQueryElasticsearch.java
+++
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/DeleteByQueryElasticsearch.java
@@ -40,7 +40,7 @@ import java.util.List;
@InputRequirement(InputRequirement.Requirement.INPUT_ALLOWED)
@SupportsBatching
@Tags({ "elastic", "elasticsearch", "elasticsearch7", "elasticsearch8",
"elasticsearch9", "delete", "query"})
-@CapabilityDescription("Delete from an Elasticsearch index using a query. The
query can be loaded from a flowfile body " +
+@CapabilityDescription("Delete from an Elasticsearch index using a query. The
query can be loaded from a FlowFile body " +
"or from the Query parameter.")
@DynamicProperties({
@DynamicProperty(
diff --git
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/ElasticsearchRestProcessor.java
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/ElasticsearchRestProcessor.java
index 2ab8446ab53..c2777e1576d 100644
---
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/ElasticsearchRestProcessor.java
+++
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/ElasticsearchRestProcessor.java
@@ -92,8 +92,8 @@ public interface ElasticsearchRestProcessor extends
Processor, VerifiableProcess
PropertyDescriptor QUERY = new PropertyDescriptor.Builder()
.name("Query")
.description("A query in JSON syntax, not Lucene syntax. Ex:
{\"query\":{\"match\":{\"somefield\":\"somevalue\"}}}. " +
- "If this parameter is not set, the query will be read from
the flowfile content. " +
- "If the query (property and flowfile content) is empty, a
default empty JSON Object will be used, " +
+ "If this parameter is not set, the query will be read from
the FlowFile content. " +
+ "If the query (property and FlowFile content) is empty, a
default empty JSON Object will be used, " +
"which will result in a \"match_all\" query in
Elasticsearch.")
.dependsOn(QUERY_DEFINITION_STYLE, QueryDefinitionType.FULL_QUERY)
.required(false)
@@ -174,7 +174,7 @@ public interface ElasticsearchRestProcessor extends
Processor, VerifiableProcess
PropertyDescriptor QUERY_ATTRIBUTE = new PropertyDescriptor.Builder()
.name("Query Attribute")
- .description("If set, the executed query will be set on each
result flowfile in the specified attribute.")
+ .description("If set, the executed query will be set on each
result FlowFile in the specified attribute.")
.expressionLanguageSupported(ExpressionLanguageScope.FLOWFILE_ATTRIBUTES)
.addValidator(Validator.VALID)
.required(false)
diff --git
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/JsonQueryElasticsearch.java
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/JsonQueryElasticsearch.java
index 4ae59fd07c2..725386d1973 100644
---
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/JsonQueryElasticsearch.java
+++
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/JsonQueryElasticsearch.java
@@ -40,9 +40,9 @@ import java.util.concurrent.TimeUnit;
@WritesAttributes({
@WritesAttribute(attribute = "mime.type", description =
"application/json"),
- @WritesAttribute(attribute = "aggregation.name", description = "The name
of the aggregation whose results are in the output flowfile"),
- @WritesAttribute(attribute = "aggregation.number", description = "The
number of the aggregation whose results are in the output flowfile"),
- @WritesAttribute(attribute = "hit.count", description = "The number of
hits that are in the output flowfile"),
+ @WritesAttribute(attribute = "aggregation.name", description = "The name
of the aggregation whose results are in the output FlowFile"),
+ @WritesAttribute(attribute = "aggregation.number", description = "The
number of the aggregation whose results are in the output FlowFile"),
+ @WritesAttribute(attribute = "hit.count", description = "The number of
hits that are in the output FlowFile"),
@WritesAttribute(attribute = "elasticsearch.query.error", description =
"The error message provided by Elasticsearch if there is an error querying the
index.")
})
@InputRequirement(InputRequirement.Requirement.INPUT_ALLOWED)
@@ -50,7 +50,7 @@ import java.util.concurrent.TimeUnit;
@Tags({"elasticsearch", "elasticsearch7", "elasticsearch8", "elasticsearch9",
"query", "read", "get", "json"})
@CapabilityDescription("A processor that allows the user to run a query (with
aggregations) written with the " +
"Elasticsearch JSON DSL. It does not automatically paginate queries
for the user. If an incoming relationship is added to this " +
- "processor, it will use the flowfile's content for the query. Care
should be taken on the size of the query because the entire response " +
+ "processor, it will use the FlowFile's content for the query. Care
should be taken on the size of the query because the entire response " +
"from Elasticsearch will be loaded into memory all at once and
converted into the resulting FlowFiles.")
@SeeAlso(PaginatedJsonQueryElasticsearch.class)
@DynamicProperties({
diff --git
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/PaginatedJsonQueryElasticsearch.java
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/PaginatedJsonQueryElasticsearch.java
index aad4a578b4a..195227f7388 100644
---
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/PaginatedJsonQueryElasticsearch.java
+++
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/PaginatedJsonQueryElasticsearch.java
@@ -38,16 +38,16 @@ import java.util.List;
@WritesAttributes({
@WritesAttribute(attribute = "mime.type", description =
"application/json"),
- @WritesAttribute(attribute = "aggregation.name", description = "The name
of the aggregation whose results are in the output flowfile"),
- @WritesAttribute(attribute = "aggregation.number", description = "The
number of the aggregation whose results are in the output flowfile"),
- @WritesAttribute(attribute = "page.number", description = "The number of
the page (request), starting from 1, in which the results were returned that
are in the output flowfile"),
- @WritesAttribute(attribute = "hit.count", description = "The number of
hits that are in the output flowfile"),
+ @WritesAttribute(attribute = "aggregation.name", description = "The name
of the aggregation whose results are in the output FlowFile"),
+ @WritesAttribute(attribute = "aggregation.number", description = "The
number of the aggregation whose results are in the output FlowFile"),
+ @WritesAttribute(attribute = "page.number", description = "The number of
the page (request), starting from 1, in which the results were returned that
are in the output FlowFile"),
+ @WritesAttribute(attribute = "hit.count", description = "The number of
hits that are in the output FlowFile"),
@WritesAttribute(attribute = "elasticsearch.query.error", description =
"The error message provided by Elasticsearch if there is an error querying the
index.")
})
@InputRequirement(InputRequirement.Requirement.INPUT_REQUIRED)
@Tags({"elasticsearch", "elasticsearch7", "elasticsearch8", "elasticsearch9",
"query", "scroll", "page", "read", "json"})
@CapabilityDescription("A processor that allows the user to run a paginated
query (with aggregations) written with the Elasticsearch JSON DSL. " +
- "It will use the flowfile's content for the query unless the QUERY
attribute is populated. " +
+ "It will use the FlowFile's content for the query unless the QUERY
attribute is populated. " +
"Search After/Point in Time queries must include a valid \"sort\"
field.")
@SeeAlso({JsonQueryElasticsearch.class, ConsumeElasticsearch.class,
SearchElasticsearch.class})
@DynamicProperties({
diff --git
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/SearchElasticsearch.java
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/SearchElasticsearch.java
index a0dde76d04f..c33cb8b7ebc 100644
---
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/SearchElasticsearch.java
+++
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/SearchElasticsearch.java
@@ -56,10 +56,10 @@ import java.util.stream.Stream;
@WritesAttributes({
@WritesAttribute(attribute = "mime.type", description =
"application/json"),
- @WritesAttribute(attribute = "aggregation.name", description = "The
name of the aggregation whose results are in the output flowfile"),
- @WritesAttribute(attribute = "aggregation.number", description = "The
number of the aggregation whose results are in the output flowfile"),
- @WritesAttribute(attribute = "page.number", description = "The number
of the page (request), starting from 1, in which the results were returned that
are in the output flowfile"),
- @WritesAttribute(attribute = "hit.count", description = "The number of
hits that are in the output flowfile"),
+ @WritesAttribute(attribute = "aggregation.name", description = "The
name of the aggregation whose results are in the output FlowFile"),
+ @WritesAttribute(attribute = "aggregation.number", description = "The
number of the aggregation whose results are in the output FlowFile"),
+ @WritesAttribute(attribute = "page.number", description = "The number
of the page (request), starting from 1, in which the results were returned that
are in the output FlowFile"),
+ @WritesAttribute(attribute = "hit.count", description = "The number of
hits that are in the output FlowFile"),
@WritesAttribute(attribute = "elasticsearch.query.error", description
= "The error message provided by Elasticsearch if there is an error querying
the index.")
})
@InputRequirement(InputRequirement.Requirement.INPUT_FORBIDDEN)
diff --git
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/UpdateByQueryElasticsearch.java
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/UpdateByQueryElasticsearch.java
index 0142973fa93..7c84da0ce74 100644
---
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/UpdateByQueryElasticsearch.java
+++
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/UpdateByQueryElasticsearch.java
@@ -37,7 +37,7 @@ import org.apache.nifi.expression.ExpressionLanguageScope;
@InputRequirement(InputRequirement.Requirement.INPUT_ALLOWED)
@SupportsBatching
@Tags({ "elastic", "elasticsearch", "elasticsearch7", "elasticsearch8",
"elasticsearch9", "update", "query"})
-@CapabilityDescription("Update documents in an Elasticsearch index using a
query. The query can be loaded from a flowfile body " +
+@CapabilityDescription("Update documents in an Elasticsearch index using a
query. The query can be loaded from a FlowFile body " +
"or from the Query parameter. The loaded Query can contain any JSON
accepted by Elasticsearch's _update_by_query API, " +
"for example a \"query\" object to identify what documents are to be
updated, plus a \"script\" to define the updates to perform.")
@DynamicProperties({
diff --git
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/api/ResultOutputStrategy.java
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/api/ResultOutputStrategy.java
index 61341e11e06..94faedb1c3c 100644
---
a/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/api/ResultOutputStrategy.java
+++
b/nifi-extension-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-restapi-processors/src/main/java/org/apache/nifi/processors/elasticsearch/api/ResultOutputStrategy.java
@@ -22,9 +22,9 @@ import org.apache.nifi.components.DescribedValue;
import java.util.EnumSet;
public enum ResultOutputStrategy implements DescribedValue {
- PER_HIT("splitUp-yes", "Flowfile per hit."),
- PER_RESPONSE("splitUp-no", "Flowfile per response."),
- PER_QUERY("splitUp-query", "Combine results from all query responses (one
flowfile per entire paginated result set of hits). " +
+ PER_HIT("splitUp-yes", "FlowFile per hit."),
+ PER_RESPONSE("splitUp-no", "FlowFile per response."),
+ PER_QUERY("splitUp-query", "Combine results from all query responses (one
FlowFile per entire paginated result set of hits). " +
"Note that aggregations cannot be paged, they are generated across
the entire result set and " +
"returned as part of the first page. Results are output with one
JSON object per line " +
"(allowing hits to be combined from multiple pages without loading
all results into memory).");
diff --git
a/nifi-extension-bundles/nifi-email-bundle/nifi-email-processors/src/main/java/org/apache/nifi/processors/email/ExtractEmailHeaders.java
b/nifi-extension-bundles/nifi-email-bundle/nifi-email-processors/src/main/java/org/apache/nifi/processors/email/ExtractEmailHeaders.java
index f452f4347ee..2d882be041c 100644
---
a/nifi-extension-bundles/nifi-email-bundle/nifi-email-processors/src/main/java/org/apache/nifi/processors/email/ExtractEmailHeaders.java
+++
b/nifi-extension-bundles/nifi-email-bundle/nifi-email-processors/src/main/java/org/apache/nifi/processors/email/ExtractEmailHeaders.java
@@ -63,7 +63,7 @@ import java.util.concurrent.atomic.AtomicInteger;
@SideEffectFree
@Tags({"split", "email"})
@InputRequirement(Requirement.INPUT_REQUIRED)
-@CapabilityDescription("Using the flowfile content as source of data, extract
header from an RFC compliant email file adding the relevant attributes to the
flowfile. " +
+@CapabilityDescription("Using the FlowFile content as source of data, extract
header from an RFC compliant email file adding the relevant attributes to the
FlowFile. " +
"This processor does not perform extensive RFC validation but still
requires a bare minimum compliance with RFC 2822")
@WritesAttributes({
@WritesAttribute(attribute = "email.headers.bcc.*", description =
"Each individual BCC recipient (if available)"),
@@ -89,7 +89,7 @@ public class ExtractEmailHeaders extends AbstractProcessor {
public static final PropertyDescriptor CAPTURED_HEADERS = new
PropertyDescriptor.Builder()
.name("Additional Header List")
- .description("COLON separated list of additional headers to be
extracted from the flowfile content." +
+ .description("COLON separated list of additional headers to be
extracted from the FlowFile content." +
"NOTE the header key is case insensitive and will be
matched as lower-case." +
" Values will respect email contents.")
.required(false)
diff --git
a/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/main/java/org/apache/nifi/processors/GeoEnrichIPRecord.java
b/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/main/java/org/apache/nifi/processors/GeoEnrichIPRecord.java
index 0edf57eba26..77847e4730f 100644
---
a/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/main/java/org/apache/nifi/processors/GeoEnrichIPRecord.java
+++
b/nifi-extension-bundles/nifi-enrich-bundle/nifi-enrich-processors/src/main/java/org/apache/nifi/processors/GeoEnrichIPRecord.java
@@ -64,13 +64,13 @@ import java.util.concurrent.locks.Lock;
public class GeoEnrichIPRecord extends AbstractEnrichIP {
public static final PropertyDescriptor READER = new
PropertyDescriptor.Builder()
.name("Record Reader")
- .description("Record reader service to use for reading the
flowfile contents.")
+ .description("Record reader service to use for reading the
FlowFile contents.")
.required(true)
.identifiesControllerService(RecordReaderFactory.class)
.build();
public static final PropertyDescriptor WRITER = new
PropertyDescriptor.Builder()
.name("Record Writer")
- .description("Record writer service to use for enriching the
flowfile contents.")
+ .description("Record writer service to use for enriching the
FlowFile contents.")
.required(true)
.identifiesControllerService(RecordSetWriterFactory.class)
.build();
@@ -136,7 +136,7 @@ public class GeoEnrichIPRecord extends AbstractEnrichIP {
public static final Relationship REL_ORIGINAL = new Relationship.Builder()
.name("original")
- .description("The original input flowfile goes to this
relationship regardless of whether the content was enriched or not.")
+ .description("The original input FlowFile goes to this
relationship regardless of whether the content was enriched or not.")
.build();
public static final Set<Relationship> RELATIONSHIPS = Set.of(
diff --git
a/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/PublishGCPubSub.java
b/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/PublishGCPubSub.java
index 00f042aea0a..1de338c6682 100644
---
a/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/PublishGCPubSub.java
+++
b/nifi-extension-bundles/nifi-gcp-bundle/nifi-gcp-processors/src/main/java/org/apache/nifi/processors/gcp/pubsub/PublishGCPubSub.java
@@ -96,7 +96,7 @@ import static
org.apache.nifi.processors.gcp.pubsub.PubSubAttributes.TOPIC_NAME_
@SeeAlso({ConsumeGCPubSub.class})
@InputRequirement(Requirement.INPUT_REQUIRED)
@Tags({"google", "google-cloud", "gcp", "message", "pubsub", "publish"})
-@CapabilityDescription("Publishes the content of the incoming flowfile to the
configured Google Cloud PubSub topic. The processor supports dynamic
properties." +
+@CapabilityDescription("Publishes the content of the incoming FlowFile to the
configured Google Cloud PubSub topic. The processor supports dynamic
properties." +
" If any dynamic properties are present, they will be sent along with
the message in the form of 'attributes'.")
@DynamicProperty(name = "Attribute name", value = "Value to be set to the
attribute",
description = "Attributes to be set for the outgoing Google Cloud
PubSub message", expressionLanguageScope =
ExpressionLanguageScope.FLOWFILE_ATTRIBUTES)
diff --git
a/nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/src/main/java/org/apache/nifi/processors/graph/AbstractGraphExecutor.java
b/nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/src/main/java/org/apache/nifi/processors/graph/AbstractGraphExecutor.java
index 2241c230150..4cf5796a69d 100644
---
a/nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/src/main/java/org/apache/nifi/processors/graph/AbstractGraphExecutor.java
+++
b/nifi-extension-bundles/nifi-graph-bundle/nifi-graph-processors/src/main/java/org/apache/nifi/processors/graph/AbstractGraphExecutor.java
@@ -57,7 +57,7 @@ abstract class AbstractGraphExecutor extends
AbstractProcessor {
.description("Failed FlowFiles are routed to this
relationship").build();
static final Relationship REL_ORIGINAL = new
Relationship.Builder().name("original")
- .description("If there is an input flowfile, the original input
flowfile will be " +
+ .description("If there is an input FlowFile, the original input
FlowFile will be " +
"written to this relationship if the operation succeeds.")
.build();
diff --git
a/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/DeleteHDFS.java
b/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/DeleteHDFS.java
index 12dbe40871c..7b1580db440 100644
---
a/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/DeleteHDFS.java
+++
b/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/DeleteHDFS.java
@@ -55,7 +55,7 @@ import java.util.stream.Stream;
+ "will ignore running on a periodic basis and instead rely on
incoming FlowFiles to trigger a delete. "
+ "Note that you may use a wildcard character to match multiple files
or directories. If there are"
+ " no incoming connections no FlowFiles will be transfered to any
output relationships. If there is an incoming"
- + " flowfile then provided there are no detected failures it will be
transferred to success otherwise it will be sent to false. If"
+ + " FlowFile then provided there are no detected failures it will be
transferred to success otherwise it will be sent to false. If"
+ " knowledge of globbed files deleted is necessary use ListHDFS first
to produce a specific list of files to delete. ")
@WritesAttributes({
@@ -71,12 +71,12 @@ public class DeleteHDFS extends AbstractHadoopProcessor {
public static final Relationship REL_SUCCESS = new Relationship.Builder()
.name("success")
- .description("When an incoming flowfile is used then if there are
no errors invoking delete the flowfile will route here.")
+ .description("When an incoming FlowFile is used then if there are
no errors invoking delete the FlowFile will route here.")
.build();
public static final Relationship REL_FAILURE = new Relationship.Builder()
.name("failure")
- .description("When an incoming flowfile is used and there is a
failure while deleting then the flowfile will route here.")
+ .description("When an incoming FlowFile is used and there is a
failure while deleting then the FlowFile will route here.")
.build();
public static final PropertyDescriptor FILE_OR_DIRECTORY = new
PropertyDescriptor.Builder()
@@ -185,7 +185,7 @@ public class DeleteHDFS extends AbstractHadoopProcessor {
getLogger().warn("Failed to delete file or
directory", ioe);
Map<String, String> attributes = new
HashMap<>(1);
- // The error message is helpful in
understanding at a flowfile level what caused the IOException (which ACL is
denying the operation, e.g.)
+ // The error message is helpful in
understanding at a FlowFile level what caused the IOException (which ACL is
denying the operation, e.g.)
attributes.put(getAttributePrefix() +
".error.message", ioe.getMessage());
session.transfer(session.putAllAttributes(session.clone(flowFile), attributes),
getFailureRelationship());
diff --git
a/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/GetHDFSFileInfo.java
b/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/GetHDFSFileInfo.java
index c071e6e4fa9..86d975ea918 100644
---
a/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/GetHDFSFileInfo.java
+++
b/nifi-extension-bundles/nifi-hadoop-bundle/nifi-hdfs-processors/src/main/java/org/apache/nifi/processors/hadoop/GetHDFSFileInfo.java
@@ -158,14 +158,14 @@ public class GetHDFSFileInfo extends
AbstractHadoopProcessor {
.build();
static final AllowableValue GROUP_ALL = new
AllowableValue("gethdfsfileinfo-group-all", "All",
- "Group all results into a single flowfile.");
+ "Group all results into a single FlowFile.");
static final AllowableValue GROUP_PARENT_DIR = new
AllowableValue("gethdfsfileinfo-group-parent-dir", "Parent Directory",
- "Group HDFS objects by their parent directories only. Processor
will generate flowfile for each directory (if recursive). "
+ "Group HDFS objects by their parent directories only. Processor
will generate FlowFile for each directory (if recursive). "
+ "If 'Recurse Subdirectories' property set to 'false',
then will have the same effect as 'All'");
static final AllowableValue GROUP_NONE = new
AllowableValue("gethdfsfileinfo-group-none", "None",
- "Don't group results. Generate flowfile per each HDFS object.");
+ "Don't group results. Generate FlowFile per each HDFS object.");
public static final PropertyDescriptor GROUPING = new
PropertyDescriptor.Builder()
.name("Group Results")
@@ -178,14 +178,14 @@ public class GetHDFSFileInfo extends
AbstractHadoopProcessor {
public static final PropertyDescriptor BATCH_SIZE = new
PropertyDescriptor.Builder()
.name("Batch Size")
- .description("Number of records to put into an output flowfile
when 'Destination' is set to 'Content'"
+ .description("Number of records to put into an output FlowFile
when 'Destination' is set to 'Content'"
+ " and 'Group Results' is set to 'None'")
.required(false)
.addValidator(StandardValidators.POSITIVE_INTEGER_VALIDATOR)
.build();
static final AllowableValue DESTINATION_ATTRIBUTES = new
AllowableValue("gethdfsfileinfo-dest-attr", "Attributes",
- "Details of given HDFS object will be stored in attributes of
flowfile. "
+ "Details of given HDFS object will be stored in attributes of
FlowFile. "
+ "WARNING: In case when scan finds thousands or millions
of objects, having huge values in attribute could impact flow file repo and
GC/heap usage. "
+ "Use content destination for such cases.");
@@ -194,7 +194,7 @@ public class GetHDFSFileInfo extends
AbstractHadoopProcessor {
public static final PropertyDescriptor DESTINATION = new
PropertyDescriptor.Builder()
.name("Destination")
- .description("Sets the destination for the resutls. When set to
'Content', attributes of flowfile won't be used for storing results. ")
+ .description("Sets the destination for the resutls. When set to
'Content', attributes of FlowFile won't be used for storing results. ")
.required(true)
.addValidator(StandardValidators.NON_EMPTY_VALIDATOR)
.allowableValues(DESTINATION_ATTRIBUTES, DESTINATION_CONTENT)
@@ -452,7 +452,7 @@ public class GetHDFSFileInfo extends
AbstractHadoopProcessor {
/*
* Checks whether HDFS object should be sent to output.
- * If it should be sent, new flowfile will be created, its content and
attributes will be populated according to other request params.
+ * If it should be sent, new FlowFile will be created, its content and
attributes will be populated according to other request params.
*/
protected void processHDFSObject(
final ProcessSession session,
diff --git
a/nifi-extension-bundles/nifi-media-bundle/nifi-media-processors/src/main/java/org/apache/nifi/processors/image/ExtractImageMetadata.java
b/nifi-extension-bundles/nifi-media-bundle/nifi-media-processors/src/main/java/org/apache/nifi/processors/image/ExtractImageMetadata.java
index def7c6da155..548653f9fff 100644
---
a/nifi-extension-bundles/nifi-media-bundle/nifi-media-processors/src/main/java/org/apache/nifi/processors/image/ExtractImageMetadata.java
+++
b/nifi-extension-bundles/nifi-media-bundle/nifi-media-processors/src/main/java/org/apache/nifi/processors/image/ExtractImageMetadata.java
@@ -58,7 +58,7 @@ public class ExtractImageMetadata extends AbstractProcessor {
public static final PropertyDescriptor MAX_NUMBER_OF_ATTRIBUTES = new
PropertyDescriptor.Builder()
.name("Max Number of Attributes")
- .description("Specify the max number of attributes to add to the
flowfile. There is no guarantee in what order"
+ .description("Specify the max number of attributes to add to the
FlowFile. There is no guarantee in what order"
+ " the tags will be processed. By default it will process all
of them.")
.required(false)
.addValidator(StandardValidators.NON_NEGATIVE_INTEGER_VALIDATOR)
diff --git
a/nifi-extension-bundles/nifi-media-bundle/nifi-media-processors/src/main/java/org/apache/nifi/processors/media/ExtractMediaMetadata.java
b/nifi-extension-bundles/nifi-media-bundle/nifi-media-processors/src/main/java/org/apache/nifi/processors/media/ExtractMediaMetadata.java
index a221ab8c3b2..afa2cc5fbd4 100644
---
a/nifi-extension-bundles/nifi-media-bundle/nifi-media-processors/src/main/java/org/apache/nifi/processors/media/ExtractMediaMetadata.java
+++
b/nifi-extension-bundles/nifi-media-bundle/nifi-media-processors/src/main/java/org/apache/nifi/processors/media/ExtractMediaMetadata.java
@@ -69,7 +69,7 @@ public class ExtractMediaMetadata extends AbstractProcessor {
static final PropertyDescriptor MAX_NUMBER_OF_ATTRIBUTES = new
PropertyDescriptor.Builder()
.name("Max Number of Attributes")
- .description("Specify the max number of attributes to add to the
flowfile. There is no guarantee in what order"
+ .description("Specify the max number of attributes to add to the
FlowFile. There is no guarantee in what order"
+ " the tags will be processed. By default it will process
all of them.")
.required(false)
.defaultValue("100")
@@ -90,15 +90,15 @@ public class ExtractMediaMetadata extends AbstractProcessor
{
static final PropertyDescriptor METADATA_KEY_FILTER = new
PropertyDescriptor.Builder()
.name("Metadata Key Filter")
.description("A regular expression identifying which metadata keys
received from the parser should be"
- + " added to the flowfile attributes. If left blank, all
metadata keys parsed will be added to the"
- + " flowfile attributes.")
+ + " added to the FlowFile attributes. If left blank, all
metadata keys parsed will be added to the"
+ + " FlowFile attributes.")
.required(false)
.addValidator(StandardValidators.REGULAR_EXPRESSION_VALIDATOR)
.build();
static final PropertyDescriptor METADATA_KEY_PREFIX = new
PropertyDescriptor.Builder()
.name("Metadata Key Prefix")
- .description("Text to be prefixed to metadata keys as the are
added to the flowfile attributes. It is"
+ .description("Text to be prefixed to metadata keys as the are
added to the FlowFile attributes. It is"
+ " recommended to end with with a separator character
like '.' or '-', this is not automatically "
+ " added by the processor.")
.required(false)
diff --git
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/AbstractMongoProcessor.java
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/AbstractMongoProcessor.java
index 5d6b9eb1381..7f7f2a3d810 100644
---
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/AbstractMongoProcessor.java
+++
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/AbstractMongoProcessor.java
@@ -98,7 +98,7 @@ public abstract class AbstractMongoProcessor extends
AbstractProcessor {
static final PropertyDescriptor RESULTS_PER_FLOWFILE = new
PropertyDescriptor.Builder()
.name("Results Per FlowFile")
- .description("How many results to put into a flowfile at once. The
whole body will be treated as a JSON array of results.")
+ .description("How many results to put into a FlowFile at once. The
whole body will be treated as a JSON array of results.")
.required(false)
.addValidator(StandardValidators.POSITIVE_INTEGER_VALIDATOR)
.defaultValue("1")
diff --git
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/DeleteMongo.java
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/DeleteMongo.java
index 1b0eb62e8dd..d2481b59707 100644
---
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/DeleteMongo.java
+++
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/DeleteMongo.java
@@ -47,12 +47,12 @@ import java.util.stream.Stream;
@InputRequirement(InputRequirement.Requirement.INPUT_REQUIRED)
@Tags({ "delete", "mongo", "mongodb" })
@CapabilityDescription(
- "Executes a delete query against a MongoDB collection. The query is
provided in the body of the flowfile " +
+ "Executes a delete query against a MongoDB collection. The query is
provided in the body of the FlowFile " +
"and the user can select whether it will delete one or many documents that
match it."
)
@ReadsAttribute(
attribute = "mongodb.delete.mode",
- description = "Configurable parameter for controlling delete mode on a
per-flowfile basis. The process must be " +
+ description = "Configurable parameter for controlling delete mode on a per
FlowFile basis. The process must be " +
"configured to use this option. Acceptable values are 'one' and
'many.'"
)
public class DeleteMongo extends AbstractMongoProcessor {
@@ -75,7 +75,7 @@ public class DeleteMongo extends AbstractMongoProcessor {
static final PropertyDescriptor FAIL_ON_NO_DELETE = new
PropertyDescriptor.Builder()
.name("Fail When Nothing Is Deleted")
- .description("Determines whether to send the flowfile to the
success or failure relationship if nothing is successfully deleted.")
+ .description("Determines whether to send the FlowFile to the
success or failure relationship if nothing is successfully deleted.")
.allowableValues(YES_FAIL, NO_FAIL)
.defaultValue("true")
.addValidator(Validator.VALID)
diff --git
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/PutMongo.java
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/PutMongo.java
index fb0e958ac1c..bf27510816d 100644
---
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/PutMongo.java
+++
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/PutMongo.java
@@ -127,7 +127,7 @@ public class PutMongo extends AbstractMongoProcessor {
.defaultValue(UPDATE_WITH_DOC)
.description("Choose an update mode. You can either supply a JSON
document to use as a direct replacement " +
"or specify a document that contains update operators like
$set, $unset, and $inc. " +
- "When Operators mode is enabled, the flowfile content is
expected to be the operator part " +
+ "When Operators mode is enabled, the FlowFile content is
expected to be the operator part " +
"for example: {$set:{\"key\":
\"value\"},$inc:{\"count\":1234}} and the update query will come " +
"from the configured Update Query property.")
.build();
diff --git
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/PutMongoRecord.java
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/PutMongoRecord.java
index 3df82b25370..0a4dae9c387 100644
---
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/PutMongoRecord.java
+++
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/PutMongoRecord.java
@@ -68,7 +68,7 @@ import java.util.stream.Stream;
"that MongoDB is not overloaded with too many operations at once.")
@ReadsAttribute(
attribute = AbstractMongoProcessor.ATTRIBUTE_MONGODB_UPDATE_MODE,
- description = "Configurable parameter for controlling update mode on a
per-flowfile basis." +
+ description = "Configurable parameter for controlling update mode on a per
FlowFile basis." +
" Acceptable values are 'one' and 'many' and controls whether a single
incoming record should update a single or multiple Mongo documents."
)
public class PutMongoRecord extends AbstractMongoProcessor {
diff --git
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/RunMongoAggregation.java
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/RunMongoAggregation.java
index 52654ce1d87..091a85b5a2b 100644
---
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/RunMongoAggregation.java
+++
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/RunMongoAggregation.java
@@ -49,16 +49,16 @@ import java.util.Set;
import java.util.stream.Stream;
@Tags({"mongo", "aggregation", "aggregate"})
-@CapabilityDescription("A processor that runs an aggregation query whenever a
flowfile is received.")
+@CapabilityDescription("A processor that runs an aggregation query whenever a
FlowFile is received.")
@InputRequirement(InputRequirement.Requirement.INPUT_ALLOWED)
public class RunMongoAggregation extends AbstractMongoProcessor {
static final Relationship REL_ORIGINAL = new Relationship.Builder()
- .description("The input flowfile gets sent to this relationship
when the query succeeds.")
+ .description("The input FlowFile gets sent to this relationship
when the query succeeds.")
.name("original")
.build();
static final Relationship REL_FAILURE = new Relationship.Builder()
- .description("The input flowfile gets sent to this relationship
when the query fails.")
+ .description("The input FlowFile gets sent to this relationship
when the query fails.")
.name("failure")
.build();
static final Relationship REL_RESULTS = new Relationship.Builder()
diff --git
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/gridfs/AbstractGridFSProcessor.java
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/gridfs/AbstractGridFSProcessor.java
index 0372b3613a2..d8868d60770 100644
---
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/gridfs/AbstractGridFSProcessor.java
+++
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/gridfs/AbstractGridFSProcessor.java
@@ -81,12 +81,12 @@ public abstract class AbstractGridFSProcessor extends
AbstractProcessor {
static final Relationship REL_FAILURE = new Relationship.Builder()
.name("failure")
- .description("When there is a failure processing the flowfile, it goes
to this relationship.")
+ .description("When there is a failure processing the FlowFile, it goes
to this relationship.")
.build();
static final Relationship REL_SUCCESS = new Relationship.Builder()
.name("success")
- .description("When the operation succeeds, the flowfile is sent to
this relationship.")
+ .description("When the operation succeeds, the FlowFile is sent to
this relationship.")
.build();
private static final List<PropertyDescriptor> PROPERTY_DESCRIPTORS =
List.of(
diff --git
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/gridfs/FetchGridFS.java
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/gridfs/FetchGridFS.java
index a40f479667f..6c91f8375da 100644
---
a/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/gridfs/FetchGridFS.java
+++
b/nifi-extension-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/gridfs/FetchGridFS.java
@@ -71,7 +71,7 @@ public class FetchGridFS extends AbstractGridFSProcessor
implements QueryHelper
static final Relationship REL_ORIGINAL = new Relationship.Builder()
.name("original")
- .description("The original input flowfile goes to this relationship if
the query does not cause an error")
+ .description("The original input FlowFile goes to this relationship if
the query does not cause an error")
.build();
private static final List<PropertyDescriptor> PROPERTY_DESCRIPTORS =
Stream.concat(
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AttributesToCSV.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AttributesToCSV.java
index 47d843cbb87..272ada254a0 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AttributesToCSV.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AttributesToCSV.java
@@ -70,10 +70,10 @@ public class AttributesToCSV extends AbstractProcessor {
private static final String OUTPUT_MIME_TYPE = "text/csv";
private static final String SPLIT_REGEX = OUTPUT_SEPARATOR +
"(?=(?:[^\"]*\"[^\"]*\")*[^\"]*$)";
- static final AllowableValue OUTPUT_OVERWRITE_CONTENT = new
AllowableValue("flowfile-content", "flowfile-content", "The resulting CSV
string will be placed into the content of the flowfile." +
- "Existing flowfile context will be overwritten. 'CSVData' will not
be written to at all (neither null nor empty string).");
- static final AllowableValue OUTPUT_NEW_ATTRIBUTE = new
AllowableValue("flowfile-attribute", "flowfile-attribute", "The resulting CSV
string will be placed into a new flowfile" +
- " attribute named 'CSVData'. The content of the flowfile will not
be changed.");
+ static final AllowableValue OUTPUT_OVERWRITE_CONTENT = new
AllowableValue("flowfile-content", "flowfile-content", "The resulting CSV
string will be placed into the content of the FlowFile." +
+ "Existing FlowFile context will be overwritten. 'CSVData' will not
be written to at all (neither null nor empty string).");
+ static final AllowableValue OUTPUT_NEW_ATTRIBUTE = new
AllowableValue("flowfile-attribute", "flowfile-attribute", "The resulting CSV
string will be placed into a new FlowFile" +
+ " attribute named 'CSVData'. The content of the FlowFile will not
be changed.");
public static final PropertyDescriptor ATTRIBUTES_LIST = new
PropertyDescriptor.Builder()
.name("Attribute List")
@@ -102,8 +102,8 @@ public class AttributesToCSV extends AbstractProcessor {
public static final PropertyDescriptor DESTINATION = new
PropertyDescriptor.Builder()
.name("Destination")
- .description("Control if CSV value is written as a new flowfile
attribute 'CSVData' " +
- "or written in the flowfile content.")
+ .description("Control if CSV value is written as a new FlowFile
attribute 'CSVData' " +
+ "or written in the FlowFile content.")
.required(true)
.allowableValues(OUTPUT_NEW_ATTRIBUTE, OUTPUT_OVERWRITE_CONTENT)
.defaultValue(OUTPUT_NEW_ATTRIBUTE.getDisplayName())
@@ -206,14 +206,14 @@ public class AttributesToCSV extends AbstractProcessor {
}
}
} else {
- //the user did not give a list of attributes, take all the
attributes from the flowfile
+ //the user did not give a list of attributes, take all the
attributes from the FlowFile
result.putAll(ffAttributes);
}
//now glue on the core attributes if the user wants them.
if (includeCoreAttributes) {
for (String coreAttribute : coreAttributes) {
- //make sure this coreAttribute is applicable to this flowfile.
+ //make sure this coreAttribute is applicable to this FlowFile.
String val = ff.getAttribute(coreAttribute);
if (ffAttributes.containsKey(coreAttribute)) {
if (!StringUtils.isEmpty(val)) {
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AttributesToJSON.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AttributesToJSON.java
index bfb365e0ba6..1a006cc03e6 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AttributesToJSON.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/AttributesToJSON.java
@@ -119,9 +119,9 @@ public class AttributesToJSON extends AbstractProcessor {
public static final PropertyDescriptor DESTINATION = new
PropertyDescriptor.Builder()
.name("Destination")
- .description("Control if JSON value is written as a new flowfile
attribute '" + JSON_ATTRIBUTE_NAME + "' " +
- "or written in the flowfile content. Writing to flowfile
content will overwrite any " +
- "existing flowfile content.")
+ .description("Control if JSON value is written as a new FlowFile
attribute '" + JSON_ATTRIBUTE_NAME + "' " +
+ "or written in the FlowFile content. Writing to FlowFile
content will overwrite any " +
+ "existing FlowFile content.")
.required(true)
.allowableValues(DESTINATION_ATTRIBUTE, DESTINATION_CONTENT)
.defaultValue(DESTINATION_ATTRIBUTE)
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CryptographicHashContent.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CryptographicHashContent.java
index c138a9aa999..47a2b66f125 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CryptographicHashContent.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/CryptographicHashContent.java
@@ -44,9 +44,9 @@ import java.util.concurrent.atomic.AtomicReference;
@SupportsBatching
@Tags({"content", "hash", "sha", "blake2", "md5", "cryptography"})
@InputRequirement(InputRequirement.Requirement.INPUT_REQUIRED)
-@CapabilityDescription("Calculates a cryptographic hash value for the flowfile
content using the given algorithm and writes it to an output attribute. Please
refer to
https://csrc.nist.gov/Projects/Hash-Functions/NIST-Policy-on-Hash-Functions for
help to decide which algorithm to use.")
+@CapabilityDescription("Calculates a cryptographic hash value for the FlowFile
content using the given algorithm and writes it to an output attribute. Please
refer to
https://csrc.nist.gov/Projects/Hash-Functions/NIST-Policy-on-Hash-Functions for
help to decide which algorithm to use.")
@WritesAttribute(attribute = "content_<algorithm>", description = "This
processor adds an attribute whose value is the result of "
- + "hashing the flowfile content. The name of this attribute is
specified by the value of the algorithm, e.g. 'content_SHA-256'.")
+ + "hashing the FlowFile content. The name of this attribute is
specified by the value of the algorithm, e.g. 'content_SHA-256'.")
public class CryptographicHashContent extends AbstractProcessor {
static final PropertyDescriptor FAIL_WHEN_EMPTY = new
PropertyDescriptor.Builder()
@@ -128,7 +128,7 @@ public class CryptographicHashContent extends
AbstractProcessor {
final AtomicReference<String> hashValueHolder = new
AtomicReference<>(null);
try {
- // Read the flowfile content via a lambda InputStreamCallback and
hash the content
+ // Read the FlowFile content via a lambda InputStreamCallback and
hash the content
session.read(flowFile, in ->
hashValueHolder.set(HashService.hashValueStreaming(algorithm, in)));
// Determine the destination attribute name
diff --git
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExtractGrok.java
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExtractGrok.java
index af048c1147c..1d5d9029d08 100644
---
a/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExtractGrok.java
+++
b/nifi-extension-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExtractGrok.java
@@ -71,7 +71,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
"adding the results as attributes or replacing the content of the FlowFile
with a JSON " +
"notation of the matched content")
@WritesAttributes({
- @WritesAttribute(attribute = "grok.XXX", description = "When operating in
flowfile-attribute mode, each of the Grok identifier that is matched in the
flowfile " +
+ @WritesAttribute(attribute = "grok.XXX", description = "When operating in
flowfile-attribute mode, each of the Grok identifier that is matched in the
FlowFile " +
"will be added as an attribute, prefixed with \"grok.\" For example," +
"if the grok identifier \"timestamp\" is matched, then the value will
be added to an attribute named \"grok.timestamp\"")})
@@ -109,10 +109,10 @@ public class ExtractGrok extends AbstractProcessor {
public static final PropertyDescriptor DESTINATION = new
PropertyDescriptor.Builder()
.name("Destination")
- .description("Control if Grok output value is written as a new
flowfile attributes, in this case " +
- "each of the Grok identifier that is matched in the flowfile will
be added as an attribute, " +
- "prefixed with \"grok.\" or written in the flowfile content.
Writing to flowfile content " +
- "will overwrite any existing flowfile content.")
+ .description("Control if Grok output value is written as a new
FlowFile attributes, in this case " +
+ "each of the Grok identifier that is matched in the FlowFile will
be added as an attribute, " +
+ "prefixed with \"grok.\" or written in the FlowFile content.
Writing to FlowFile content " +
+ "will overwrite any existing FlowFile content.")
.required(true)
.allowableValues(FLOWFILE_ATTRIBUTE, FLOWFILE_CONTENT)
.defaultValue(FLOWFILE_ATTRIBUTE)
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/FlowFileQueueResource.java
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/FlowFileQueueResource.java
index 399f6f06445..3175a306a2f 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/FlowFileQueueResource.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/FlowFileQueueResource.java
@@ -66,7 +66,7 @@ import org.springframework.stereotype.Controller;
import java.net.URI;
/**
- * RESTful endpoint for managing a flowfile queue.
+ * RESTful endpoint for managing a FlowFile queue.
*/
@Controller
@Path("/flowfile-queues")
@@ -77,17 +77,17 @@ public class FlowFileQueueResource extends
ApplicationResource {
private Authorizer authorizer;
/**
- * Populate the URIs for the specified flowfile listing.
+ * Populate the URIs for the specified FlowFile listing.
*
* @param connectionId connection
- * @param flowFileListing flowfile listing
+ * @param flowFileListing FlowFile listing
* @return dto
*/
public ListingRequestDTO populateRemainingFlowFileListingContent(final
String connectionId, final ListingRequestDTO flowFileListing) {
// uri of the listing
flowFileListing.setUri(generateResourceUri("flowfile-queues",
connectionId, "listing-requests", flowFileListing.getId()));
- // uri of each flowfile
+ // uri of each FlowFile
if (flowFileListing.getFlowFileSummaries() != null) {
for (final FlowFileSummaryDTO flowFile :
flowFileListing.getFlowFileSummaries()) {
populateRemainingFlowFileContent(connectionId, flowFile);
@@ -97,10 +97,10 @@ public class FlowFileQueueResource extends
ApplicationResource {
}
/**
- * Populate the URIs for the specified flowfile.
+ * Populate the URIs for the specified FlowFile.
*
* @param connectionId the connection id
- * @param flowFile the flowfile
+ * @param flowFile the FlowFile
* @return the dto
*/
public FlowFileSummaryDTO populateRemainingFlowFileContent(final String
connectionId, final FlowFileSummaryDTO flowFile) {
@@ -109,11 +109,11 @@ public class FlowFileQueueResource extends
ApplicationResource {
}
/**
- * Gets the specified flowfile from the specified connection.
+ * Gets the specified FlowFile from the specified connection.
*
* @param connectionId The connection id
- * @param flowFileUuid The flowfile uuid
- * @param clusterNodeId The cluster node id where the flowfile resides
+ * @param flowFileUuid The FlowFile uuid
+ * @param clusterNodeId The cluster node id where the FlowFile resides
* @return a flowFileDTO
* @throws InterruptedException if interrupted
*/
@@ -142,7 +142,7 @@ public class FlowFileQueueResource extends
ApplicationResource {
)
@PathParam("id") final String connectionId,
@Parameter(
- description = "The flowfile uuid.",
+ description = "The FlowFile uuid.",
required = true
)
@PathParam("flowfile-uuid") final String flowFileUuid,
@@ -167,9 +167,9 @@ public class FlowFileQueueResource extends
ApplicationResource {
}
}
- // NOTE - deferred authorization so we can consider flowfile
attributes in the access decision
+ // NOTE - deferred authorization so we can consider FlowFile
attributes in the access decision
- // get the flowfile
+ // get the FlowFile
final FlowFileDTO flowfileDto =
serviceFacade.getFlowFile(connectionId, flowFileUuid);
populateRemainingFlowFileContent(connectionId, flowfileDto);
@@ -181,11 +181,11 @@ public class FlowFileQueueResource extends
ApplicationResource {
}
/**
- * Gets the content for the specified flowfile in the specified connection.
+ * Gets the content for the specified FlowFile in the specified connection.
*
* @param clientId Optional client id. If the client id is not specified,
a new one will be generated. This value (whether specified or generated) is
included in the response.
* @param connectionId The connection id
- * @param flowFileUuid The flowfile uuid
+ * @param flowFileUuid The FlowFile uuid
* @param clusterNodeId The cluster node id
* @return The content stream
*/
@@ -224,7 +224,7 @@ public class FlowFileQueueResource extends
ApplicationResource {
)
@PathParam("id") final String connectionId,
@Parameter(
- description = "The flowfile uuid.",
+ description = "The FlowFile uuid.",
required = true
)
@PathParam("flowfile-uuid") final String flowFileUuid,
@@ -249,7 +249,7 @@ public class FlowFileQueueResource extends
ApplicationResource {
}
}
- // NOTE - deferred authorization so we can consider flowfile
attributes in the access decision
+ // NOTE - deferred authorization so we can consider FlowFile
attributes in the access decision
// get the uri of the request
final String uri = generateResourceUri("flowfile-queues",
connectionId, "flowfiles", flowFileUuid, "content");
diff --git
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/ProvenanceResource.java
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/ProvenanceResource.java
index 5434459732a..c00ae703deb 100644
---
a/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/ProvenanceResource.java
+++
b/nifi-framework-bundle/nifi-framework/nifi-web/nifi-web-api/src/main/java/org/apache/nifi/web/api/ProvenanceResource.java
@@ -371,12 +371,12 @@ public class ProvenanceResource extends
ApplicationResource {
}
/**
- * Submits a lineage request based on an event or a flowfile uuid.
+ * Submits a lineage request based on an event or a FlowFile uuid.
* <p>
* When querying for the lineage of an event you must specify the eventId
and the eventDirection. The eventDirection must be 'parents' or 'children' and
specifies whether we are going up or down
- * the flowfile ancestry. The uuid cannot be specified in these cases.
+ * the FlowFile ancestry. The uuid cannot be specified in these cases.
* <p>
- * When querying for the lineage of a flowfile you must specify the uuid.
The eventId and eventDirection cannot be specified in this case.
+ * When querying for the lineage of a FlowFile you must specify the uuid.
The eventId and eventDirection cannot be specified in this case.
*
* @param requestLineageEntity A lineageEntity
* @return A lineageEntity
@@ -477,7 +477,7 @@ public class ProvenanceResource extends ApplicationResource
{
/**
* Gets the lineage with the specified id.
*
- * @param clusterNodeId The id of node in the cluster that the
event/flowfile originated from. This is only required when clustered.
+ * @param clusterNodeId The id of node in the cluster that the
event/FlowFile originated from. This is only required when clustered.
* @param id The id of the lineage
* @return A lineageEntity
*/
@@ -533,7 +533,7 @@ public class ProvenanceResource extends ApplicationResource
{
/**
* Deletes the lineage with the specified id.
*
- * @param clusterNodeId The id of node in the cluster that the
event/flowfile originated from. This is only required when clustered.
+ * @param clusterNodeId The id of node in the cluster that the
event/FlowFile originated from. This is only required when clustered.
* @param id The id of the lineage
* @return A lineageEntity
*/
