Movatterモバイル変換


[0]ホーム

URL:


Spark 4.0.1 ScalaDoc< Back

Packages

o

org.apache.spark.rdd

DeterministicLevel

objectDeterministicLevel extendsEnumeration

The deterministic level of RDD's output (i.e. whatRDD#compute returns). This explains howthe output will diff when Spark reruns the tasks for the RDD. There are 3 deterministic levels:1. DETERMINATE: The RDD output is always the same data set in the same order after a rerun.2. UNORDERED: The RDD output is always the same data set but the order can be different after a rerun.3. INDETERMINATE. The RDD output can be different after a rerun.

Note that, the output of an RDD usually relies on the parent RDDs. When the parent RDD's outputis INDETERMINATE, it's very likely the RDD's output is also INDETERMINATE.

Annotations
@DeveloperApi()
Source
RDD.scala
Linear Supertypes
Enumeration,Serializable,AnyRef,Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DeterministicLevel
  2. Enumeration
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Type Members

  1. classVal extendsValue withSerializable
    Attributes
    protected
    Definition Classes
    Enumeration
    Annotations
    @SerialVersionUID()
  2. abstractclassValue extendsOrdered[Value] withSerializable
    Definition Classes
    Enumeration
    Annotations
    @SerialVersionUID()
  3. classValueSet extendsAbstractSet[Value] withSortedSet[Value] withSortedSetOps[Value,SortedSet,ValueSet] withStrictOptimizedIterableOps[Value,Set,ValueSet] withSerializable
    Definition Classes
    Enumeration
    Annotations
    @SerialVersionUID()

Value Members

  1. finaldef!=(arg0:Any):Boolean
    Definition Classes
    AnyRef → Any
  2. finaldef##:Int
    Definition Classes
    AnyRef → Any
  3. finaldef==(arg0:Any):Boolean
    Definition Classes
    AnyRef → Any
  4. valDETERMINATE:Value
  5. valINDETERMINATE:Value
  6. valUNORDERED:Value
  7. finaldefValue(i:Int,name:String):Value
    Attributes
    protected
    Definition Classes
    Enumeration
  8. finaldefValue(name:String):Value
    Attributes
    protected
    Definition Classes
    Enumeration
  9. finaldefValue(i:Int):Value
    Attributes
    protected
    Definition Classes
    Enumeration
  10. finaldefValue:Value
    Attributes
    protected
    Definition Classes
    Enumeration
  11. finaldefapply(x:Int):Value
    Definition Classes
    Enumeration
  12. finaldefasInstanceOf[T0]:T0
    Definition Classes
    Any
  13. defclone():AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException])@IntrinsicCandidate()@native()
  14. finaldefeq(arg0:AnyRef):Boolean
    Definition Classes
    AnyRef
  15. defequals(arg0:AnyRef):Boolean
    Definition Classes
    AnyRef → Any
  16. finaldefgetClass():Class[_ <:AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate()@native()
  17. defhashCode():Int
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate()@native()
  18. finaldefisInstanceOf[T0]:Boolean
    Definition Classes
    Any
  19. finaldefmaxId:Int
    Definition Classes
    Enumeration
  20. finaldefne(arg0:AnyRef):Boolean
    Definition Classes
    AnyRef
  21. varnextId:Int
    Attributes
    protected
    Definition Classes
    Enumeration
  22. varnextName:Iterator[String]
    Attributes
    protected
    Definition Classes
    Enumeration
  23. finaldefnotify():Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate()@native()
  24. finaldefnotifyAll():Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate()@native()
  25. defreadResolve():AnyRef
    Attributes
    protected
    Definition Classes
    Enumeration
  26. finaldefsynchronized[T0](arg0: =>T0):T0
    Definition Classes
    AnyRef
  27. deftoString():String
    Definition Classes
    Enumeration → AnyRef → Any
  28. defvalues:ValueSet
    Definition Classes
    Enumeration
  29. finaldefwait(arg0:Long,arg1:Int):Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  30. finaldefwait(arg0:Long):Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])@native()
  31. finaldefwait():Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  32. finaldefwithName(s:String):Value
    Definition Classes
    Enumeration
  33. implicitobjectValueOrdering extendsOrdering[Value]
    Definition Classes
    Enumeration

Deprecated Value Members

  1. deffinalize():Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable])@Deprecated
    Deprecated

    (Since version 9)

Inherited fromEnumeration

Inherited fromSerializable

Inherited fromAnyRef

Inherited fromAny

Ungrouped


[8]ページ先頭

©2009-2025 Movatter.jp