Hi all, I am trying to learn about UDAF and implemented a simple reservoir sample UDAF. It's working fine. However I am not able to figure out what DataType should I use so that its can deal with all DataTypes (simple and complex). For instance currently I have defined my input schema as
def inputSchema = StructType(StructField("id", StringType) :: Nil )
Instead of StringType can I use some other data type that is superclass of
all the DataTypes ?
Ritesh
