org.apache.spark.rdd
Class PartitionCoalescer.LocationIterator

Object
  extended by org.apache.spark.rdd.PartitionCoalescer.LocationIterator
All Implemented Interfaces:
scala.collection.GenTraversableOnce<scala.Tuple2<String,Partition>>, scala.collection.Iterator<scala.Tuple2<String,Partition>>, scala.collection.TraversableOnce<scala.Tuple2<String,Partition>>
Enclosing class:
PartitionCoalescer

public class PartitionCoalescer.LocationIterator
extends Object
implements scala.collection.Iterator<scala.Tuple2<String,Partition>>


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
PartitionCoalescer.LocationIterator(RDD<?> prev)
           
 
Method Summary
 boolean hasNext()
           
 boolean isEmpty()
           
 scala.collection.Iterator<scala.Tuple2<String,Partition>> it()
           
 scala.Tuple2<String,Partition> next()
           
 scala.collection.Iterator<scala.Tuple2<String,Partition>> resetIterator()
           
 
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, 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

PartitionCoalescer.LocationIterator

public PartitionCoalescer.LocationIterator(RDD<?> prev)
Method Detail

it

public scala.collection.Iterator<scala.Tuple2<String,Partition>> it()

isEmpty

public boolean isEmpty()
Specified by:
isEmpty in interface scala.collection.GenTraversableOnce<scala.Tuple2<String,Partition>>
Specified by:
isEmpty in interface scala.collection.Iterator<scala.Tuple2<String,Partition>>
Specified by:
isEmpty in interface scala.collection.TraversableOnce<scala.Tuple2<String,Partition>>

resetIterator

public scala.collection.Iterator<scala.Tuple2<String,Partition>> resetIterator()

hasNext

public boolean hasNext()
Specified by:
hasNext in interface scala.collection.Iterator<scala.Tuple2<String,Partition>>

next

public scala.Tuple2<String,Partition> next()
Specified by:
next in interface scala.collection.Iterator<scala.Tuple2<String,Partition>>