Added comment to InterruptibleIterator.
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/c68e72be Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/c68e72be Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/c68e72be Branch: refs/heads/master Commit: c68e72be59c9912fa56028a397b244a99160c0d1 Parents: 7095381 Author: Reynold Xin <reyno...@gmail.com> Authored: Thu Sep 19 18:40:06 2013 -0700 Committer: Reynold Xin <reyno...@gmail.com> Committed: Thu Sep 19 18:40:06 2013 -0700 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/InterruptibleIterator.scala | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/c68e72be/core/src/main/scala/org/apache/spark/InterruptibleIterator.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/InterruptibleIterator.scala b/core/src/main/scala/org/apache/spark/InterruptibleIterator.scala index d2659db..56e0b8d 100644 --- a/core/src/main/scala/org/apache/spark/InterruptibleIterator.scala +++ b/core/src/main/scala/org/apache/spark/InterruptibleIterator.scala @@ -17,6 +17,10 @@ package org.apache.spark +/** + * An iterator that wraps around an existing iterator to provide task killing functionality. + * It works by checking the interrupted flag in TaskContext. + */ class InterruptibleIterator[+T](val context: TaskContext, val delegate: Iterator[T]) extends Iterator[T] {
