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 into the specified collection.
MapReduce Performs a map-reduce operation on the specified collection and writes the result into another collection.
GetMongoDBConnection Obtains a MongoDB Connection reference.
GetResult Utilizes 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.