JDBC connection
}
}
Somebody knows how I could do just one connection? I tried to do in the
Constructor but the JDBC is not serializable.
Thanks
Toletum
Thanks Chiwan and Chesnay
I'm happy :-)
On lun., mar. 7, 2016 at 14:18, Chiwan Park wrote:
Hi Toletum,
You can initialize a JDBC connection with RichSinkFunction [1]. There are two
methods, `open` and `close`. The `open` method is called once before calling
`invoke` method. The `close` m
Hi! I'm a beginner in Flink.
I'm reading from a Kafka topic. In this topic, I receive a character each
event, like that:
Event.: 1 2 3 4 5 6 7 8 9...
Data..: A A A B B B B C C...
I would like to do a "trigger" when the character is different than before. For
example:
Event º1 fire because of A
Thanks Till,
At the end, I'm going to use a countWindowAll(2,1) and RichAllWindowFunction.
Regards,
On mié., abr. 20, 2016 at 16:46, Till Rohrmann wrote: You could use CEP for
that. First you would create a pattern of two states which matches everything.
In the select function you could then c
window has events, but, it doesn't if there aren't events.
Somebody knows how I could force it. I tried with a trigger and
ContinuousProcessingTimeTrigger, but, I don't know how use it.
Regards,
Toletum
