trait FlinkWriteEngine extends AnyRef

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

Abstract Value Members

  1. 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.DataClientNonRetriableException in case of non-retriable error

    com.here.platform.data.client.DataClientRetriableException in case of retriable error

  2. 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.DataClientNonRetriableException in case of non-retriable error

    com.here.platform.data.client.DataClientRetriableException in case of retriable error

  3. 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.DataClientNonRetriableException in case of non-retriable error

    com.here.platform.data.client.DataClientRetriableException in case of retriable error

    java.lang.UnsupportedOperationException in case method called for non-objectstore layer

  4. 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.DataClientNonRetriableException in case of non-retriable error

    com.here.platform.data.client.DataClientRetriableException in case of retriable error

    java.lang.UnsupportedOperationException in case method called for non-objectstore layer

  5. 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.DataClientNonRetriableException in case of non-retriable error

    com.here.platform.data.client.DataClientRetriableException in case of retriable error

  6. 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.DataClientNonRetriableException in case of non-retriable error

    com.here.platform.data.client.DataClientRetriableException in case of retriable error

  7. 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.DataClientNonRetriableException in case of non-retriable error

    com.here.platform.data.client.DataClientRetriableException in case of retriable error

    java.lang.UnsupportedOperationException in case method called for non-volatile layer

  8. 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.DataClientNonRetriableException in case of non-retriable error

    com.here.platform.data.client.DataClientRetriableException in case of retriable error

  9. 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.DataClientNonRetriableException in case of non-retriable error

    com.here.platform.data.client.DataClientRetriableException in case of retriable error

    java.lang.UnsupportedOperationException in case method called for non-objectstore layer

Concrete 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. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  16. def toString(): String
    Definition Classes
    AnyRef → Any
  17. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  18. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  19. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... ) @native()

Inherited from AnyRef

Inherited from Any

Ungrouped