Packages

class HadoopCOGLayerReader extends COGLayerReader[LayerId]

Handles reading raster RDDs and their metadata from HDFS.

Linear Supertypes
COGLayerReader[LayerId], Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. HadoopCOGLayerReader
  2. COGLayerReader
  3. Serializable
  4. Serializable
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new HadoopCOGLayerReader(attributeStore: AttributeStore, runtime: ⇒ IORuntime = IORuntimeTransient.IORuntime)(implicit sc: SparkContext)

    attributeStore

    AttributeStore that contains metadata for corresponding LayerId

Value Members

  1. val attributeStore: AttributeStore
    Definition Classes
    HadoopCOGLayerReader → COGLayerReader
  2. def baseReadAllBands[K, V <: CellGrid[Int]](id: LayerId, tileQuery: LayerQuery[K, TileLayerMetadata[K]], numPartitions: Int)(implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K], arg4: GeoTiffReader[V], arg5: ClassTag[V], sc: SparkContext, idToLayerId: (LayerId) ⇒ LayerId): RDD[(K, V)] with Metadata[TileLayerMetadata[K]]
    Definition Classes
    COGLayerReader
  3. def baseReadSubsetBands[K](id: LayerId, targetBands: Seq[Int], tileQuery: LayerQuery[K, TileLayerMetadata[K]], numPartitions: Int)(implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K], sc: SparkContext, idToLayerId: (LayerId) ⇒ LayerId): RDD[(K, Array[Option[Tile]])] with Metadata[TileLayerMetadata[K]]
    Definition Classes
    COGLayerReader
  4. val defaultNumPartitions: Int
    Definition Classes
    HadoopCOGLayerReader → COGLayerReader
  5. def fullPath(path: String): URI
    Definition Classes
    HadoopCOGLayerReader → COGLayerReader
  6. def getHeader(id: LayerId): HadoopLayerHeader
    Definition Classes
    HadoopCOGLayerReader → COGLayerReader
  7. val hadoopConfiguration: SerializableConfiguration
  8. implicit lazy val ioRuntime: IORuntime
    Definition Classes
    HadoopCOGLayerReader → COGLayerReader
    Annotations
    @transient()
  9. def pathExists(path: String): Boolean
    Definition Classes
    HadoopCOGLayerReader → COGLayerReader
  10. def produceGetKeyPath(id: LayerId): (ZoomRange, Int) ⇒ (BigInt) ⇒ String
    Definition Classes
    HadoopCOGLayerReader → COGLayerReader
  11. def query[K, V <: CellGrid[Int]](layerId: LayerId, numPartitions: Int)(implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K], arg4: GeoTiffReader[V], arg5: ClassTag[V]): BoundLayerQuery[K, TileLayerMetadata[K], RDD[(K, V)] with Metadata[TileLayerMetadata[K]]]
    Definition Classes
    COGLayerReader
  12. def query[K, V <: CellGrid[Int]](layerId: LayerId)(implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K], arg4: GeoTiffReader[V], arg5: ClassTag[V]): BoundLayerQuery[K, TileLayerMetadata[K], RDD[(K, V)] with Metadata[TileLayerMetadata[K]]]
    Definition Classes
    COGLayerReader
  13. def querySubsetBands[K](layerId: LayerId, targetBands: Seq[Int], numPartitions: Int)(implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K]): BoundLayerQuery[K, TileLayerMetadata[K], RDD[(K, Array[Option[Tile]])] with Metadata[TileLayerMetadata[K]]]
    Definition Classes
    COGLayerReader
  14. def querySubsetBands[K](layerId: LayerId, targetBands: Seq[Int])(implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K]): BoundLayerQuery[K, TileLayerMetadata[K], RDD[(K, Array[Option[Tile]])] with Metadata[TileLayerMetadata[K]]]
    Definition Classes
    COGLayerReader
  15. def read[K, V <: CellGrid[Int]](id: LayerId, tileQuery: LayerQuery[K, TileLayerMetadata[K]], numPartitions: Int)(implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K], arg4: GeoTiffReader[V], arg5: ClassTag[V]): RDD[(K, V)] with Metadata[TileLayerMetadata[K]]

    read

    read

    This function will read an RDD layer based on a query.

    K

    Type of RDD Key (ex: SpatialKey)

    V

    Type of RDD Value (ex: Tile or MultibandTile )

    id

    The ID of the layer to be read

    numPartitions

    The desired number of partitions in the resulting RDD.

    Definition Classes
    HadoopCOGLayerReader → COGLayerReader
  16. def read[K, V <: CellGrid[Int]](id: LayerId)(implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K], arg4: GeoTiffReader[V], arg5: ClassTag[V]): RDD[(K, V)] with Metadata[TileLayerMetadata[K]]
    Definition Classes
    COGLayerReader
  17. def read[K, V <: CellGrid[Int]](id: LayerId, numPartitions: Int)(implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K], arg4: GeoTiffReader[V], arg5: ClassTag[V]): RDD[(K, V)] with Metadata[TileLayerMetadata[K]]
    Definition Classes
    COGLayerReader
  18. def read[K, V <: CellGrid[Int]](id: LayerId, rasterQuery: LayerQuery[K, TileLayerMetadata[K]])(implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K], arg4: GeoTiffReader[V], arg5: ClassTag[V]): RDD[(K, V)] with Metadata[TileLayerMetadata[K]]
    Definition Classes
    COGLayerReader
  19. def readSubsetBands[K](id: LayerId, targetBands: Seq[Int], rasterQuery: LayerQuery[K, TileLayerMetadata[K]], numPartitions: Int)(implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K]): RDD[(K, Array[Option[Tile]])] with Metadata[TileLayerMetadata[K]]

    This method will read in an RDD layer whose value will only contain the desired bands in their given order.

    This method will read in an RDD layer whose value will only contain the desired bands in their given order. This value is represented as an: Array[Option[Tile]]. Where Some(tile) represents a single band and None represents a band that could not be accessed.

    K

    Type of RDD Key (ex: SpatialKey)

    id

    The ID of the layer to be read

    targetBands

    The desired set of bands the output layer should have.

    rasterQuery

    The query that will specify the filter for this read.

    numPartitions

    The desired number of partitions in the resulting RDD.

    Definition Classes
    HadoopCOGLayerReader → COGLayerReader
  20. def readSubsetBands[K](id: LayerId, targetBands: Seq[Int])(implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K]): RDD[(K, Array[Option[Tile]])] with Metadata[TileLayerMetadata[K]]
    Definition Classes
    COGLayerReader
  21. def readSubsetBands[K](id: LayerId, targetBands: Seq[Int], numPartitions: Int)(implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K]): RDD[(K, Array[Option[Tile]])] with Metadata[TileLayerMetadata[K]]
    Definition Classes
    COGLayerReader
  22. def readSubsetBands[K](id: LayerId, targetBands: Seq[Int], rasterQuery: LayerQuery[K, TileLayerMetadata[K]])(implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K]): RDD[(K, Array[Option[Tile]])] with Metadata[TileLayerMetadata[K]]
    Definition Classes
    COGLayerReader
  23. def reader[K, V <: CellGrid[Int]](implicit arg0: SpatialComponent[K], arg1: Boundable[K], arg2: Decoder[K], arg3: ClassTag[K], arg4: GeoTiffReader[V], arg5: ClassTag[V]): Reader[LayerId, RDD[(K, V)] with Metadata[TileLayerMetadata[K]]]
    Definition Classes
    COGLayerReader
  24. implicit val sc: SparkContext