Packages

c

com.here.platform.data.processing.validation.Transformations

MultiPartBaseAggregateTransformation

implicit class MultiPartBaseAggregateTransformation[K <: Name] extends AnyRef

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MultiPartBaseAggregateTransformation
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new MultiPartBaseAggregateTransformation(deltaSets: Map[Int, DeltaSet[K, Map[Id, Payload]]])(implicit arg0: Ordering[K], arg1: ClassTag[K])

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( ... ) @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  8. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  9. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  13. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  14. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  15. def publishAndAggregate(outLayers: Set[Id], metricsLayer: Id, mapper: PublishedPartMapper, parts: Seq[Int], ancestorFn: (K) ⇒ K, aggregateNamespace: Id = "aggregateMetrics")(implicit deltaContext: DeltaContext, metricsSerializer: Serializer[Metrics], metricsDeserializer: Deserializer[Metrics]): (PublishedSet, DeltaSet[Key, Metrics])

    Publishes the reports and metrics encoded in a map of com.here.platform.data.processing.driver.deltasets.DeltaSets indexed by part number, with respect to a user provided com.here.platform.data.processing.driver.deltasets.PublishedPartMapper, and recursively aggregates the metrics using the same com.here.platform.data.processing.driver.deltasets.PublishedPartMapper.

    Publishes the reports and metrics encoded in a map of com.here.platform.data.processing.driver.deltasets.DeltaSets indexed by part number, with respect to a user provided com.here.platform.data.processing.driver.deltasets.PublishedPartMapper, and recursively aggregates the metrics using the same com.here.platform.data.processing.driver.deltasets.PublishedPartMapper.

    outLayers

    All output layers, including the suite report layers and the metrics layer.

    metricsLayer

    The metrics layer.

    mapper

    The com.here.platform.data.processing.driver.deltasets.PublishedPartMapper to map each partition to its corresponding aggregation level part.

    parts

    The sequence of part numbers, starting from the lowest level part, that this deltaset belongs to, up to a fully aggregated single partition.

    ancestorFn

    Function that given a partition name returns its ancestor, that is the partition name of the corresponding aggregated partition.

    aggregateNamespace

    Deltaset namespace used in the aggregation transformations.

    deltaContext

    The deltaset context.

    metricsSerializer

    The Metrics Serialization.Serializer.

    metricsDeserializer

    The Metrics Serialization.Deserializer.

    returns

    a tuple containing the published set and a deltaset containing the fully aggregated metrics partition.

  16. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  17. def toString(): String
    Definition Classes
    AnyRef → Any
  18. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  19. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  20. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped