File tree Expand file tree Collapse file tree 2 files changed +8
-2
lines changed
core/src/main/scala/org/apache/spark Expand file tree Collapse file tree 2 files changed +8
-2
lines changed Original file line number Diff line number Diff line change 1717
1818package org .apache .spark
1919
20+ import org .apache .spark .annotation .DeveloperApi
21+
2022/**
2123 * An iterator that wraps around an existing iterator to provide task killing functionality.
2224 * It works by checking the interrupted flag in [[TaskContext ]].
2325 */
24- private [spark] class InterruptibleIterator [+ T ](val context : TaskContext , val delegate : Iterator [T ])
26+ @ DeveloperApi
27+ class InterruptibleIterator [+ T ](val context : TaskContext , val delegate : Iterator [T ])
2528 extends Iterator [T ] {
2629
2730 def hasNext : Boolean = {
Original file line number Diff line number Diff line change 1717
1818package org .apache .spark
1919
20+ import org .apache .spark .annotation .DeveloperApi
21+
2022/**
2123 * Exception for a task getting killed.
2224 */
23- private [spark] class TaskKilledException extends RuntimeException
25+ @ DeveloperApi
26+ class TaskKilledException extends RuntimeException
You can’t perform that action at this time.
0 commit comments