ECLDistribute: Creates an ECL "DISTRIBUTE" definition.

In rHpcc: Interface between HPCC and R

Description

Creates an ECL "DISTRIBUTE" definition. The DISTRIBUTE function re-distributes records from the recordset across all the nodes of the cluster

Examples

  ## Not run: 
    ecl1 <- ECL$new(hostName="127.0.0.1", port="8008")
    recPerson <- ECLRecord$new(name="rec_person")
    recPerson$addField("STRING", "code")
    recPerson$addField("STRING", "firstName")
    recPerson$addField("STRING", "lastName")
    recPerson$addField("STRING", "address")
    recPerson$addField("STRING", "stateCode")
    recPerson$addField("STRING", "city")
    recPerson$addField("STRING", "zip")
    ecl1$add(recPerson)
      
    condition <- "SKEW(0.1)"
    distribute <- ECLDistribute$new(inECLRecord=recPerson, condition=condition)
    ecl1$add(distribute)
    ecl1$print()
   
## End(Not run)

Example output

Loading required package: RCurl
Loading required package: bitops
Loading required package: XML
[1] " rec_person  := RECORD   STRING  code ; STRING  firstName ; STRING  lastName ; STRING  address ; STRING  stateCode ; STRING  city ; STRING  zip ;  END; DISTRIBUTE(  rec_person , SKEW(0.1)  );"

rHpcc documentation built on May 2, 2019, 11:04 a.m.