또한이 Mapreduce 코드를 수정하여 엔터티의 네임 스페이스를 변경하려면 어떻게해야합니까?

Question

내가 Ikai 란 만든이 매퍼를 사용하고 있습니다 :

package com.ikai.mapperdemo.mappers; 

import java.util.Date; 
import java.util.logging.Logger; 

import org.apache.hadoop.io.NullWritable; 

import com.google.appengine.api.datastore.Entity; 
import com.google.appengine.api.datastore.Key; 
import com.google.appengine.tools.mapreduce.AppEngineMapper; 
import com.google.appengine.tools.mapreduce.DatastoreMutationPool; 

/** 
* 
* The functionality of this is exactly the same as in {@link NaiveToLowercaseMapper}. 
* The advantage here is that since a {@link DatastoreMutationPool} is used, mutations 
* can be done in batch, saving API calls. 
* 
* @author Ikai Lan 
* 
*/ 
public class PooledToLowercaseMapper extends 
     AppEngineMapper<Key, Entity, NullWritable, NullWritable> { 
    private static final Logger log = Logger 
      .getLogger(PooledToLowercaseMapper.class.getName()); 

    @Override 
    public void map(Key key, Entity value, Context context) { 
     log.info("Mapping key: " + key); 

     if (value.hasProperty("comment")) { 
      String comment = (String) value.getProperty("comment"); 
      comment = comment.toLowerCase(); 
      value.setProperty("comment", comment); 
      value.setProperty("updatedAt", new Date()); 

      DatastoreMutationPool mutationPool = this.getAppEngineContext(
        context).getMutationPool(); 
      mutationPool.put(value); 
     } 
    } 
} 

내가 또한 수정되는 엔티티의 데이터 저장소 네임 스페이스를 변경하는 위에 추가하고 싶은.

어떻게 가능합니까?

Answer 1

네임 스페이스는 Entity의 변경 불가능한 키의 구성 요소입니다. 그것을 바꾸는 개념은 없습니다. 엔티티를 다른 네임 스페이스로 '이동'하려는 경우 해당 네임 스페이스에 새 엔티티를 만들고 이전 엔티티에 대한 참조를 추적하여 업데이트 한 다음 이전 엔티티를 삭제해야합니다.