class CatalogLightProxy extends CatalogLight
Proxy class to allow mixins for runtime loaded CatalogLight classes.
- Alphabetic
- By Inheritance
- CatalogLightProxy
- CatalogLight
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Instance Constructors
- new CatalogLightProxy(impl: CatalogLight)
- impl
Wrapped CatalogLight object.
Type Members
- type CommitPart = CatalogLight.CommitPart
The type of each part identifier of a multipart commit.
The type of each part identifier of a multipart commit.
- Definition Classes
- CatalogLightProxy → CatalogLight
- type CommitToken = CatalogLight.CommitToken
The type of a commit token.
The type of a commit token.
- Definition Classes
- CatalogLightProxy → CatalogLight
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 abortCommit(token: CommitToken): Unit
Aborts a commit being prepared.
Aborts a commit being prepared.
- token
The token identifying the commit to abort
- Definition Classes
- CatalogLightProxy → CatalogLight
- def additionalFields: Set[AdditionalField]
The set of Catalog.AdditionalFields requested to the service when retrieving catalog metadata.
The set of Catalog.AdditionalFields requested to the service when retrieving catalog metadata.
- Definition Classes
- CatalogLightProxy → CatalogLight
- 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()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def finishCommit(token: CommitToken, parts: Seq[CommitPart]): Unit
Completes a multipart commit.
Completes a multipart commit.
- token
The token obtained when startCommit was called to start this commit.
- parts
All the commit parts obtained from calls made to Catalog.partialCommit as part of this commit.
- Definition Classes
- CatalogLightProxy → CatalogLight
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hrn: HRN
The HRN (HERE Resource Name) of the catalog.
The HRN (HERE Resource Name) of the catalog. It is a resource descriptor that provides a globally unique handle for a catalog in the sense of an instance.
- Definition Classes
- CatalogLightProxy → CatalogLight
- def id: Id
The unique identifier for the catalog, that is added to every Partition.Key returned by the query APIs and is used by the commit API for logging and statistics generation.
The unique identifier for the catalog, that is added to every Partition.Key returned by the query APIs and is used by the commit API for logging and statistics generation.
- Definition Classes
- CatalogLightProxy → CatalogLight
- See also
Catalog.Id for more details.
- val impl: CatalogLight
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- 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 queryConfiguration(): Configuration
Queries the current configuration of the catalog.
Queries the current configuration of the catalog.
- returns
The current configuration of the catalog.
- Definition Classes
- CatalogLightProxy → CatalogLight
- def queryDependencies(version: Version): Seq[Dependency]
Queries the dependencies for a particular catalog version.
Queries the dependencies for a particular catalog version.
- version
The version of the catalog for which dependencies will be queried.
- returns
The dependencies of the catalog version.
- Definition Classes
- CatalogLightProxy → CatalogLight
- def queryLatestVersion(): BaseVersion
Queries the latest version of the catalog.
Queries the latest version of the catalog.
- returns
The latest catalog version available in the Data API, or com.here.platform.data.processing.catalog.utils.EmptyCatalog otherwise.
- Definition Classes
- CatalogLightProxy → CatalogLight
- def queryLayerVersions(version: Version): Map[Id, Version]
Queries the latest version for each of the catalog layers.
Queries the latest version for each of the catalog layers. This is the version of the most recent event affecting that layer, either because a partition was changed and/or deleted in that version.
For some layers, this version may be older than the catalog's overall version, particularly if those layers did not change, but other layers have changed.
- version
The version for which the catalog's layers are queried.
- returns
The latest version for each of the catalog's layers.
- Definition Classes
- CatalogLightProxy → CatalogLight
- Note
Layers that have never changed since catalog creation are not returned.
- def queryMinimumVersion(): BaseVersion
Queries the minimum version of the catalog.
Queries the minimum version of the catalog.
- returns
The minimum catalog version available in the Data API, or com.here.platform.data.processing.catalog.utils.EmptyCatalog otherwise.
- Definition Classes
- CatalogLightProxy → CatalogLight
- def queryPartitionChangeHistory(version: Version, layer: Id, partition: Name, direction: Catalog.ChangeHistoryDirection.Value): Seq[Change]
Queries metadata history for the selected partition.
Queries metadata history for the selected partition.
This query is done directly in the Driver, and the metadata is returned. You can query up to 100 changes with one call.
- version
The version from which to begin the change history search.
- layer
The layer that contains the partition.
- partition
The partition to query the change history for.
- direction
Specifies the direction in which to lookup the history: forward or backward.
- returns
A Partition.Change object containing the partition size and checksum.
- Definition Classes
- CatalogLightProxy → CatalogLight
- Note
This method is scheduled to be deprecated in a future release. Only supported by the Datastore1 implementation.
- def querySingleChanges(versionStart: Version, versionEnd: Version, layer: Id, partitions: Set[Name]): Map[Key, Change]
Queries metadata for the selected partitions changed between given versions.
Queries metadata for the selected partitions changed between given versions.
This query is done directly in the Driver, and the metadata is returned. You can query up to 100 partitions with one call.
- versionStart
Query the partitions changed after this version.
- versionEnd
Query the changed partitions up to this version.
- layer
The layer that contains the partitions being queried.
- partitions
The partition names that should be queried.
- returns
The queried metadata, for partitions that have content in the catalog at the specified version. Partitions not present in the catalog at the specified version are not returned.
- Definition Classes
- CatalogLightProxy → CatalogLight
- Note
This method is only intended to be used internally, by the library. When implementing your compiler, you are encouraged to use Catalog.queryAll/Catalog.queryChanges instead, as these methods are implemented in a distributed way.
- def querySinglePartitions(version: Version, layer: Id, partitions: Set[Name]): Map[Key, Meta]
Queries metadata for the selected partitions.
Queries metadata for the selected partitions.
This query is done directly in the Driver, and the metadata is returned. You can query up to 100 partitions with one call.
- version
The version at which the catalog is queried for partitions.
- layer
The layer that contains the partitions being queried.
- partitions
The partition names that should be queried.
- returns
The queried metadata, for partitions that have content in the catalog at the specified version. Partitions not present in the catalog at the specified version are not returned.
- Definition Classes
- CatalogLightProxy → CatalogLight
- Note
This method is only intended to be used internally, by the library. When implementing your compiler, you are encouraged to use Catalog.queryAll/Catalog.queryChanges instead, as these methods are implemented in a distributed way.
- def retriever: Retriever
Exposes the Retriever for this catalog.
Exposes the Retriever for this catalog. The returned object can be captured in Spark functions and transmitted to worker nodes.
- Definition Classes
- CatalogLightProxy → CatalogLight
- def startCommit(baseVersion: BaseVersion, dependencies: Seq[Dependency]): CommitToken
Starts a new multipart commit on top of an existing version or an empty catalog.
Starts a new multipart commit on top of an existing version or an empty catalog.
- baseVersion
The current version of the catalog in the Data API. This information is required to prevent race conditions if the version is changed elsewhere, in another process, while we are preparing data for the commit. If the catalog is empty, use utils.EmptyCatalog.
- dependencies
The upstream dependencies for this commit.
- returns
A new multipart commit token representing the commit in progress.
- Definition Classes
- CatalogLightProxy → CatalogLight
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toSerializable: CatalogLight with Serializable
Returns a
CatalogLightfor this catalog that is guaranteed to be serializable.Returns a
CatalogLightfor this catalog that is guaranteed to be serializable.- Attributes
- protected[processing]
- Definition Classes
- CatalogLightProxy → CatalogLight
- def toString(): String
- Definition Classes
- AnyRef → Any
- def tokenFromString(s: String): CommitToken
Create a commit token for the catalog given its string representation.
Create a commit token for the catalog given its string representation.
- Definition Classes
- CatalogLightProxy → CatalogLight
- def tokenToString(t: CommitToken): String
Return the string representation of a commit token.
Return the string representation of a commit token.
- Definition Classes
- CatalogLightProxy → CatalogLight
- 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)