I need an SQS source for my project that is using beam. A brief search did not turn up any in-progress work in this area. Please point me to the right repo if I missed it.
Assuming there is no in-progress effort, I would like to contribute an Amazon SQS source. I have a few questions before I begin. It seems that the current AWS code is split into two different modules: sdk/java/io/amazon-web-services which contains the S3FileSystem, AwsOptions, etc, and sdk/java/io/kinesis which contains an unbounded source based on a kinesis topic. I'd like to add this source to the amazon-web-services module since I'd like to depend on AwsOptions. Does adding this source to the amazon-web-services module make sense? Also, the kinesis source looks a touch more complex than other sources. Both the JMS and AMQP sources look like better examples to follow. Which existing source would be the best to model this contribution after? If anyone has put some thoughts into this, or better yet some code, I'd appreciate hearing from you. Thanks!
