c

geotrellis.spark.store.hadoop

SaveToHadoopMethods

class SaveToHadoopMethods[K, V] extends AnyRef

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

Instance Constructors

  1. new SaveToHadoopMethods(rdd: RDD[(K, V)])

Value Members

  1. def saveToHadoop(keyToUri: (K) ⇒ String)(getBytes: (K, V) ⇒ Array[Byte]): Long

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

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

    keyToUri

    maps each key to full hadoop supported path

    getBytes

    K and V both provided in case K contains required information, like extent.

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

    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

    maps each key to full hadoop supported path

    getBytes

    K and V both provided in case K contains required information, like extent.