Hadoop'ta Kayıt Başlangıcı Çalışması

Question

RecordReader'ın aslında nasıl çalıştığını açıklayan herhangi biri var mı? Program başlatıldıktan sonra nextkeyvalue(), getCurrentkey() ve getprogress() yöntemleri nasıl çalışır?

Answer 1

(yeni API):

public void run(Context context) throws IOException, InterruptedException { 
    setup(context); 
    while (context.nextKeyValue()) { 
     map(context.getCurrentKey(), context.getCurrentValue(), context); 
    } 
    cleanup(context); 
} 

Context.nextKeyValue(), Context.getCurrentKey() ve Context.getCurrentValue() yöntemleri RecordReader yöntemleri için sargı olan: Varsayılan Mapper sınıfı şöyle bir çalışma metodu vardır. Kaynak dosyaya bakın src/mapred/org/apache/hadoop/mapreduce/MapContext.java.

Bu döngü, Mapper uygulamanızın map(K, V, Context) yöntemini yürütür ve çağırır.

Özellikle, başka ne bilmek istersiniz?

Answer 2

org.apache.hadoop.mapred.MapTask - runNewMapper()

İth adımlar:

1. yeni mapper mapper

2. için

3. olsun giriş bölünmüş yaratır

   bölme için kayıt aleti getir

4. çok yararlı Chris..Thts @