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.
- Alphabetic
- By Inheritance
- FullPublishingMode
- PublishingMode
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
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
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native() @IntrinsicCandidate()
-
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.
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @IntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
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
- FullPublishingMode → PublishingMode
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @IntrinsicCandidate()
-
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
- FullPublishingMode → PublishingMode
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
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()
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
Deprecated Value Members
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] ) @Deprecated
- Deprecated