|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Object org.apache.spark.InterruptibleIterator<T>
public class InterruptibleIterator<T>
:: DeveloperApi ::
An iterator that wraps around an existing iterator to provide task killing functionality.
It works by checking the interrupted flag in TaskContext
.
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface scala.collection.Iterator |
---|
scala.collection.Iterator.GroupedIterator<B> |
Nested classes/interfaces inherited from interface scala.collection.TraversableOnce |
---|
scala.collection.TraversableOnce.BufferedCanBuildFrom<A,Coll extends scala.collection.TraversableOnce<Object>>, scala.collection.TraversableOnce.FlattenOps<A>, scala.collection.TraversableOnce.ForceImplicitAmbiguity, scala.collection.TraversableOnce.MonadOps<A>, scala.collection.TraversableOnce.OnceCanBuildFrom<A> |
Constructor Summary | |
---|---|
InterruptibleIterator(TaskContext context,
scala.collection.Iterator<T> delegate)
|
Method Summary | |
---|---|
TaskContext |
context()
|
scala.collection.Iterator<T> |
delegate()
|
boolean |
hasNext()
|
T |
next()
|
Methods inherited from class Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface scala.collection.Iterator |
---|
$plus$plus, buffered, collect, contains, copyToArray, corresponds, drop, dropWhile, duplicate, exists, filter, filterNot, find, flatMap, forall, foreach, grouped, hasDefiniteSize, indexOf, indexWhere, isEmpty, isTraversableAgain, length, map, padTo, partition, patch, sameElements, scanLeft, scanRight, seq, slice, sliding, sliding$default$2, span, take, takeWhile, toIterator, toStream, toString, toTraversable, withFilter, zip, zipAll, zipWithIndex |
Methods inherited from interface scala.collection.TraversableOnce |
---|
$colon$bslash, $div$colon, addString, addString, addString, aggregate, collectFirst, copyToArray, copyToArray, copyToBuffer, count, fold, foldLeft, foldRight, max, maxBy, min, minBy, mkString, mkString, mkString, nonEmpty, product, reduce, reduceLeft, reduceLeftOption, reduceOption, reduceRight, reduceRightOption, reversed, size, sum, to, toArray, toBuffer, toIndexedSeq, toIterable, toList, toMap, toSeq, toSet, toVector |
Methods inherited from interface scala.collection.GenTraversableOnce |
---|
$div$colon$bslash |
Constructor Detail |
---|
public InterruptibleIterator(TaskContext context, scala.collection.Iterator<T> delegate)
Method Detail |
---|
public TaskContext context()
public scala.collection.Iterator<T> delegate()
public boolean hasNext()
hasNext
in interface scala.collection.Iterator<T>
public T next()
next
in interface scala.collection.Iterator<T>
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |