Re: readCsvFile

2016-10-09 Thread Alberto Ramón
yes ¡ I didn't see this :( Thanks 2016-10-09 23:23 GMT+02:00 Fabian Hueske : > Shouldn't "val counts4 = text3" be "val counts4 = text4"? > > > 2016-10-09 23:14 GMT+02:00 Alberto Ramón : > >> I think The char delimited its OK >> (I attached CSV) >> >> val text4 = env.readCsvFile [Tuple1[String]

Re: Regarding

2016-10-09 Thread Fabian Hueske
Hi Rashmi, as Marton said, you do not need to start a local Flink instance (start-lcoal.bat) if you want to run programs from your IDE. Maybe running a local instance causes a conflict when starting an instance from IDE. Developing and running Flink programs on Windows should work, both from the I

Re: readCsvFile

2016-10-09 Thread Fabian Hueske
Shouldn't "val counts4 = text3" be "val counts4 = text4"? 2016-10-09 23:14 GMT+02:00 Alberto Ramón : > I think The char delimited its OK > (I attached CSV) > > val text4 = env.readCsvFile [Tuple1[String]]("file://data.csv" > ,fieldDelimiter = "," > ,includedFields = Array(2)) > val counts4 =

Re: readCsvFile

2016-10-09 Thread Alberto Ramón
I think The char delimited its OK (I attached CSV) val text4 = env.readCsvFile [Tuple1[String]]("file://data.csv" ,fieldDelimiter = "," ,includedFields = Array(2)) val counts4 = text3 .map { (_, 1) } .groupBy(0) .sum(1) counts4.print() The result is: [image: Imágenes integradas 1] Can

Re: Listening to timed-out patterns in Flink CEP

2016-10-09 Thread lgfmt
>>FLINK-3320 (CEP "not" operator) does not address this because again, how >>would the "not match" be triggered if no event at all occurs? Good question. I'm not sure whether the following will work: This could be done by creating a CEP matching pattern that uses both of "notNext" (or "notFollow

Re: Listening to timed-out patterns in Flink CEP

2016-10-09 Thread David Koch
Hello, Thank you for the explanation as well as the link to the other post. Interesting to learn about some of the open JIRAs. Indeed, I was not using event time, but processing time. However, even when using event time I only get notified of timeouts upon subsequent events. The link

Re: jdbc.JDBCInputFormat

2016-10-09 Thread Alberto Ramón
After solved some issues, I connected with Kylin, but I can't read data import org.apache.flink.api.scala._ import org.apache.flink.api.java.io.jdbc.JDBCInputFormat import org.apache.flink.api.table.Row import org.apache.flink.api.table.typeutils.RowTypeInfo import org.apache.flink.api.common.type