GSoC project proposal: Query optimisation layer for Flink Streaming

Hello, I cam out with the following proposal which I believe needs alot of review. I will appreciate if you can help me make appropriate corrections before the deadline for submission. Thanks @gyfora, @pariscarbone *GSoC project: Query optimisation layer for Flink Streaming

Re: HBase TableOutputFormat

Hi Flavio! The issue that abstract classes and interfaces are not supported is definitely fixed in 0.9. Your other fix (adding the call for configuring the output format) - is that always needed, or just important in a special case? How has the output format worked before? If this is critical to

Re: Flink execution time benchmark

Hi, The execute() method returns an execution result object that also contains the runtime of the job. Sent from my iPhone > On 21.03.2015, at 11:09, Giacomo Licari wrote: > > Hi guys, > I'm trying to execute a benchmark reading a 1GB file and applying a reduce > function. > > I'd like to

Flink execution time benchmark

Hi guys, I'm trying to execute a benchmark reading a 1GB file and applying a reduce function. I'd like to get the overall execution time. I put that code before applying the reduce function: long startTime = System.currentTimeMillis(); and after env.execute("Flink Processor"); I put the code to