MapReduceAggregate.bwp

This process demonstrates how to use the plug-in to perform map-reduce operations in a specified collection.

The process is designed with the following activities:



The following table describes the activities in the process:

Activity Description
Timer Starts the process
CleanResultDocuments Invokes the CleanDocument subprocess to delete all result documents from the specified collection
CleanSampleDocuments Invokes the CleanDocument subprocess to delete all sample documents from the specified collection
InsertDocuments Invokes the InsertDocument subprocess to insert a group of documents in the specified collection
MapReduce Performs a map-reduce operation on the specified collection and writes the result to another collection
GetMongoDBConnection Obtains a MongoDB Connection reference
GetResult Uses the obtained Connection reference to get information related to the collection where the result of the map-reduce operation is located
DataBaseCommand Performs database commands in the collection where the result of the map-reduce operation is located