如何将参数传递给mapreducemapreduce_pipeline.MapreducePipeline中定义的mapreduce_pipeline.MapreducePipeline函数?我使用DatastoreInputReader作为输入源。function """def mapper(model_entity_instance, params_dict):
""" my m
/year=2014/month=8/day=20/hour=2/logB.txt 如果我将一个日志文件作为输入传递给Java mapreduce程序,它就会工作。See my working syntax below:
hadoop jar test.jar wc /year=2014/month=8/