flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tzu-Li (Gordon) Tai" <tzuli...@gmail.com>
Subject Re: Would like to add a connector to DistributedLog.
Date Sun, 29 May 2016 05:37:36 GMT
Hi Jia,

There's currently no dedicated documentation for composing streaming
connectors, but for examples, I would say that the Elasticsearch and Nifi
connectors are a good place to start learning. For a more full blown example
I recommend taking a look at the Kafka connector. Basically, you'll extend
the RichParallelSourceFunction for sources (or RichSinkFunction for sinks)
and implement the required methods that will be called during the source /
sink tasks' life cycle.

I'd be happy to help you with any questions you may come into while
implementing the connector. Also, I'm thinking about adding documentation
for composing a new connector (filed in
https://issues.apache.org/jira/browse/FLINK-3989) as its a frequently asked
question, so any feedback during your learning process will be quite
helpful!



--
View this message in context: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Would-like-to-add-a-connector-to-DistributedLog-tp11869p11872.html
Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.

Mime
View raw message