Java library for Flink-Kudu integration

2017-03-27 Thread ruben.casado.tejedor
Hi all, I apologize for sending the email to both accounts, but not sure where this topic fits better. In my team, we have been working in some PoCs and PoVs about new data architectures. As part of this work, we have implemented a library to connect Kudu and Flink. The library allows reading/

Re: Need guidance for write a client connector for 'Flink'

2017-01-19 Thread ruben.casado.tejedor
Hi, Just in case it could useful, we are working in Flink-Kudu integration [1]. This is a still Work in Progess but we had to implemente an InputFormat to read from Kudu tables so maybe the code is useful for you [2] Best [1] https://github.com/rubencasado/Flink-Kudu [2] https://github.com/ru

Re: Flink CEP development is stalling

2017-01-12 Thread ruben.casado.tejedor
+1 I have some clientes interested in CEP features El 11/1/17 16:23, "Ivan Mushketyk" escribió: Hi Flink devs, Roughly half a year ago I implemented several PRs for Flink-CEP[1][2][3] but since then there were no progress with the reviews. What is frustrating about this situati

RE: Apache Flink and Kudu integration

2016-11-09 Thread ruben.casado.tejedor
Hi, I am starting a PoC to do that. I will try to develop both source and sink. I will let you know asap I have something ;-) Best -Original Message- From: Márton Balassi [mailto:balassi.mar...@gmail.com] Sent: viernes, 28 de octubre de 2016 8:50 To: dev@flink.apache.org Subject: Re: Ap

Apache Flink and Kudu integration

2016-10-27 Thread ruben.casado.tejedor
Hi all, Is there any PoC about reading/writing from/to Kudu? I think the flow kafka-flink-kudu is an interesting pattern. I would like to evaluate it so please let me know if there is any existing attempt to avoid starting from scratch. Advices are welcomed :) Best --

RE: [DISCUSS] Drop Hadoop 1 support with Flink 1.2

2016-10-13 Thread ruben.casado.tejedor
I am totally agree with Robert. From the industry point of view, we are not using in any client Hadoop 1.x . Even in legacy system, we have already upgraded the software. From: Robert Metzger [mailto:rmetz...@apache.org] Sent: jueves, 13 de octubre de 2016 16:48 To: dev@flink.apache.org; u...@fl