hadoop - 级联函数是在单线程中作为hadoop 映射器函数执行的吗？

Question

我正在阅读级联文档第 5.2 章函数，我想知道下面的代码会发生什么。它应该在多线程环境中正常工作吗？更普遍的问题是函数可以是多线程的吗？据我所知，单个映射器是单线程的。

具体来说，我已经测试了这样的代码，在我看来这不是线程安全的。也许我不正确理解第 (39) 页上的文档。

public class NotThreadSafeObject{ 
 ...
 public void doSomething(){
       // update state
 }
 public String getValue(){
       // returns value from state 
 }
public class SomeFunction extends BaseOperation<Tuple> implements Function<Tuple>
 {
    // constructors
   @Override
   public void prepare( FlowProcess flowProcess, OperationCall<Tuple> call )
   {
   // create a reusable Object with state of size 1
    call.setContext( new NotThreadSafeObject() );
   }

   public void operate( FlowProcess flowProcess, FunctionCall<Tuple> call )
   {
     // ...
     NotThreadSafeObject obj = call.getContext();
     obj.doSomething(); 
     Tuple tup = new Tuple();
     tup.set(0,obj.getValue());  
     call.getOutputCollector().add(tup);
   }

   @Override
   public void cleanup( FlowProcess flowProcess, OperationCall<Tuple> call )
   {
      call.setContext( null );
   }
}

Answer 1

根据Cascading 文档，这应该可以正常工作，实际上是在非聚合操作中使用 Context 的主要原因。