cds

Type Members

1. case class SmvChunkUDF(para: Seq[Symbol], outSchema: StructType, eval: (List[Seq[Any]]) ⇒ List[Seq[Any]]) extends Product with Serializable

   

   User defined "chuck" mapping function see the chunkBy and chunkByPlus method of org.tresamigos.smv.SmvDFHelper for details

2. abstract class SmvGDO extends Serializable

   

   SmvGDO - SMV GroupedData Operator

   SmvGDO - SMV GroupedData Operator

   Used with smvMapGroup method of SmvGroupedData.

   Examples:

   val res1 = df.smvGroupBy('k).smvMapGroup(gdo1).agg(sum('v) as 'sumv, sum('v2) as 'sumv2)
   val res2 = df.smvGroupBy('k).smvMapGroup(gdo2).toDF

   Annotations

   @Experimental()