public class RDDPartitionSeq extends Object implements scala.collection.Seq<RDDPartitionInfo>
The external interface is an immutable Seq, which is thread-safe for traversal. There are no guarantees about consistency though - iteration might return elements that have been removed or miss added elements.
Internally, the sequence is mutable, and elements can modify the data they expose. Additions and removals are O(1). It is not safe to do multiple writes concurrently.
scala.PartialFunction.AndThen<A,B,C>, scala.PartialFunction.Lifted<A,B>, scala.PartialFunction.OrElse<A,B>, scala.PartialFunction.Unlifted<A,B>scala.collection.SeqLike.CombinationsItr, scala.collection.SeqLike.PermutationsItrscala.collection.TraversableLike.WithFilterscala.collection.TraversableOnce.BufferedCanBuildFrom<A,CC 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 and Description |
|---|
RDDPartitionSeq() |
| Modifier and Type | Method and Description |
|---|---|
void |
addPartition(LiveRDDPartition part) |
RDDPartitionInfo |
apply(int idx) |
int |
count() |
scala.collection.Iterator<RDDPartitionInfo> |
iterator() |
int |
length() |
void |
removePartition(LiveRDDPartition part) |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitandThen, applyOrElse, isDefinedAt, lift, orElse, runWithapply, apply$mcDD$sp, apply$mcDF$sp, apply$mcDI$sp, apply$mcDJ$sp, apply$mcFD$sp, apply$mcFF$sp, apply$mcFI$sp, apply$mcFJ$sp, apply$mcID$sp, apply$mcIF$sp, apply$mcII$sp, apply$mcIJ$sp, apply$mcJD$sp, apply$mcJF$sp, apply$mcJI$sp, apply$mcJJ$sp, apply$mcVD$sp, apply$mcVF$sp, apply$mcVI$sp, apply$mcVJ$sp, apply$mcZD$sp, apply$mcZF$sp, apply$mcZI$sp, apply$mcZJ$sp, compose, toStringflatten, foreach, genericBuilder, head, isEmpty, transpose, unzip, unzip3$colon$plus, $plus$colon, combinations, contains, containsSlice, corresponds, diff, distinct, endsWith, indexOfSlice, indexOfSlice, indexWhere, indices, intersect, isEmpty, lastIndexOfSlice, lastIndexOfSlice, lastIndexWhere, lengthCompare, padTo, parCombiner, patch, permutations, reverse, reverseIterator, reverseMap, segmentLength, size, sortBy, sorted, sortWith, startsWith, thisCollection, toCollection, toSeq, toString, union, updated, view, viewcanEqual, copyToArray, drop, dropRight, exists, find, foldRight, forall, foreach, grouped, head, reduceRight, sameElements, slice, sliding, sliding, take, takeRight, takeWhile, toIterable, toIterator, toStream, zip, zipAll, zipWithIndex$plus$plus, $plus$plus$colon, $plus$plus$colon, collect, dropWhile, filter, filterNot, flatMap, groupBy, hasDefiniteSize, headOption, init, inits, isTraversableAgain, last, lastOption, map, newBuilder, partition, repr, scan, scanLeft, scanRight, sliceWithKnownBound, sliceWithKnownDelta, span, splitAt, stringPrefix, tail, tails, to, toTraversable, withFilter$colon$bslash, $div$colon, addString, addString, addString, aggregate, collectFirst, copyToArray, copyToArray, copyToBuffer, count, fold, foldLeft, max, maxBy, min, minBy, mkString, mkString, mkString, nonEmpty, product, reduce, reduceLeft, reduceLeftOption, reduceOption, reduceRightOption, reversed, sum, toArray, toBuffer, toIndexedSeq, toList, toMap, toSet, toVectorpublic void addPartition(LiveRDDPartition part)
public RDDPartitionInfo apply(int idx)
apply in interface scala.collection.GenSeqLike<RDDPartitionInfo,scala.collection.Seq<RDDPartitionInfo>>apply in interface scala.collection.SeqLike<RDDPartitionInfo,scala.collection.Seq<RDDPartitionInfo>>public int count()
public scala.collection.Iterator<RDDPartitionInfo> iterator()
iterator in interface scala.collection.GenIterableLike<RDDPartitionInfo,scala.collection.Seq<RDDPartitionInfo>>iterator in interface scala.collection.IterableLike<RDDPartitionInfo,scala.collection.Seq<RDDPartitionInfo>>public int length()
length in interface scala.collection.GenSeqLike<RDDPartitionInfo,scala.collection.Seq<RDDPartitionInfo>>length in interface scala.collection.SeqLike<RDDPartitionInfo,scala.collection.Seq<RDDPartitionInfo>>public void removePartition(LiveRDDPartition part)