I don't think I need state for this... I need to load a CSV. I'm guessing as a table and then filter my events parse the number, transform the event into geolocation data and sink that downstream data source.
So I'm guessing i need a CSV source and my Kafka source and somehow join those transform the event... On Fri, 27 Sep 2019 at 14:43, Oytun Tez <oy...@motaword.com> wrote: > Hi, > > You should look broadcast state pattern in Flink docs. > > --- > Oytun Tez > > *M O T A W O R D* > The World's Fastest Human Translation Platform. > oy...@motaword.com — www.motaword.com > > > On Fri, Sep 27, 2019 at 2:42 PM John Smith <java.dev....@gmail.com> wrote: > >> Using 1.8 >> >> I have a list of phone area codes, cities and their geo location in CSV >> file. And my events from Kafka contain phone numbers. >> >> I want to parse the phone number get it's area code and then associate >> the phone number to a city, geo location and as well count how many numbers >> are in that city/geo location. >> >
