trait FlinkPublishApi extends AnyRef
- Alphabetic
- By Inheritance
- FlinkPublishApi
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def cancelBatch(token: BatchToken): Unit
Cancels a batch operation.
Cancels a batch operation.
Cancels an active batch and signals that submitted batch publications can be discarded. The token will no longer be valid after cancel batch operation.
- token
Token retrieved from a function com.here.platform.data.client.flink.scaladsl.FlinkPublishApi.startBatch2.
- returns
batch is fully cancelled by the server.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def completeBatch(token: BatchToken): Unit
Finalizes the batch and waits until the metadata has been processed.
Finalizes the batch and waits until the metadata has been processed.
- token
Token retrieved from a function com.here.platform.data.client.flink.scaladsl.FlinkPublishApi.startBatch2.
- returns
publication is fully processed by server and new version is published to catalog or when the processing failed.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def deleteFeatures(layer: String, ids: Seq[String]): FeatureCollection
Deletes specified features from Interactive Map layer.
Deletes specified features from Interactive Map layer.
- layer
Name of interactive Map layer. If the layer specified in request does not exist, an error is returned.
- ids
List of feature IDs to be deleted
- returns
Future which completes when specified featureCollection is uploaded.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def deleteIndex(layer: String, queryString: String): String
Deletes the partitions from index layer that match the provided query written in the RSQL query language.
Deletes the partitions from index layer that match the provided query written in the RSQL query language.
- layer
Name of the index layer. If the layer specified in request does not exist, an error is returned.
- queryString
String written in the RSQL query language to query the index layer
- returns
Delete request id which can be used to query the delete status.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def getBaseVersion(): Option[Long]
Get latest version available for the given catalog which can be used in com.here.platform.data.client.flink.scaladsl.FlinkPublishApi.startBatch2.
Get latest version available for the given catalog which can be used in com.here.platform.data.client.flink.scaladsl.FlinkPublishApi.startBatch2.
- returns
Returns Some(version) - latest version for the given catalog. If the catalog doesn't contain any versions None will be returned.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def patchFeature(layer: String, feature: Feature, featureId: String): Feature
Patch specified feature in Interactive Map layer.
Patch specified feature in Interactive Map layer.
- layer
Name of interactive Map layer. If the layer specified in request does not exist, an error is returned.
- feature
The feature to put in Interactive Map layer.
- featureId
The feature ID of the feature.
- returns
Future which completes when specified feature is patched.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def patchFeatureJson(layer: String, feature: String, featureId: String): String
Patch specified feature in Interactive Map layer.
Patch specified feature in Interactive Map layer.
- layer
Name of interactive Map layer. If the layer specified in request does not exist, an error is returned.
- feature
The feature to put in Interactive Map layer.
- featureId
The feature ID of the feature.
- returns
Future which completes when specified feature is patched.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def postFeatureCollection(layer: String, featureCollection: FeatureCollection, ifExist: Option[IfExistType] = Some(IfExistType.PATCH), ifNotExist: Option[IfNotExistType] = Some(IfNotExistType.CREATE), transactional: Boolean = true): FeatureCollection
Uploads specified FeatureCollection to Interactive Map layer.
Uploads specified FeatureCollection to Interactive Map layer.
- layer
Name of interactive Map layer. If the layer specified in request does not exist, an error is returned.
- featureCollection
The FeatureCollection to put in Interactive Map layer.
- ifExist
The action to execute, when a feature with the provided ID exists. Default is PATCH.
- ifNotExist
The action to execute, when a feature with the provided ID does not exist or the feature contains no ID. Default is CREATE.
- transactional
Defines, if this is a transactional operation. Default is true.
- returns
Future which completes when specified featureCollection is uploaded.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def postFeatureCollectionJson(layer: String, featureCollection: String, ifExist: Option[IfExistType] = Some(IfExistType.PATCH), ifNotExist: Option[IfNotExistType] = Some(IfNotExistType.CREATE), transactional: Boolean = true): String
Uploads specified FeatureCollection to Interactive Map layer.
Uploads specified FeatureCollection to Interactive Map layer.
- layer
Name of interactive Map layer. If the layer specified in request does not exist, an error is returned.
- featureCollection
The FeatureCollection to put in Interactive Map layer.
- ifExist
The action to execute, when a feature with the provided ID exists. Default is PATCH.
- ifNotExist
The action to execute, when a feature with the provided ID does not exist or the feature contains no ID. Default is CREATE.
- transactional
Defines, if this is a transactional operation. Default is true.
- returns
Future which completes when specified featureCollection is uploaded.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def postFeatureModifications(layer: String, featureModificationList: FeatureModificationList, transactional: Boolean = true): FeatureCollection
Uploads FeatureCollection(s) specified in FeatureModificationList to Interactive Map layer.
Uploads FeatureCollection(s) specified in FeatureModificationList to Interactive Map layer.
- layer
Name of interactive Map layer. If the layer specified in request does not exist, an error is returned.
- featureModificationList
The FeatureModificationList which contains list of features that need to get created/updated/deleted in Interactive Map layer.
- transactional
Defines, if this is a transactional operation. Default is true.
- returns
Future which completes when specified FeatureCollection(s) are uploaded.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def postFeatureModificationsJson(layer: String, featureModificationList: String, transactional: Boolean = true): String
Uploads FeatureCollection(s) specified in FeatureModificationList to Interactive Map layer.
Uploads FeatureCollection(s) specified in FeatureModificationList to Interactive Map layer.
- layer
Name of interactive Map layer. If the layer specified in request does not exist, an error is returned.
- featureModificationList
The FeatureModificationList which contains list of features that need to get created/updated/deleted in Interactive Map layer.
- transactional
Defines, if this is a transactional operation. Default is true.
- returns
Future which completes when specified FeatureCollection(s) are uploaded.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def publishBatch2(baseVersion: Option[Long], layerIds: Option[Seq[String]], dependencies: Seq[VersionDependency], partitions: Iterator[CommitPartition]): Unit
Performs new batch publication to a catalog.
Performs new batch publication to a catalog.
This call is identical to com.here.platform.data.client.flink.scaladsl.FlinkPublishApi.startBatch2 + com.here.platform.data.client.flink.scaladsl.FlinkPublishApi.publishToBatch(token:com\.here\.platform\.data\.client\.model\.BatchToken,partitions:Iterator* + com.here.platform.data.client.flink.scaladsl.FlinkPublishApi.completeBatch.
Please note that there can only be one active publication at a time per versioned layer.- baseVersion
This parameter is deprecated and not used anymore.
- layerIds
List of layer ids which should be updated. Note: Publishing versioned and volatile layer partitions in the same publication is not advisable as in this case it increases version number even for volatile layers.
- dependencies
List of the dependencies for this publication. This is only relevant for publishing to versioned layer.
- partitions
partitions to publish.
- returns
publication is fully processed by server and new version is published to catalog.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def publishIndex(layer: String, partitions: Iterator[CommitPartition]): Unit
Performs indexing of the specified partitions in Index layer.
Performs indexing of the specified partitions in Index layer.
The partitions are indexed using the specified index keys defined in each indexing partition. After indexing the partitions can be searched by keys using query method from Query API.
- layer
Name of index layer. If the layer specified in request does not exist, an error is returned.
- partitions
The partitions to index.
- returns
Future which completes when specified partitions are indexed.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def publishToBatch(token: BatchToken, partitions: Iterator[CommitPartition]): Unit
Upload partitions for given commit token.
Upload partitions for given commit token.
- token
Token retrieved from a function com.here.platform.data.client.flink.scaladsl.FlinkPublishApi.startBatch2.
- partitions
partitions to upload.
- returns
future which completes when all partitions are uploaded to server.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def putFeature(layer: String, feature: Feature, featureId: String): Feature
Uploads specified feature to Interactive Map layer.
Uploads specified feature to Interactive Map layer.
- layer
Name of interactive Map layer. If the layer specified in request does not exist, an error is returned.
- feature
The feature to put in Interactive Map layer.
- featureId
The feature ID of the feature.
- returns
Future which completes when specified feature is uploaded.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def putFeatureCollection(layer: String, featureCollection: FeatureCollection): FeatureCollection
Uploads specified FeatureCollection to Interactive Map layer.
Uploads specified FeatureCollection to Interactive Map layer.
- layer
Name of interactive Map layer. If the layer specified in request does not exist, an error is returned.
- featureCollection
The FeatureCollection to put in Interactive Map layer.
- returns
Future which completes when specified featureCollection is uploaded.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def putFeatureCollectionJson(layer: String, featureCollection: String): String
Uploads specified FeatureCollection to Interactive Map layer.
Uploads specified FeatureCollection to Interactive Map layer.
- layer
Name of interactive Map layer. If the layer specified in request does not exist, an error is returned.
- featureCollection
The FeatureCollection to put in Interactive Map layer.
- returns
Future which completes when specified featureCollection is uploaded.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def putFeatureJson(layer: String, feature: String, featureId: String): String
Uploads specified feature to Interactive Map layer.
Uploads specified feature to Interactive Map layer.
- layer
Name of interactive Map layer. If the layer specified in request does not exist, an error is returned.
- feature
The feature to put in Interactive Map layer.
- featureId
The feature ID of the feature.
- returns
Future which completes when specified feature is uploaded.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def startBatch2(baseVersion: Option[Long], layerIds: Option[Seq[String]], dependencies: Seq[VersionDependency] = Seq.empty): BatchToken
Starts a new batch for a catalog with layers explicitly named.
Starts a new batch for a catalog with layers explicitly named.
This call is used to start a new publishing to a catalog. The layers must be named explicitly. The returned token is valid for 24 hours.
Please note that there can only be one active publication at a time per versioned layer.- baseVersion
This parameter is deprecated and not used anymore.
- layerIds
List of layer ids which should be updated. Note: Publishing versioned and volatile layer partitions in the same publication is not advisable as in this case it increases version number even for volatile layers.
- dependencies
List of the dependencies for this publication. This is only relevant for publishing to versioned layer.
- returns
The token to use in subsequent calls that are part of the same publication (e.g.com.here.platform.data.client.flink.scaladsl.FlinkPublishApi.publishToBatch(token:com\.here\.platform\.data\.client\.model\.BatchToken,partitions:Iterator*).
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def updateIndex(layer: String, additions: Iterator[CommitPartition], removals: Iterator[CommitPartition]): Unit
Updates an index layer by adding the
additionspartitions and removingremovalspartitions.Updates an index layer by adding the
additionspartitions and removingremovalspartitions.- layer
Name of the index layer. If the layer specified in request does not exist, an error is returned.
- additions
The partitions to add to the index.
- removals
The partitions to remove from the index.
- returns
passed addition partitions are added and removal partitions are removed.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
Concrete 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(classOf[java.lang.CloneNotSupportedException]) @IntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @IntrinsicCandidate() @native()
- 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()
- 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(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)