Package org.apache.spark.status

Class RDDPartitionSeq

Object
org.apache.spark.status.RDDPartitionSeq
All Implemented Interfaces:
scala.collection.immutable.Iterable<RDDPartitionInfo>, scala.collection.immutable.Seq<RDDPartitionInfo>, scala.collection.immutable.SeqOps<RDDPartitionInfo,scala.collection.immutable.Seq,scala.collection.immutable.Seq<RDDPartitionInfo>>, scala.collection.Iterable<RDDPartitionInfo>, scala.collection.IterableFactoryDefaults<RDDPartitionInfo,scala.collection.Iterable>, scala.collection.IterableOnce<RDDPartitionInfo>, scala.collection.IterableOnceOps<RDDPartitionInfo,scala.collection.Iterable,scala.collection.Iterable>, scala.collection.IterableOps<RDDPartitionInfo,scala.collection.Iterable,scala.collection.Iterable>, scala.collection.Seq<RDDPartitionInfo>, scala.collection.SeqOps<RDDPartitionInfo,scala.collection.Seq,scala.collection.Seq<RDDPartitionInfo>>, scala.Equals, scala.Function1<Object,RDDPartitionInfo>, scala.PartialFunction<Object,RDDPartitionInfo>
public class RDDPartitionSeq extends Object implements scala.collection.immutable.Seq<RDDPartitionInfo>
A custom sequence of partitions based on a mutable linked list.

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.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface scala.Function1

    scala.Function1.UnliftOps<A extends Object,B extends Object>, scala.Function1.UnliftOps$

    Nested classes/interfaces inherited from interface scala.collection.IterableOps

    scala.collection.IterableOps.SizeCompareOps, scala.collection.IterableOps.SizeCompareOps$, scala.collection.IterableOps.WithFilter<A extends Object,CC extends Object>

    Nested classes/interfaces inherited from interface scala.PartialFunction

    scala.PartialFunction.ElementWiseExtractor<A extends Object,B extends Object>, scala.PartialFunction.ElementWiseExtractor$

  • Constructor Summary

    Constructors
    Constructor
    Description
    RDDPartitionSeq()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addPartition(LiveRDDPartition part)
     
    RDDPartitionInfo
    apply(int idx)
     
    int
    count()
     
    scala.collection.Iterator<RDDPartitionInfo>
    iterator()
     
    int
    length()
     
    void
    removePartition(LiveRDDPartition part)
     

    Methods inherited from class java.lang.Object

    equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface scala.Function1

    apply, 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

    Methods inherited from interface scala.collection.Iterable

    className, coll, collectionClassName, lazyZip, seq, toIterable

    Methods inherited from interface scala.collection.IterableFactoryDefaults

    empty, fromSpecific, newSpecificBuilder

    Methods inherited from interface scala.collection.IterableOnce

    knownSize, stepper

    Methods inherited from interface scala.collection.IterableOnceOps

    $colon$bslash, $div$colon, addString, addString, addString, aggregate, collectFirst, copyToArray, copyToArray, copyToArray, copyToBuffer, corresponds, count, exists, find, fold, foldLeft, foldRight, forall, foreach, hasDefiniteSize, max, maxBy, maxByOption, maxOption, min, minBy, minByOption, minOption, mkString, mkString, mkString, nonEmpty, product, reduce, reduceLeft, reduceLeftOption, reduceOption, reduceRight, reduceRightOption, reversed, sum, to, toArray, toBuffer, toIndexedSeq, toIterator, toList, toMap, toSet, toStream, toVector

    Methods inherited from interface scala.collection.IterableOps

    $plus$plus, collect, companion, drop, dropRight, dropWhile, filter, filterNot, flatMap, flatten, groupBy, grouped, groupMap, groupMapReduce, head, headOption, init, inits, isTraversableAgain, last, lastOption, map, partition, partitionMap, repr, scan, scanLeft, scanRight, sizeIs, slice, sliding, sliding, span, splitAt, tail, tails, take, takeRight, takeWhile, tapEach, toTraversable, transpose, unzip, unzip3, view, withFilter, zip, zipAll, zipWithIndex

    Methods inherited from interface scala.PartialFunction

    andThen, andThen, applyOrElse, compose, elementWise, isDefinedAt, lift, orElse, runWith, unapply

    Methods inherited from interface scala.collection.immutable.Seq

    iterableFactory, toSeq

    Methods inherited from interface scala.collection.Seq

    canEqual, equals, hashCode, stringPrefix, toString

    Methods inherited from interface scala.collection.SeqOps

    $colon$plus, $colon$plus$plus, $plus$colon, $plus$plus$colon, appended, appendedAll, combinations, concat, contains, containsSlice, corresponds, diff, distinct, distinctBy, endsWith, findLast, indexOf, indexOf, indexOfSlice, indexOfSlice, indexWhere, indexWhere, indices, intersect, isDefinedAt, isEmpty, lastIndexOf, lastIndexOf$default$2, lastIndexOfSlice, lastIndexOfSlice, lastIndexWhere, lastIndexWhere, lengthCompare, lengthCompare, lengthIs, occCounts, padTo, patch, permutations, prefixLength, prepended, prependedAll, reverse, reverseIterator, reverseMap, sameElements, scala$collection$SeqOps$$toGenericSeq, search, search, segmentLength, segmentLength, size, sizeCompare, sizeCompare, sortBy, sorted, sortWith, startsWith, startsWith$default$2, union, updated, view

  • Constructor Details

    • RDDPartitionSeq

      public RDDPartitionSeq()

  • Method Details