org.apache.spark.util

Class CompletionIterator<A,I extends scala.collection.Iterator<A>>

Object

org.apache.spark.util.CompletionIterator<A,I>

All Implemented Interfaces:

scala.collection.GenTraversableOnce<A>, scala.collection.Iterator<A>, scala.collection.TraversableOnce<A>

public abstract class CompletionIterator<A,I extends scala.collection.Iterator<A>>
extends Object
implements scala.collection.Iterator<A>

Wrapper around an iterator which calls a completion method after it successfully iterates through all the elements.

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

Constructors

Constructor and Description
CompletionIterator(I sub)

Method Summary

Methods

Modifier and Type	Method and Description
static <A,I extends scala.collection.Iterator<A>> CompletionIterator<A,I>	apply(I sub, scala.Function0<scala.runtime.BoxedUnit> completionFunction)
abstract void	completion()
boolean	hasNext()
A	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

CompletionIterator

public CompletionIterator(I sub)

Method Detail

apply

public static <A,I extends scala.collection.Iterator<A>> CompletionIterator<A,I> apply(I sub,
                                                                       scala.Function0<scala.runtime.BoxedUnit> completionFunction)

next

public A next()

Specified by:

next in interface scala.collection.Iterator<A>

hasNext

public boolean hasNext()

Specified by:

hasNext in interface scala.collection.Iterator<A>

completion

public abstract void completion()