Skip to content

Commit

Permalink
Updated Sample ETL program to compile
Browse files Browse the repository at this point in the history
  • Loading branch information
metasim committed Oct 14, 2016
1 parent 40a2f7a commit ac98ba7
Showing 1 changed file with 5 additions and 7 deletions.
12 changes: 5 additions & 7 deletions docs/spark-etl/spark-etl-intro.md
Original file line number Diff line number Diff line change
Expand Up @@ -20,23 +20,21 @@ This affords an opportunity to modify the dataset using any of the GeoTrellis op
import geotrellis.raster.Tile
import geotrellis.spark._
import geotrellis.spark.etl.Etl
import geotrellis.spark.io.index.ZCurveKeyIndexMethod
import geotrellis.spark.etl.config.EtlConf
import geotrellis.spark.util.SparkUtils
import geotrellis.vector.ProjectedExtent

import org.apache.spark.SparkConf

object GeoTrellisETL {
type I = ProjectedExtent // or TemporalProjectedExtent for temporal ingest
type K = SpatialKey // or SpaceTimeKey for temporal ingest
type V = Tile // or MultibandTile to ingest multiband tile
def main(args: Array[String]): Unit = {
implicit val sc = SparkUtils.createSparkContext("GeoTrellis ETL", new SparkConf(true))
type I = ProjectedExtent // or TemporalProjectedExtent for temporal ingest
type K = SpatialKey // or SpaceTimeKey for temporal ingest
type V = Tile // or MultibandTile to ingest multiband tile

try {
EtlConf(args) foreach { conf =>
/* parse command line arguments */
val etl = Etl(conf, modules)
val etl = Etl(conf)
/* load source tiles using input module specified */
val sourceTiles = etl.load[I, V]
/* perform the reprojection and mosaicing step to fit tiles to LayoutScheme specified */
Expand Down

0 comments on commit ac98ba7

Please sign in to comment.