run_pipeline: Runs user-provided pipeline for each row of arguments in...

Description Usage Arguments Examples

View source: R/run_pipeline.R

Description

Runs user-provided pipeline for each row of arguments in parameters, converting any JSON strings to objects

Usage

1
run_pipeline(pipeline, parameters)

Arguments

pipeline

User-provided function with one argument, a dataframe

parameters

An dataframe of fields to convert to json

Examples

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
library(whisker)

run_pipeline(
  function(params){
   query <- "SELECT result FROM {{table_prefix}}_results;"
   whisker.render(query,params)
 },
 data.frame(
   table_prefix = c('batman', 'robin')
 )
)

condusco documentation built on May 2, 2019, 3:50 a.m.