context in udf

context in udf

R/processes.R

@@ -900,14 +900,6 @@ run_udf <- Process$new(
         subtype = "string"
       )
     ),
-    Parameter$new(
-      name = "names",
-      description = "List of names to define outputs from a reducer UDF",
-      schema = list(
-        type = "string",
-        subtype = "string"
-      )
-    ),
     Parameter$new(
       name = "runtime",
       description = "A UDF runtime identifier available at the back-end.",
@@ -935,7 +927,7 @@ run_udf <- Process$new(
     description = "The computed result.",
     schema = list(type = c("number", "null"))
   ),
-  operation = function(data, udf, names = c("default"), runtime = "R", version = NULL, context = NULL, job) {
+  operation = function(data, udf, runtime = "R", version = NULL, context = NULL, job) {
     if (runtime != "R") {
       stop("Only R runtime is supported.")
     }
@@ -953,7 +945,7 @@ run_udf <- Process$new(
         user_function <- eval(func_parse)
         # reducer udf
         message("reducer function -> time")
-        data <- reduce_time(data, names = names, FUN = user_function)
+        data <- reduce_time(data, names = context, FUN = user_function)
         return(data)
       } else {
         # convert parsed string function to class function

README.md

@@ -223,7 +223,7 @@ change_detection = "function(x) {
   }"
 
 # run udf
-datacube_udf = p$run_udf(data = datacube_filtered, udf = change_detection, names =  c("change_date", "change_magnitude"))
+datacube_udf = p$run_udf(data = datacube_filtered, udf = change.detection, context =  c("change_date", "change_magnitude"))
 
 # supported formats
 formats = list_file_formats()
@@ -233,7 +233,7 @@ result = p$save_result(data = datacube_udf, format = formats$output$NetCDF)
 
 # Process and download data synchronously
 start.time <- Sys.time()
-compute_result(graph = result, output_file = "change_detection.nc")
+compute_result(graph = result, output_file = "detected_changes.nc")
 end.time <- Sys.time()
 time.taken <- end.time - start.time
 time.taken

examples/03-change-detection/R-Client-bfast-brandenburg.R

@@ -57,7 +57,7 @@ change.detection = 'function(x) {
   }'
 
 # run udf
-datacube_udf = p$run_udf(data = datacube_filtered, udf = change.detection, names =  c("change_date", "change_magnitude"))
+datacube_udf = p$run_udf(data = datacube_filtered, udf = change.detection, context = c("change_date", "change_magnitude"))
 
 # supported formats
 formats = list_file_formats()
@@ -67,7 +67,7 @@ result = p$save_result(data = datacube_udf, format = formats$output$NetCDF)
 
 # Process and download data synchronously
 start.time <- Sys.time()
-compute_result(graph = result, output_file = "change_detection.nc")
+compute_result(graph = result, output_file = "detected_changes.nc")
 end.time <- Sys.time()
 time.taken <- end.time - start.time
 time.taken