final case class CatalogViewSinceVersion(catalog: Catalog, version: Version, sinceVersion: Version) extends NonEmptyCatalogView with Product with Serializable
Provides a view on a specific version of a catalog, with a reference to a previous version of the catalog, with respect to which changes are defined.
- catalog
The catalog which is encapsulated by this view.
- version
The version of the catalog. Must be non-negative.
- sinceVersion
The version of the catalog with respect to which changes are calculated. Must be non-negative.
- Alphabetic
- By Inheritance
- CatalogViewSinceVersion
- Serializable
- Serializable
- Product
- Equals
- NonEmptyCatalogView
- CatalogView
- CatalogViewLight
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Instance Constructors
-
new
CatalogViewSinceVersion(catalog: Catalog, version: Version, sinceVersion: Version)
- catalog
The catalog which is encapsulated by this view.
- version
The version of the catalog. Must be non-negative.
- sinceVersion
The version of the catalog with respect to which changes are calculated. Must be non-negative.
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
-
val
catalog: Catalog
The catalog which is encapsulated by this view.
The catalog which is encapsulated by this view.
- Definition Classes
- CatalogViewSinceVersion → CatalogView → CatalogViewLight
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
def
empty(partitioner: Partitioner[Key] = catalog.defaultPartitioner): RDD[(Key, Meta)]
Creates a partitioned empty RDD of (Key, Meta) in compliance with other methods of this component.
Creates a partitioned empty RDD of (Key, Meta) in compliance with other methods of this component.
- partitioner
The com.here.platform.data.processing.spark.partitioner.Partitioner applied when constructing the RDD returned.
- returns
An empty RDD of (Partition.Key, Partition.Meta), which is partitioned according to the partitioner parameter.
- Definition Classes
- CatalogView
-
def
emptyChanges(partitioner: Partitioner[Key] = catalog.defaultPartitioner): RDD[(Key, Change)]
Creates a partitioned empty RDD of (Partition.Key, Partition.Change) in compliance with other methods of this component.
Creates a partitioned empty RDD of (Partition.Key, Partition.Change) in compliance with other methods of this component.
- partitioner
The com.here.platform.data.processing.spark.partitioner.Partitioner applied when constructing the RDD returned.
- returns
An empty RDD of (Partition.Key, Partition.Change), partitioned according to the partitioner parameter.
- Definition Classes
- CatalogView
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hasChanges(layers: Set[Id]): Boolean
Returns true if at least one of the given layers has changes between this and the previous version.
Returns true if at least one of the given layers has changes between this and the previous version.
- layers
The set of layers for which the changes should be queried.
-
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
- CatalogViewLight
-
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
- CatalogViewLight
- See also
Catalog.Id for more details.
-
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
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
def
queryAll(layers: Set[Id], partitioner: Partitioner[Key] = catalog.defaultPartitioner): RDD[(Key, Meta)]
Queries metadata of all the partitions in a given set of layers.
Queries metadata of all the partitions in a given set of layers.
Creates an RDD containing the queried metadata.
- layers
The set of layers for which the partitions should be queried.
- partitioner
The com.here.platform.data.processing.spark.partitioner.Partitioner applied when constructing the RDD returned.
- returns
The queried metadata in an RDD object partitioned according to the partitioner parameter.
- Definition Classes
- NonEmptyCatalogView
-
def
queryChanges(layers: Set[Id], partitioner: Partitioner[Key] = catalog.defaultPartitioner): RDD[(Key, Change)]
Queries metadata of all the partitions in a given set of layers changed.
Queries metadata of all the partitions in a given set of layers changed.
Creates an RDD containing the queries metadata.
- layers
The set of layers for which the partitions should be queried.
- partitioner
The com.here.platform.data.processing.spark.partitioner.Partitioner applied when constructing the RDD returned.
- returns
The queried metadata in an RDD object partitioned according to the partitioner parameter.
-
def
queryDependencies(): Seq[Dependency]
Queries the dependencies for the catalog.
Queries the dependencies for the catalog.
- returns
The dependencies of the catalog version.
- Definition Classes
- NonEmptyCatalogView
-
def
querySinglePartitions(layer: Id, partitions: Set[Name]): Map[Key, Meta]
Queries metadata for the selected partitions.
Queries metadata for the selected partitions.
You can query up to 100 partitions with one call.
- 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 version referenced by this catalog view. Partitions not present are not returned.
- Definition Classes
- NonEmptyCatalogView → CatalogViewLight
- Note
Querying large amounts of metadata using this function is expensive and should be avoided. Instead,
CatalogView.queryAll(...)should be used whenever possible.
-
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
- CatalogViewLight
- val sinceVersion: Version
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
val
version: Version
The catalog version which is encapsulated by this view.
The catalog version which is encapsulated by this view. Must be non-negative.
- Definition Classes
- CatalogViewSinceVersion → NonEmptyCatalogView
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()