Packages

case class PublisherStats(compiled: LongAccumulator, compiledSize: LongAccumulator, added: LongAccumulator, changed: LongAccumulator, deleted: LongAccumulator, rebaseUploaded: LongAccumulator, rebaseDeleted: LongAccumulator, pulledFromBase: LongAccumulator, deletedFromBase: LongAccumulator) extends Product with Serializable

Spark accumulators for publishing statistics.

compiled

The total number of output partitions compiled, but not necessarily published.

added

The number of output partitions added.

changed

The number of output partitions changed.

deleted

The number of output partitions deleted.

rebaseUploaded

The number of output partitions re-uploaded to override a base change.

rebaseDeleted

The number of output partitions re-deleted to override a base change.

pulledFromBase

The number of output partitions not published because already published in base.

deletedFromBase

The number of output partitions not deleted because already deleted in base.

Linear Supertypes
Serializable, Serializable, Product, Equals, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PublisherStats
  2. Serializable
  3. Serializable
  4. Product
  5. Equals
  6. AnyRef
  7. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new PublisherStats(compiled: LongAccumulator, compiledSize: LongAccumulator, added: LongAccumulator, changed: LongAccumulator, deleted: LongAccumulator, rebaseUploaded: LongAccumulator, rebaseDeleted: LongAccumulator, pulledFromBase: LongAccumulator, deletedFromBase: LongAccumulator)

    compiled

    The total number of output partitions compiled, but not necessarily published.

    added

    The number of output partitions added.

    changed

    The number of output partitions changed.

    deleted

    The number of output partitions deleted.

    rebaseUploaded

    The number of output partitions re-uploaded to override a base change.

    rebaseDeleted

    The number of output partitions re-deleted to override a base change.

    pulledFromBase

    The number of output partitions not published because already published in base.

    deletedFromBase

    The number of output partitions not deleted because already deleted in base.

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. val added: LongAccumulator
  5. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  6. val changed: LongAccumulator
  7. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native() @IntrinsicCandidate()
  8. val compiled: LongAccumulator
  9. val compiledSize: LongAccumulator
  10. val deleted: LongAccumulator
  11. val deletedFromBase: LongAccumulator
  12. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  14. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  15. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  16. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  17. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  18. val pulledFromBase: LongAccumulator
  19. val rebaseDeleted: LongAccumulator
  20. val rebaseUploaded: LongAccumulator
  21. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  22. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  23. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()
  24. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

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

Inherited from Serializable

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from AnyRef

Inherited from Any

Ungrouped