[NEMO-146] Simpler InputReader#read Return Type

• Type: Sub-task
• Status: Open
• Priority: Minor
• Resolution: Unresolved
• Labels: runtime
• Assignee: Unassigned
• Reporter: John Yang
• Created: 08/Jul/18 06:37
• Updated: 09/Jul/18 05:52

Description

At the moment the InputReader class provides a method

   List<CompletableFuture<DataUtil.IteratorWithNumBytes>> read();

This is much more complex than the OutputWriter class's method

   void write(final Object element);

As a result we have bunch of low-level logic for handling multiple futures and iterators in ParentTaskDataFetcher. We may want to move that logic into InputReader, so ParentTaskDataFetcher only has logic related to tasks.

Something like this would be nicer

  DataUtil.IteratorWithNumBytes read();