2011-02-25 3 views
1

J'ai vu le lien ci-dessous qui est d'obtenir commencé MapReduce avec pythonAyant des difficultés à comprendre MapReduce

http://code.google.com/p/appengine-mapreduce/wiki/GettingStartedInPython

Mais je ne suis pas en mesure de comprendre comment son fonctionnement. J'exécute le code ci-dessous, mais je ne suis pas capable de comprendre ce qui se passe exactement?

mapreduce.yaml

mapreduce: 
- name: Testmapper 
    mapper: 
     input_reader: mapreduce.input_readers.DatastoreInputReader 
     handler: main.process 
    params: 
     - name: entity_kind 
     default: main.userDetail 

MapReduce/main.py

some code 

class userDetail(db.Model): 
name = db.StringProperty() 

some code 

def process(u): 
      u.name="mahesh" 
      yield op.db.Put(u) 

Je passe la présente et il me donne l'état = succès dans la page d'état.

Mais pas en mesure de comprendre ce happend

La principale chose que je veux faire avec MapReduce est de rechercher ou de compter les enregistrements de l'entité

tout le monde peut me aider ?? s'il vous plaît

Merci à l'avance

+0

Vous pouvez formater le code par 4 espaces indenter. Pas besoin d'insérer un groupe de ' '. – kennytm

Répondre

1

Vous définissez la valeur "mahesh" à la StringProperty name de toutes vos userDetail entités.

Si vous voulez compter vos entités utilisent:

from mapreduce import operation as op 
def process(entity): 
    yield op.counters.Increment("counter1") 
+0

le code que vous avez donné fonctionne bien pour les compteurs mais ma question était où cet enregistrement est stocké? – mahesh

+0

http://stackoverflow.com/questions/3465669/how-do-i-get-the-values-from-the-counter-after-i-processus-all-the-records-with-g – systempuntoout

Questions connexes