trait FlinkWriteEngine extends AnyRef
- Alphabetic
- By Inheritance
- FlinkWriteEngine
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Abstract Value Members
- abstract def blobChecksum(layer: String, blob: BufferedBlob): Option[String]
Computes a blob's checksum based on its layer configuration.
Computes a blob's checksum based on its layer configuration.
The algorithm used is defined accordingly to the layer's configuration. If the layer doesn't have the respective field set, then scala.None is returned.
- layer
the layer that the specified blob is associated to.
- blob
the blob that will have its checksum computed.
- returns
a checksum or None if the layer's configuration field is not set.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def blobCrc(layer: String, blob: BufferedBlob): Option[String]
Computes a blob's crc based on its layer configuration.
Computes a blob's crc based on its layer configuration.
The algorithm used is defined accordingly to the layer's configuration. If the layer doesn't have the respective field set, then scala.None is returned.
- layer
the layer that the specified blob is associated to.
- blob
the blob that will have its crc computed.
- returns
a crc or None if the layer's configuration field is not set.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def copyObject(layerId: String, key: String, sourceKey: String): Unit
Copies object from one location to other
Copies object from one location to other
- layerId
the id of the layer
- key
the key of the destination object
- sourceKey
the key of the source object
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable errorjava.lang.UnsupportedOperationExceptionin case method called for non-objectstore layer
- abstract def deleteObject(layerId: String, key: String): Unit
Deletes the specified object from object store
Deletes the specified object from object store
- layerId
the id of the layer
- key
the key of the object to be deleted
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable errorjava.lang.UnsupportedOperationExceptionin case method called for non-objectstore layer
- abstract def publish(): SinkFunction[PendingPartition]
Publish new partitions to a catalog.
Publish new partitions to a catalog.
This method can be used to publish new partitions to stream layer.
- returns
a sink which all partitions are published 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 put(partition: PendingPartition): CommitPartition
Adds the selected partition to the underlying storage
Adds the selected partition to the underlying storage
- partition
the partition to add
- returns
a partition that could be committed
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def updateObjectTtl(layerId: String, key: String, ttlSeconds: Long): Unit
Updates the TTL for the object stored in Volatile Layer
Updates the TTL for the object stored in Volatile Layer
- layerId
the id of the layer
- key
the key of the target object
- ttlSeconds
new value of ttl for the object
- returns
future which completes when server update request is sent to server.
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable errorjava.lang.UnsupportedOperationExceptionin case method called for non-volatile layer
- abstract def uploadIMLFeatureCollection(layer: String, featureCollection: FeatureCollection, batchSize: Option[Int]): Unit
Upload a large FeatureCollection to the Interactive Map Layer
Upload a large FeatureCollection to the Interactive Map Layer
- layer
the id of the layer
- featureCollection
the FeatureCollection to upload
- batchSize
the number of features in an upload batch
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable error
- abstract def uploadObject2(layerId: String, key: String, blob: Blob, contentType: Option[String] = None, contentEncoding: Option[ContentEncoding] = None): Unit
Uploads the specified object to object store
Uploads the specified object to object store
- layerId
the id of the layer
- key
the key of the object to be uploaded
- blob
the blob of data that is to be uploaded
- Exceptions thrown
com.here.platform.data.client.DataClientNonRetriableExceptionin case of non-retriable errorcom.here.platform.data.client.DataClientRetriableExceptionin case of retriable errorjava.lang.UnsupportedOperationExceptionin case method called for non-objectstore layer
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)