Re: UDF in Flink table API

2016-06-23 Thread Fabian Hueske
. Best, Fabian 2016-06-22 14:58 GMT+02:00 Cody Innowhere <e.neve...@gmail.com>: > Hi guys, > I'm trying to add a UDF in Flink table API, say, in DataSet table API. > My example code is as follows: > --- > object WordCountTable { > case class W

UDF in Flink table API

2016-06-22 Thread Cody Innowhere
Hi guys, I'm trying to add a UDF in Flink table API, say, in DataSet table API. My example code is as follows: --- object WordCountTable { case class WC(word: String, num: Int) def main(args: Array[String]): Unit = { // set up execution environment val env