Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

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)

...