trait StateStoreInstanceMetric extends AnyRef
- Alphabetic
- By Inheritance
- StateStoreInstanceMetric
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def combine(originalMetric: SQLMetric, value: Long): Long
Defines how to merge metric values from different executors for the same state store instance in situations like speculative execution or provider unloading.
Defines how to merge metric values from different executors for the same state store instance in situations like speculative execution or provider unloading. In most cases, the original metric value is at its initial value.
- abstract def createSQLMetric(sparkContext: SparkContext): SQLMetric
- abstract def descPrefix: String
- abstract def ignoreIfUnchanged: Boolean
Should this instance metric be reported if it is unchanged from its initial value
- abstract def initValue: Long
- abstract def metricPrefix: String
- abstract def ordering: Ordering[Long]
Defines how instance metrics are selected for progress reporting.
Defines how instance metrics are selected for progress reporting. Metrics are sorted by value using this ordering, and only the first N metrics are displayed. For example, the highest N metrics by value should use Ordering.Long.reverse.
- abstract def partitionId: Option[Int]
- abstract def storeName: String
- abstract def withNewId(partitionId: Int, storeName: String): StateStoreInstanceMetric
Concrete Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- def desc: String
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def name: String
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @IntrinsicCandidate() @native()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)