case class StateStoreSnapshotLastUploadInstanceMetric(partitionId: Option[Int] = None, storeName: String = StateStoreId.DEFAULT_STORE_NAME) extends StateStoreInstanceMetric with Product with Serializable
Linear Supertypes
Ordering
- Alphabetic
- By Inheritance
Inherited
- StateStoreSnapshotLastUploadInstanceMetric
- Serializable
- Product
- Equals
- StateStoreInstanceMetric
- AnyRef
- Any
- Hide All
- Show All
Visibility
- Public
- Protected
Instance Constructors
- new StateStoreSnapshotLastUploadInstanceMetric(partitionId: Option[Int] = None, storeName: String = StateStoreId.DEFAULT_STORE_NAME)
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 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.
- Definition Classes
- StateStoreSnapshotLastUploadInstanceMetric → StateStoreInstanceMetric
- def createSQLMetric(sparkContext: SparkContext): SQLMetric
- Definition Classes
- StateStoreSnapshotLastUploadInstanceMetric → StateStoreInstanceMetric
- def desc: String
- Definition Classes
- StateStoreInstanceMetric
- def descPrefix: String
- Definition Classes
- StateStoreSnapshotLastUploadInstanceMetric → StateStoreInstanceMetric
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def ignoreIfUnchanged: Boolean
Should this instance metric be reported if it is unchanged from its initial value
Should this instance metric be reported if it is unchanged from its initial value
- Definition Classes
- StateStoreSnapshotLastUploadInstanceMetric → StateStoreInstanceMetric
- def initValue: Long
- Definition Classes
- StateStoreSnapshotLastUploadInstanceMetric → StateStoreInstanceMetric
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def metricPrefix: String
- Definition Classes
- StateStoreSnapshotLastUploadInstanceMetric → StateStoreInstanceMetric
- def name: String
- Definition Classes
- StateStoreInstanceMetric
- 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()
- 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.
- Definition Classes
- StateStoreSnapshotLastUploadInstanceMetric → StateStoreInstanceMetric
- val partitionId: Option[Int]
- Definition Classes
- StateStoreSnapshotLastUploadInstanceMetric → StateStoreInstanceMetric
- def productElementNames: Iterator[String]
- Definition Classes
- Product
- val storeName: String
- Definition Classes
- StateStoreSnapshotLastUploadInstanceMetric → StateStoreInstanceMetric
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- 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])
- def withNewId(partitionId: Int, storeName: String): StateStoreSnapshotLastUploadInstanceMetric
- Definition Classes
- StateStoreSnapshotLastUploadInstanceMetric → StateStoreInstanceMetric
Deprecated Value Members
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable]) @Deprecated
- Deprecated
(Since version 9)