sanha commented on a change in pull request #2: [NEMO-7] Intra-TaskGroup
pipelining
URL: https://github.com/apache/incubator-nemo/pull/2#discussion_r173049551
##########
File path:
runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/datatransfer/OutputCollectorImpl.java
##########
@@ -46,11 +61,39 @@ public void emit(final String dstVertexId, final Object
output) {
}
/**
- * Collects the accumulated output and replace the output list.
+ * Inter-Task data is transferred from sender-side Task's
OutputCollectorImpl to receiver-side Task.
*
- * @return the list of output elements.
+ * @return the first element of this list
*/
- public List<O> collectOutputList() {
- return outputList.getAndSet(new ArrayList<>());
+ public O remove() {
Review comment:
Please add comments about these methods
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
With regards,
Apache Git Services
