Skip to content

Commit

Permalink
Adding applys to HadoopRasterCatalog
Browse files Browse the repository at this point in the history
  • Loading branch information
lossyrob committed Sep 22, 2015
1 parent 337165e commit 757ce6e
Showing 1 changed file with 10 additions and 1 deletion.
Expand Up @@ -44,9 +44,18 @@ object HadoopRasterCatalogConfig {


object HadoopRasterCatalog {
def apply(rootPath: String)(implicit sc: SparkContext): HadoopRasterCatalog =
apply(new Path(rootPath))

def apply(rootPath: String, catalogConfig: HadoopRasterCatalogConfig)(implicit sc: SparkContext): HadoopRasterCatalog =
apply(new Path(rootPath), catalogConfig)

def apply(rootPath: Path)(implicit sc: SparkContext): HadoopRasterCatalog =
apply(rootPath, HadoopRasterCatalogConfig.DEFAULT)

def apply(
rootPath: Path,
catalogConfig: HadoopRasterCatalogConfig = HadoopRasterCatalogConfig.DEFAULT)(implicit sc: SparkContext
catalogConfig: HadoopRasterCatalogConfig)(implicit sc: SparkContext
): HadoopRasterCatalog = {
HdfsUtils.ensurePathExists(rootPath, sc.hadoopConfiguration)
val attributeStore = new HadoopAttributeStore(sc.hadoopConfiguration, new Path(rootPath, "attributes"))
Expand Down

0 comments on commit 757ce6e

Please sign in to comment.