Packages

object FullPublishingMode extends PublishingMode

Publishes the candidates interpreting them as a new complete snapshot of the catalog. This removes all the data in the catalog that is not included in the candidates.

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

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() @IntrinsicCandidate()
  6. final def correlate(current: RDD[(Key, Meta)], candidates: RDD[(Key, Option[Payload])], baseChanges: Option[RDD[(Key, Change)]], digests: Map[Id, Digest], statistics: Option[Map[Id, PublisherStats]] = None): RDD[(Key, NonEmptyPublishingAction)]

    Correlates metadata of what is already published in the output catalog with candidate com.here.platform.data.processing.blobstore.Payloads to be published, discard data that hasn't changed and return what has to be uploaded or deleted.

    Correlates metadata of what is already published in the output catalog with candidate com.here.platform.data.processing.blobstore.Payloads to be published, discard data that hasn't changed and return what has to be uploaded or deleted.

    current

    Metadata currently published in the output catalog.

    candidates

    Candidate payloads.

    baseChanges

    Metadata changes inherited from the base catalog.

    digests

    Digest objects to compute the checksum of the payloads based on the layer.

    statistics

    Statistic per layer to be updated.

    returns

    The publishing actions.

    Definition Classes
    PublishingMode
    See also

    com.here.platform.data.processing.publisher.PublishingAction.

  7. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  8. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  9. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  10. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native() @IntrinsicCandidate()
  11. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  12. def join(candidates: RDD[(Key, Option[DigestedPayload])], current: RDD[(Key, Meta)]): RDD[(Key, (Candidate, Option[Meta]))]

    Joins the candidate data and the current data.

    Joins the candidate data and the current data.

    candidates

    Candidate payloads.

    current

    Metadata currently published in the output catalog.

    returns

    joined data.

    Attributes
    protected
    Definition Classes
    FullPublishingModePublishingMode
  13. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  14. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  15. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @IntrinsicCandidate()
  16. def rebaseJoin(candidates: RDD[(Key, Option[DigestedPayload])], current: RDD[(Key, Meta)], baseChanges: RDD[(Key, Change)]): RDD[(Key, (Candidate, Option[Meta], Option[Change]))]

    Joins the candidate data, the current data and the base changes in case of rebase scenarios.

    Joins the candidate data, the current data and the base changes in case of rebase scenarios.

    candidates

    Candidate payloads.

    current

    Metadata currently published in the output catalog.

    baseChanges

    Metadata changes inherited from the base catalog.

    returns

    joined data.

    Attributes
    protected
    Definition Classes
    FullPublishingModePublishingMode
  17. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  18. def toString(): String
    Definition Classes
    AnyRef → Any
  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()
  21. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

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

Inherited from PublishingMode

Inherited from AnyRef

Inherited from Any

Ungrouped