Packages

c

geotrellis.store

AsyncWriter

abstract class AsyncWriter[Client, V, E] extends Serializable

Linear Supertypes
Serializable, Serializable, AnyRef, Any
Known Subclasses
S3COGAsyncWriter
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. AsyncWriter
  2. Serializable
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new AsyncWriter(runtime: ⇒ IORuntime = IORuntimeTransient.IORuntime)

Abstract Value Members

  1. abstract def encodeRecord(key: String, value: V): E
  2. abstract def readRecord(client: Client, key: String): Try[V]
  3. abstract def writeRecord(client: Client, key: String, encoded: E): Try[Long]

Concrete Value Members

  1. def write(client: Client, partition: Iterator[(String, V)], mergeFunc: Option[(V, V) ⇒ V] = None, retryFunc: Option[(Throwable) ⇒ Boolean]): Unit