case class Changes(sinceVersion: Long, version: Long) extends ProcessingType with Product with Serializable

Indicates that there are new changes to process for this upstream catalog.

This processing type consists of two versions: the version processed in the previous run and the current version. A pipeline can use this additional information to implement incremental processing: calculate and process only the changes that have occurred since the last time the job was submitted.

If incremental processing is not implemented, a pipeline can ignore sinceVersion and use version only.

sinceVersion

The version processed in the previous run.

version

The current version to process.

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

Instance Constructors

  1. new Changes(sinceVersion: Long, version: Long)

    sinceVersion

    The version processed in the previous run.

    version

    The current version to process.

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. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @IntrinsicCandidate() @native()
  8. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  9. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  10. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  11. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @IntrinsicCandidate() @native()
  12. def productElementNames: Iterator[String]
    Definition Classes
    Product
  13. val sinceVersion: Long
  14. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  15. val version: Long
    Definition Classes
    Changes → ProcessingType
  16. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  17. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  18. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

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

    (Since version 9)

Inherited from Serializable

Inherited from Product

Inherited from Equals

Inherited from ProcessingType

Inherited from AnyRef

Inherited from Any

Ungrouped