RunMongoAggregation 2.0.0

Bundle
org.apache.nifi | nifi-mongodb-nar
Description
A processor that runs an aggregation query whenever a flowfile is received.
Tags
aggregate, aggregation, mongo
Input Requirement
ALLOWED
Supports Sensitive Dynamic Properties
false
  • Additional Details for RunMongoAggregation 2.0.0

    RunMongoAggregation

    Description:

    This processor runs a MongoDB aggregation query based on user-defined settings. The following is an example of such a query (and what the expected input looks like):

    [
      {
        "$project": {
          "domain": 1
        },
        "$group": {
          "_id": {
            "domain": "$domain"
          },
          "total": {
            "$sum": 1
          }
        }
      }
    ]
    
Properties
Relationships
Name Description
results The result set of the aggregation will be sent to this relationship.
failure The input flowfile gets sent to this relationship when the query fails.
original The input flowfile gets sent to this relationship when the query succeeds.