| /dports/devel/hadoop/hadoop-1.2.1/src/mapred/org/apache/hadoop/mapred/lib/ |
| H A D | ChainReducer.java | 125 Class<? extends V1> inputValueClass, in setReducer() argument
132 Chain.setReducer(job, klass, inputKeyClass, inputValueClass, outputKeyClass, in setReducer()
169 Class<? extends V1> inputValueClass, in addMapper() argument
175 Chain.addMapper(false, job, klass, inputKeyClass, inputValueClass, in addMapper()
|
| H A D | Chain.java | 165 Class<? extends V1> inputValueClass, in addMapper() argument
194 if (! inputValueClass.isAssignableFrom( in addMapper()
210 if (! inputValueClass.isAssignableFrom( in addMapper()
229 mapperConf.setClass(MAPPER_INPUT_VALUE_CLASS, inputValueClass, in addMapper()
271 Class<? extends V1> inputValueClass, in setReducer() argument
295 reducerConf.setClass(REDUCER_INPUT_VALUE_CLASS, inputValueClass, in setReducer()
|
| H A D | ChainMapper.java | 125 Class<? extends V1> inputValueClass, in addMapper() argument
132 Chain.addMapper(true, job, klass, inputKeyClass, inputValueClass, in addMapper()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/lib/ |
| H A D | ChainReducer.java | 129 Class<? extends V1> inputValueClass, in setReducer() argument
136 Chain.setReducer(job, klass, inputKeyClass, inputValueClass, outputKeyClass, in setReducer()
173 Class<? extends V1> inputValueClass, in addMapper() argument
179 Chain.addMapper(false, job, klass, inputKeyClass, inputValueClass, in addMapper()
|
| H A D | Chain.java | 91 Class<? extends V1> inputValueClass, in addMapper() argument
104 validateKeyValueTypes(isMap, jobConf, inputKeyClass, inputValueClass, in addMapper()
117 setMapperConf(isMap, jobConf, inputKeyClass, inputValueClass, in addMapper()
142 Class<? extends V1> inputValueClass, in setReducer() argument
163 setReducerConf(jobConf, inputKeyClass, inputValueClass, outputKeyClass, in setReducer()
|
| H A D | ChainMapper.java | 129 Class<? extends V1> inputValueClass, in addMapper() argument
136 Chain.addMapper(true, job, klass, inputKeyClass, inputValueClass, in addMapper()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapreduce/lib/chain/ |
| H A D | ChainReducer.java | 125 Class<?> inputKeyClass, Class<?> inputValueClass, in setReducer() argument
131 Chain.setReducer(job, klass, inputKeyClass, inputValueClass, in setReducer()
169 Class<?> inputKeyClass, Class<?> inputValueClass, in addMapper() argument
174 Chain.addMapper(false, job, klass, inputKeyClass, inputValueClass, in addMapper()
|
| H A D | Chain.java | 630 Class<?> inputValueClass, Class<?> outputKeyClass, in addMapper() argument
642 validateKeyValueTypes(isMap, jobConf, inputKeyClass, inputValueClass, in addMapper()
645 setMapperConf(isMap, jobConf, inputKeyClass, inputValueClass, in addMapper()
682 if (!inputValueClass.isAssignableFrom(reducerConf.getClass( in validateKeyValueTypes()
697 if (!inputValueClass.isAssignableFrom(previousMapperConf.getClass( in validateKeyValueTypes()
706 Class<?> inputKeyClass, Class<?> inputValueClass, in setMapperConf() argument
720 .setClass(MAPPER_INPUT_VALUE_CLASS, inputValueClass, Object.class); in setMapperConf()
765 Class<?> inputKeyClass, Class<?> inputValueClass, in setReducer() argument
774 setReducerConf(jobConf, inputKeyClass, inputValueClass, outputKeyClass, in setReducer()
779 Class<?> inputKeyClass, Class<?> inputValueClass, in setReducerConf() argument
[all …]
|
| H A D | ChainMapper.java | 120 Class<?> inputKeyClass, Class<?> inputValueClass, in addMapper() argument
126 Chain.addMapper(true, job, klass, inputKeyClass, inputValueClass, in addMapper()
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-tools/hadoop-pipes/src/main/native/pipes/impl/ |
| H A D | HadoopPipes.cc | 731 string* inputValueClass; member in HadoopPipes::TaskContextImpl
758 inputValueClass = NULL; in TaskContextImpl()
799 inputValueClass = new string(valueType); in setInputTypes()
978 return *inputValueClass; in getInputValueClass()
1036 delete inputValueClass; in ~TaskContextImpl()
|
| /dports/devel/hadoop/hadoop-1.2.1/src/c++/pipes/impl/ |
| H A D | HadoopPipes.cc | 731 string* inputValueClass; member in HadoopPipes::TaskContextImpl
758 inputValueClass = NULL; in TaskContextImpl()
799 inputValueClass = new string(valueType); in setInputTypes()
978 return *inputValueClass; in getInputValueClass()
1036 delete inputValueClass; in ~TaskContextImpl()
|