Github user MikeThomsen commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2448#discussion_r190665372
--- Diff:
nifi-nar-bundles/nifi-mongodb-bundle/nifi-mongodb-processors/src/main/java/org/apache/nifi/processors/mongodb/GetMongo.java
---
@@ -51,14 +53,22 @@
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Collections;
+import java.util.HashMap;
import java.util.HashSet;
import java.util.List;
+import java.util.Map;
import java.util.Set;
@Tags({ "mongodb", "read", "get" })
@InputRequirement(Requirement.INPUT_FORBIDDEN)
@CapabilityDescription("Creates FlowFiles from documents in MongoDB")
+@WritesAttributes( value = {
+ @WritesAttribute(attribute = "progress.estimate", description = "The
estimated total documents that match the query. Written if estimation is
enabled."),
+ @WritesAttribute(attribute = "progress.segment.start", description =
"Where the first part of the segment is in the total result set. Written if
estimation is enabled."),
+ @WritesAttribute(attribute = "progress.segment.end", description =
"Where the last part of the segment is in the total result set. Written if
estimation is enabled."),
+ @WritesAttribute(attribute = "progress.index", description = "When
results are written one-by-one to flowfiles, this is is set to indicate
estimated progress. Written if estimation is enabled.")
--- End diff --
Done.
---
