Re: CEP API: Question on FollowedBy

matching sequences. I > hope that answers your question Anwar. > > Cheers, > Till > ​ > > On Mon, Apr 4, 2016 at 11:18 AM, Anwar Rizal <anriza...@gmail.com> wrote: > >> Hi All, >> >> >> I saw Till's blog preparation. It will be a very helpful blog. I hop

CEP API: Question on FollowedBy

Hi All, I saw Till's blog preparation. It will be a very helpful blog. I hope that some other blogs that explain how it works will come soon :-) I have a question on followedBy pattern matching semantic. >From the documentation

Re: Where does Flink store intermediate state and triggering/scheduling a delayed event?

Allow me to jump to this very interesting discussion. The 2nd point is actually an interesting question. I understand that we can set a timestamp of event in Flink. What if we set the timestamp to somewhere in the future, for example 24 hours from now ? Can Flink handle this case ? Also , I'm

Re: Doubt about window and count trigger

) > > evaluation of the window. Thus, it is not "or-ed" to the basic window > > definition. > > > > If you want to have an or-ed window condition, you can customize it by > > specifying your own window definition. > > > > > dataStream.window

Re: Doubt about window and count trigger

more minute (and not starting a new 5 minute window). > > Cheers, Fabian > > > 2015-11-27 14:59 GMT+01:00 Anwar Rizal <anriza...@gmail.com>: > >> Thanks Fabian and Aljoscha, >> >> I try to implement the trigger as you described as follow: >

Re: Issue with sharing state in CoFlatMapFunction

Broadcast is what we do for the same type of your initial problem indeed. In another thread, Stephan mentioned a possibility of using OperatorState in ConnectedStream. I think this approach using OperatorState does the business as well. In my understanding, the approach using broadcast will

Re: Apache Flink Operator State as Query Cache

nite etc, i can just use operator state >> for this one. >> >> I just want to gauge do i need to use memory cache or operator state >> would be just fine. >> >> However i'm concern about the Gen 2 Garbage Collection for caching our >> own state without

Re: Apache Flink Operator State as Query Cache

Let me understand your case better here. You have a stream of model and stream of data. To process the data, you will need a way to access your model from the subsequent stream operations (map, filter, flatmap, ..). I'm not sure in which case Operator State is a good choice, but I think you can

Re: Scala Breeze Dependencies not resolving when adding flink-ml on build.sbt

Yeah I had similar problems with kafka in spark streaming. I worked around the problem by excluding kafka from connector and then adding the library back. Maybe you can try something like: libraryDependencies ++= Seq("org.apache.flink" % "flink-scala" % "0.9.1", "org.apache.flink" %

Re: Powered by Flink

Nice indeed :-) On Mon, Oct 19, 2015 at 3:08 PM, Suneel Marthi wrote: > +1 to this. > > On Mon, Oct 19, 2015 at 3:00 PM, Fabian Hueske wrote: > >> Sounds good +1 >> >> 2015-10-19 14:57 GMT+02:00 Márton Balassi : >> >> >

Re: Flink Data Stream Union

Do you really need to iterate ? On Mon, Oct 19, 2015 at 5:42 PM, flinkuser wrote: > > Here is my code snippet but I find the union operator not workable. > > DataStream msgDataStream1 = env.addSource((new > SocketSource(hostName1,port,'\n',-1))).filter(new >

Re: Flink Kafka example in Scala

I do the same trick as Wendong to avoid compilation error of sbt (excluding kafka_$(scala.binary.version) ) I still don't manage to make sbt pass scala.binary.version to maven. Anwar. On Mon, Jul 20, 2015 at 9:42 AM, Till Rohrmann trohrm...@apache.org wrote: Hi Wendong, why do you exclude

Re: Flink Forward 2015

Look great. Any dates for the abstract deadline already ? On Tue, Apr 7, 2015 at 2:38 PM, Kostas Tzoumas ktzou...@apache.org wrote: Ah, thanks Sebastian! :-) On Tue, Apr 7, 2015 at 2:33 PM, Sebastian ssc.o...@googlemail.com wrote: There are still some Berlin Buzzwords snippets in your texts