File tree Expand file tree Collapse file tree 1 file changed +2
-6
lines changed
core/src/test/scala/org/locationtech/rasterframes Expand file tree Collapse file tree 1 file changed +2
-6
lines changed Original file line number Diff line number Diff line change @@ -43,22 +43,18 @@ class RasterJoinSpec extends TestEnvironment with TestData with RasterMatchers {
4343 .withColumnRenamed(" tile" , " tile2" )
4444
4545 it(" should join the same scene correctly" ) {
46-
47- // spark.conf.set("spark.sql.adaptive.enabled", true)
48- // spark.conf.set("spark.sql.optimizer.nestedSchemaPruning.enabled", false)
49-
5046 val b4nativeRfPrime = b4nativeTif.toDF(Dimensions (10 , 10 ))
5147 .withColumnRenamed(" tile" , " tile2" )
5248 val joined = b4nativeRf.rasterJoin(b4nativeRfPrime.hint(" broadcast" ))
5349
5450 joined.count() should be (b4nativeRf.count())
5551
56- /* val measure = joined.select(
52+ val measure = joined.select(
5753 rf_tile_mean(rf_local_subtract($" tile" , $" tile2" )) as " diff_mean" ,
5854 rf_tile_stats(rf_local_subtract($" tile" , $" tile2" )).getField(" variance" ) as " diff_var" )
5955 .as[(Double , Double )]
6056 .collect()
61- all (measure) should be ((0.0, 0.0))*/
57+ all (measure) should be ((0.0 , 0.0 ))
6258 }
6359
6460 it(" should join same scene in different tile sizes" ){
You can’t perform that action at this time.
0 commit comments