subject:"Scala compilation error"

Re: Scala compilation error

2016-05-03 Thread Aljoscha Krettek

There is a Scaladoc but it is not covering all packages, unfortunately. In the Scala API you can call transform without specifying a TypeInformation, it works using implicits/context bounds. On Tue, 3 May 2016 at 01:48 Srikanth wrote: > Sorry for the previous incomplete

Re: Scala compilation error

2016-05-02 Thread Srikanth

Sorry for the previous incomplete email. Didn't realize I hit send! I was facing a weird compilation error in Scala when I did val joinedStream = stream1.connect(stream2) .transform("funName", outTypeInfo, joinOperator) It turned out to be due to a difference in API signature between Scala and

Scala compilation error

2016-05-02 Thread Srikanth

Hello, I'm fac val stream = env.addSource(new FlinkKafkaConsumer09[String]("test-topic", new SimpleStringSchema(), properties)) val bidderStream: KeyedStream[BidderRawLogs, Int] = stream.flatMap(b => BidderRawLogs(b)).keyBy(b => b.strategyId) val metaStrategy: KeyedStream[(Int, String), Int] =