...
Code Block |
---|
// Input class will encapsulate one of the following three things: name,// args, splits public1. classDataset Input- {name, args, splits private// final String datasetName;2. Stream - privateStreamBatchReadable final// Map<String, String> arguments;3. InputFormatProvider public privateclass finalInput List<Split>{ splits; // ... } // The new APIs on MapReduceContext will be: void addInput(Input input); void addInput(StreamBatchReadable stream); void addInput(String inputName, InputFormatProvider inputFormatProvider); void addInput(Input input, Class<?> mapperCls); void addInput(StreamBatchReadable stream, Class<?> mapperCls); void addInput(String inputName, InputFormatProvider inputFormatProvider, Class<?> mapperClsmapperClass); |
Approach for CDAP-3980 (wip)
...