Publishes results to the distributed file system, or publishes the results location, or echoes strings as inputs to the subsequent nodes in the workflow.
rciop.publish (path="./", recursive=FALSE, metalink=FALSE, mode="", driver="")
path
recursive
metalink
mode
path
as inputs to the subsequent nodes in the workflow
this mode overrides the recursive
, metalink
and driver
optionsdriver
This function stages-out local files to the distributed filesystem or will define the inputs to be passed to the next nodes in the workflow.
List with:
res <- rciop.publish(paste(TMPDIR,"output", sep="/"), TRUE, FALSE)
if (res$exit.code==0) { published <- res$output }
for(i in 1:nrow(selected)) {
selected[i, "Rdf1"] <- subset(trace, trace$V1==selected[i, "Prm1"])$x
selected[i, "Rdf2"] <- subset(trace, trace$V1==selected[i, "Prm2"])$x
rciop.publish(as.character(paste(selected[i, c("Rdf1", "Rdf2")], collapse=",")), mode="silent")
}
Terradue