Difference between revisions of "MapReduce"
From NoSQLZoo
| Line 42: | Line 42: | ||
if (this.population>100000000) | if (this.population>100000000) | ||
emit(this.continent, 1);}, | emit(this.continent, 1);}, | ||
| − | function(k, v){ return v.length; } | + | function(k, v){ return v.length; }, |
{out:{"inline":1}} | {out:{"inline":1}} | ||
) | ) | ||
</pre> | </pre> | ||
Revision as of 19:54, 2 August 2016
Introducing the MapReduce function
The MapReduce function is an aggregate function that consists of two functions: Map and Reduce.
The map is always performed before the reduce.
The map function examines every document in the collection and emits (key,value) pairs.
The map function takes no input however the current document can be accessed as this
The reduce function has two inputs, for every distinct key emitted by map the reduce function is called with a list of the corresponding values.
emit all continents
This example returns the number of countries in each continent.
db.world.mapReduce(
function(){emit(this.continent, 1);},
function(k, v){ return v.length; },
{out:{inline:1}}
)
db.world.mapReduce(
function(){emit(this.continent, 1);},
function(k, v){ return v.length; },
{out:{inline:1}}
)
emit only some continents
The map function may emit only sometimes.
In the example we are only counting the countries that have a large population
db.world.mapReduce(
function(){
if (this.population>100000000)
emit(this.continent, 1);},
function(k, v){ return v.length; },
{out:{"inline":1}}
)