Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- #setup, prepare data source
- connStr <- "Driver=SQL Server;Server=.;Database=RevoTestDB;Trusted_Connection=TRUE"
- sqlcc <- RxInSqlServer(connectionString = connStr,wait = TRUE, consoleOutput = TRUE)
- sqlQuery = 'SELECT top 100 * from AirDemoSmallTest'
- SampleData = RxSqlServerData(sqlQuery = sqlQuery,
- connectionString = connStr,
- rowsPerRead=50000)
- #set compute context
- rxSetComputeContext(sqlcc)
- constant <- 10
- xform <- function(dataList){
- dataList$newCol <- dataList$ArrDelay * dataList$CRSDepTime * constant
- return (dataList)
- }
- res <- rxDataStep(inData = SeasonIndexes, overwrite = TRUE,
- transformObjects = list(constant = constant),
- transformFunc = xform
- )
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement