Re: Result comparison from 2 DataStream Sources

[1] > > https://ci.apache.org/projects/flink/flink-docs-release-1.0/apis/common/index.html#specifying-keys > > On 02.06.2016 23:20, iñaki williams wrote: > > Hi again! Thanks for your tips and gists, those are being really > > helpful. However, I probably didn't

Re: Maxby() and KeyBy() question

ache.org/news/2015/12/04/Introducing-windows.html > > 2016-06-09 14:36 GMT+02:00 iñaki williams >: > >> Hi again! >> >> I am working with two DataStreams, I want to get the maximun value from >> each pair of them, for example: >> >> //

Maxby() and KeyBy() question

Hi again! I am working with two DataStreams, I want to get the maximun value from each pair of them, for example: //Informacion (matchName, LocalOdd, AwayOdd) Informacion info1= new Informacion("Match1", 1.10, 3.22); Informacion info2= new Informacion("Match2", 2.11, 1.10);

Re: Custom keyBy(), look for similaties

/ci.apache.org/projects/flink/flink-docs-release-1.0/apis/common/index.html#specifying-keys > > But you only a local view for the current element, e.g. the library > you use to determine the similarity has to know the similarities > upfront. > > – Ufuk > > > On Mon, Jun 6, 20

Custom keyBy(), look for similaties

Hi guys, I am using Flink on my project and I have a question. (I am using Java) Is it possible to modify the keyby method in order to key by similarities and not by the exact name? Example: I recieve 2 DataStreams, in the first one , the name of the field that I want to KeyBy is "John Locke", w

Re: Result comparison from 2 DataStream Sources

om your diagram I have put together a gist, which I think does the > job. I haven't had the time to test it though :( > > https://gist.github.com/knaufk/d1312503b99ee51554a70c9a22abe7e5 > > If you have any questions, let me know. It sometimes just takes a while > until I an

Re: Result comparison from 2 DataStream Sources

m and if not save the price. The > challenge will be to clean up state. > > Let me know, if this works out. > > Cheers, > > Konstantin > > On 26.05.2016 20:01, iñaki williams wrote: > > Hi! > > > > I will explain it with more details: > > > > I

Re: Result comparison from 2 DataStream Sources

> save prices. In each map you can then check if you have a price for this > name already saved from the other stream and if not save the price. The > challenge will be to clean up state. > > Let me know, if this works out. > > Cheers, > > Konstantin > > On 26.05.2016

Re: Result comparison from 2 DataStream Sources

pared relate in time. So basically, if an object arrives from one > source, which time window of objects from the other stream should be > considered for comparison? > > Cheers, > > Konstantin > > On 26.05.2016 18:55, iñaki williams wrote: > > Hi! > > > > I a

Result comparison from 2 DataStream Sources

Hi! I am working on something quite similar to the stockPrice example that is posted on the webpage ( https://flink.apache.org/news/2015/02/09/streaming-example.html) I am extracting some data from 2 different webpages and I represent the result using a java object. The diagram could be something

Re: Custom Source Function for reading JSON?

Hi! I have the class, I want to create objects using the values extraced from the JSON text, my fault haha. Sorry for that 2016-05-15 19:10 GMT+02:00 Gábor Horváth : > Hi! > > On 14 May 2016 at 23:47, iñaki williams wrote: > >> Hi Flink Community! >> >> I am new

Custom Source Function for reading JSON?

Hi Flink Community! I am new using Apache Flink and I have a problem reading a JSON. I am using a JSON from a webpage, this JSON is changing continuosly so I decided to use my own Source Function in order to grab the JSON using a URL that is always the same: http://www.example/blabla/this.json I