Re: Make Streaming Interoperable with Reactive Streams, Java Streams and Rx

What I ment was to have stream connectors for Java Streams, Rx (http://reactivex.io/), Reactive Streams (reactive-streams.org), JCTools (https://github.com/JCTools/JCTools), Chronicles (https://github.com/OpenHFT), Vertex (http://vertx.io/), Vertigo (https://github.com/kuujo/vertigo), Akka, Quasar

Re: Make Streaming Interoperable with Reactive Streams, Java Streams and Rx

Hey Suminda, I am not 100% by what you mean by interoperating, so clarify me if I am off-track here :) The systems that you have mentioned provide programming models for stream processing systems, in that sense a lot of features of Flink runtime are similar to these systems but it is presented

Make Streaming Interoperable with Reactive Streams, Java Streams and Rx

Hi, Is it possible to add interop with the following projects in Streaming: - http://reactive-streams.org/ specification - Java Streams - If possible http://reactivex.io/ Suminda -- View this message in context: http://apache-flink-incubator-mailing-list-archive.1008284.n3.nabble.com/Make

Re: Streaming groupby and aggregation by field expressions

Hi Gyula, I will take a look at your code once I have figured out how to implement the new batch API. Best, Viktor Gyula Fóra wrote > Hi Fabian, > > The link you sent is broken but I think you are referring the conversation > with Viktor. > > I agree that we should provide the same api for ag

Re: Introduction

Hi Johannes! Welcome :-) Right now, the parsers are used only in the CSV formats, so you can adjust them to that format's needs. Greetings, Stephan On Thu, Nov 6, 2014 at 3:17 PM, Kirschnick, Johannes < johannes.kirschn...@tu-berlin.de> wrote: > Hello, > > as have some other fellow colleges a

[jira] [Created] (FLINK-1223) Allow value escaping in CSV files

Johannes created FLINK-1223: --- Summary: Allow value escaping in CSV files Key: FLINK-1223 URL: https://issues.apache.org/jira/browse/FLINK-1223 Project: Flink Issue Type: Bug Components: J

Introduction

Hello, as have some other fellow colleges as well I would like to introduce myself as well to the list. I am a PhD student from Berlin who wants to work with Flink . As suggested by the getting started guide I had a look at some starter issues and found the issue about comments in CSV lines htt

[jira] [Created] (FLINK-1222) Let tasks finish as soon as their data is sent

Stephan Ewen created FLINK-1222: --- Summary: Let tasks finish as soon as their data is sent Key: FLINK-1222 URL: https://issues.apache.org/jira/browse/FLINK-1222 Project: Flink Issue Type: Improv

[jira] [Created] (FLINK-1221) Use program source line of invocation as the default function name

Stephan Ewen created FLINK-1221: --- Summary: Use program source line of invocation as the default function name Key: FLINK-1221 URL: https://issues.apache.org/jira/browse/FLINK-1221 Project: Flink

[jira] [Created] (FLINK-1220) Make INFO logging more verbose

Stephan Ewen created FLINK-1220: --- Summary: Make INFO logging more verbose Key: FLINK-1220 URL: https://issues.apache.org/jira/browse/FLINK-1220 Project: Flink Issue Type: Improvement Affect

[jira] [Created] (FLINK-1219) Add support for Apache Tez as execution engine

Kostas Tzoumas created FLINK-1219: - Summary: Add support for Apache Tez as execution engine Key: FLINK-1219 URL: https://issues.apache.org/jira/browse/FLINK-1219 Project: Flink Issue Type: Ne