object PreviousRunId extends PreviousRunIdEncoding
- Alphabetic
- By Inheritance
- PreviousRunId
- PreviousRunIdEncoding
- CatalogIdVersionEncoding
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
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
- def apply(name: String, previousRun: Long): Id
Defines a catalog identifier to refer to a specific version of the catalog.
Defines a catalog identifier to refer to a specific version of the catalog. Given an input catalog identifier, the augmented identifier refers the catalog version used by the given previous compilation; given the output catalog identifier, the augmented identifier refers to the catalog version produced by the given previous compilation.
Example 1:
Default.PreviousRunId("inputA", 1)
refers to the input catalog "inputA" in the version used in the previous compilation.
Example 2:
Default.PreviousRunId("inputA", 2)
refers to the input catalog "inputA" in the version used in the compilation before that.
- name
A catalog identifier from the configuration of the pipeline.
- previousRun
The number of compilations to go back in time. For example, 1 refers to the previous version of the output catalog; refers to the version before that. Must be greater than 0.
- returns
A catalog identifier that refers to the given catalog at a previous run.
- def apply(name: String): Id
Defines a catalog identifier to refer to a specific version of the catalog.
Defines a catalog identifier to refer to a specific version of the catalog. Given an input catalog identifier, the augmented identifier refers the catalog version used by the previous compilation; given the output catalog identifier, the augmented identifier refers to the catalog version produced by the previous compilation.
Example:
Default.PreviousRunId("inputA")refers to the input catalog "inputA" in the version used in the previous compilation.
- name
A catalog identifier from the configuration of the pipeline.
- returns
A catalog identifier that refers to the given catalog at the previous run.
- def apply(catalogId: Id, previousRun: Long = 1L): Id
Defines a catalog identifier to refer to a specific version of the catalog.
Defines a catalog identifier to refer to a specific version of the catalog. Given an input catalog identifier, the augmented identifier refers the catalog version used by the given previous compilation; given the output catalog identifier, the augmented identifier refers to the catalog version produced by the given previous compilation.
Example 1:
Default.PreviousRunId(Default.OutCatalogId)
refers to the output catalog produced by the previous compilation, that is, the feedback catalog.
Example 2:
Default.PreviousRunId(Default.OutCatalogId, 2)refers to the output catalog produced by the compilation before that.
Example 3:
Default.PreviousRunId(inputCatalogId)
refers to an input catalog used by the previous compilation.
- catalogId
A catalog identifier from the configuration of the pipeline.
- previousRun
The number of compilations to go back in time. For example, 1 refers to the previous version of the output catalog; 2 refers to the version before that. Must be greater than 0, and defaults to 1.
- returns
A catalog identifier that refers to the given catalog at a previous run.
- 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 encode(catalogId: String, argument: Long): Id
Given a catalog ID and a generic integer argument, returns a catalog ID encoding the argument.
Given a catalog ID and a generic integer argument, returns a catalog ID encoding the argument.
- catalogId
The original catalog ID, with no version information encoded.
- argument
The argument to be encoded.
- returns
The new catalog ID, with version information encoded.
- Attributes
- protected[impl]
- Definition Classes
- CatalogIdVersionEncoding
- 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 matches(catalogId: Id): Boolean
Checks if the given catalog ID matches the version encoding defined by the class.
Checks if the given catalog ID matches the version encoding defined by the class.
- catalogId
The catalog ID to be checked.
- returns
trueif the catalog ID matches,falseotherwise
- Attributes
- protected[impl]
- Definition Classes
- CatalogIdVersionEncoding
- 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
- def unapply(catalogId: Id): Option[(Id, Long)]
Given a catalog ID encoded in this encoding scheme, returns the decoded catalog ID and the encoding argument.
Given a catalog ID encoded in this encoding scheme, returns the decoded catalog ID and the encoding argument. Returns
Noneif the given catalog ID is not encoded in this encoding scheme.- catalogId
The catalog ID to be decoded.
- returns
The original catalog ID and the encoding argument.
- Definition Classes
- CatalogIdVersionEncoding
- 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)