Source and Sink Flink

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

Source and Sink Flink

Alberto Ramón
Can be possible from Flink?:

read from IBM MQ
write in HDFS using append
Reply | Threaded
Open this post in threaded view
|

Re: Source and Sink Flink

rmetzger0
Hi Alberto,

It should be possible. The IBM MQ supports the JMS standard, and we have a JMS compatible connector for Flink in Apache Bahir: http://bahir.apache.org/docs/flink/current/flink-streaming-activemq/ 

For writing files to HDFS, we have the bucketing sink in Flink https://ci.apache.org/projects/flink/flink-docs-release-1.2/dev/connectors/filesystem_sink.html

On Tue, Mar 14, 2017 at 6:05 PM, Alberto Ramón <[hidden email]> wrote:
Can be possible from Flink?:

read from IBM MQ
write in HDFS using append