Hi Gordon. Thanks a lot for the information and the Jira ticket. On Sun, May 29, 2016 at 1:37 PM, Tzu-Li (Gordon) Tai <tzuli...@gmail.com> wrote:
> 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. >
