Packages

c

geotrellis.spark.store.s3.cog

S3COGAsyncWriter

class S3COGAsyncWriter[V <: CellGrid[Int]] extends AsyncWriter[S3Client, GeoTiff[V], (PutObjectRequest, RequestBody)]

Linear Supertypes
AsyncWriter[S3Client, GeoTiff[V], (PutObjectRequest, RequestBody)], Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. S3COGAsyncWriter
  2. AsyncWriter
  3. Serializable
  4. Serializable
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new S3COGAsyncWriter(bucket: String, putObjectModifier: (PutObjectRequest) ⇒ PutObjectRequest, runtime: ⇒ IORuntime = IORuntimeTransient.IORuntime)(implicit arg0: GeoTiffReader[V])

Value Members

  1. def encodeRecord(key: String, value: GeoTiff[V]): (PutObjectRequest, RequestBody)
    Definition Classes
    S3COGAsyncWriter → AsyncWriter
  2. def readRecord(client: S3Client, key: String): Try[GeoTiff[V]]
    Definition Classes
    S3COGAsyncWriter → AsyncWriter
  3. def write(client: S3Client, partition: Iterator[(String, GeoTiff[V])], mergeFunc: Option[(GeoTiff[V], GeoTiff[V]) ⇒ GeoTiff[V]] = None, retryFunc: Option[(Throwable) ⇒ Boolean]): Unit
    Definition Classes
    AsyncWriter
  4. def writeRecord(client: S3Client, key: String, encodedRequest: (PutObjectRequest, RequestBody)): Try[Long]
    Definition Classes
    S3COGAsyncWriter → AsyncWriter