ges and not just keys.
>
>
>
> Regards,
>
>
>
> Diego
>
>
>
> *De:* Stephan Ewen [mailto:se...@apache.org]
> *Enviado el:* lunes, 30 de enero de 2017 17:39
> *Para:* user@flink.apache.org
> *Asunto:* Re: Calling external services/databases from DataStream API
>
, 30 de enero de 2017 17:39
Para: user@flink.apache.org
Asunto: Re: Calling external services/databases from DataStream API
Hi!
The Distributed cache would actually indeed be nice to add to the DataStream
API. Since the runtime parts for that are all in place, the code would be
mainly on the
tp://apache-flink-user-
> mailing-list-archive.2336050.n4.nabble.com/Calling-
> external-services-databases-from-DataStream-API-tp11366p11367.html
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> at Nabble.com.
>
o the same query.
--
View this message in context:
http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Calling-external-services-databases-from-DataStream-API-tp11366p11367.html
Sent from the Apache Flink User Mailing List archive. mailing list archive at
Nabble.com.
Hi all,
I'm working on an application that enriches network connections with
Geolocations, using the GeoIP database, which is stored as a file in HDFS. To
do so, I map every connection in my stream, using this function:
def enrichIp(ip: String): Location = {
val location = service.getLocati
