c

geotrellis.spark.store.hadoop

SaveBytesToHadoopMethods

class SaveBytesToHadoopMethods[K] extends AnyRef

Linear Supertypes
AnyRef, Any
Known Subclasses
withSaveBytesToHadoopMethods
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. SaveBytesToHadoopMethods
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new SaveBytesToHadoopMethods(rdd: RDD[(K, Array[Byte])])

Value Members

  1. def saveToHadoop(keyToUri: (K) ⇒ String): Long

    Saves to Hadoop FileSystem, returns a count of records saved.

    Saves to Hadoop FileSystem, returns a count of records saved.

    keyToUri

    A function from K (a key) to a Hadoop URI

  2. def setupSaveToHadoop(keyToUri: (K) ⇒ String): RDD[(K, Array[Byte])]

    Sets up saving to Hadoop, but returns an RDD so that writes can be chained.

    Sets up saving to Hadoop, but returns an RDD so that writes can be chained.

    keyToUri

    A function from K (a key) to a Hadoop URI