...
Code Block |
---|
// The new APIs on MapReduceContext will simply be: /** * Updates the input configuration of this MapReduce job to use the specified {@link Input}. * @param input the input to be used */ void addInput(Input input); /** * Updates the input configuration of this MapReduce job to use the specified {@link Input}. * @param input the input to be used * @param mapperCls the mapper class to be used for the input */ void addInput(Input input, Class<?> mapperClassmapperCls); |
Approach for CDAP-3980 (wip)
...