Re: Flink+avro integration

2015-10-22 Thread Till Rohrmann
; Thanks. Just to be sure, this is also a limitation of the Java > implementation of Flink, right? > > > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-avro-integration-tp3162p3236.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Re: Flink+avro integration

2015-10-22 Thread aawhitaker
ce function that selects the max and it should > work fine... Thanks. Just to be sure, this is also a limitation of the Java implementation of Flink, right? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-avro-integration-tp3162p3236.

Re: Flink+avro integration

2015-10-21 Thread Stephan Ewen
at java.lang.reflect.Method.invoke(Method.java:497) > at > com.intellij.rt.execution.application.AppMain.main(AppMain.java:140) > > A workaround is to use `.map` to map to tuples first, but this seems a > little clunky. > > Thanks! > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-avro-integration-tp3162p3202.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Re: Flink+avro integration

2015-10-21 Thread aawhitaker
java.lang.reflect.Method.invoke(Method.java:497) at com.intellij.rt.execution.application.AppMain.main(AppMain.java:140) A workaround is to use `.map` to map to tuples first, but this seems a little clunky. Thanks! -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-a

Re: Flink+avro integration

2015-10-21 Thread Stephan Ewen
t;> don't work on Java POJOs, as far as I could tell. Does that sound correct? >> What would you recommend? >> >> >> >> -- >> View this message in context: >> http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-avro-integration-tp3162p3187.html >> Sent from the Apache Flink User Mailing List archive. mailing list >> archive at Nabble.com. >> > >

Re: Flink+avro integration

2015-10-21 Thread Till Rohrmann
Does that sound correct? > What would you recommend? > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-avro-integration-tp3162p3187.html > Sent from the Apache Flink User Mailing List archive. mailing list archive > at Nabble.com. >

Re: Flink+avro integration

2015-10-20 Thread aawhitaker
could tell. Does that sound correct? What would you recommend? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-avro-integration-tp3162p3187.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

Re: Flink+avro integration

2015-10-20 Thread aawhitaker
Stephan, Thanks for the quick reply and the example. That does help! -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Flink-avro-integration-tp3162p3185.html Sent from the Apache Flink User Mailing List archive. mailing list archive at

Re: Flink+avro integration

2015-10-20 Thread Stephan Ewen
> > Best, > > Marton > > On Mon, Oct 19, 2015 at 4:21 PM, Andrew Whitaker > wrote: > >> I'm doing some research on Flink + Avro integration, and I've come across >> "org.apache.flink.api.java.io.AvroInputFormat" as a way to create a stream >

Re: Flink+avro integration

2015-10-19 Thread Márton Balassi
/connectors/kafka/FlinkKafkaConsumer.java#L256 I hope this clarifies the situation. Best, Marton On Mon, Oct 19, 2015 at 4:21 PM, Andrew Whitaker wrote: > I'm doing some research on Flink + Avro integration, and I've come across > "org.apache.flink.api.java.io.AvroInputForma

Flink+avro integration

2015-10-19 Thread Andrew Whitaker
I'm doing some research on Flink + Avro integration, and I've come across "org.apache.flink.api.java.io.AvroInputFormat" as a way to create a stream of Avro objects from a file. I had the following questions: 1. Is this the extent of Flink's integration with Avro?