This is an automated email from the ASF dual-hosted git repository. jiayu pushed a commit to branch fix-lonlat-order in repository https://gitbox.apache.org/repos/asf/sedona.git
commit ae1662a5c841963216abee54973d663f77f3e7b5 Author: Jia Yu <[email protected]> AuthorDate: Tue Aug 8 01:47:40 2023 -0700 Remove calling storage level --- R/R/data_interface.R | 22 ---------------------- 1 file changed, 22 deletions(-) diff --git a/R/R/data_interface.R b/R/R/data_interface.R index a7cbfdfa..0504a39e 100644 --- a/R/R/data_interface.R +++ b/R/R/data_interface.R @@ -147,7 +147,6 @@ sedona_read_dsv_to_typed_rdd <- function(sc, max(as.integer(repartition %||% 1L), 1L), fmt ) %>% - set_storage_level(storage_level) %>% new_spatial_rdd(type) } @@ -211,7 +210,6 @@ sedona_read_shapefile_to_typed_rdd <- function(sc, java_context(sc), location ) %>% - set_storage_level(storage_level) %>% new_spatial_rdd(type) } @@ -240,7 +238,6 @@ sedona_read_geojson_to_typed_rdd <- function(sc, has_non_spatial_attrs, max(as.integer(repartition %||% 1L), 1L) ) %>% - set_storage_level(storage_level) %>% new_spatial_rdd(type) } @@ -305,7 +302,6 @@ sedona_read_geojson <- function(sc, allow_invalid_geometries, skip_syntactically_invalid_geometries ) %>% - set_storage_level(storage_level) %>% new_spatial_rdd(NULL) } @@ -335,7 +331,6 @@ sedona_read_wkb <- function(sc, allow_invalid_geometries, skip_syntactically_invalid_geometries ) %>% - set_storage_level(storage_level) %>% new_spatial_rdd(NULL) } @@ -365,7 +360,6 @@ sedona_read_wkt <- function(sc, allow_invalid_geometries, skip_syntactically_invalid_geometries ) %>% - set_storage_level(storage_level) %>% new_spatial_rdd(NULL) } @@ -381,7 +375,6 @@ sedona_read_shapefile <- function(sc, java_context(sc), location ) %>% - set_storage_level(storage_level) %>% new_spatial_rdd(NULL) } @@ -800,18 +793,3 @@ to_delimiter_enum_value <- function(sc, delimiter) { sc$state$enums$delimiter[[delimiter]] } - -set_storage_level <- function(rdd, storage_level) { - sc <- spark_connection(rdd) - storage_level <- sc$state$object_cache$storage_levels[[storage_level]] %||% { - storage_level_obj <- invoke_static( - sc, "org.apache.spark.storage.StorageLevel", storage_level - ) - sc$state$object_cache$storage_levels[[storage_level]] <- storage_level_obj - - storage_level_obj - } - invoke(rdd, "analyze", storage_level) - - rdd -}
