Hi all,
I've implemented basic functionality for MailIO, following the suggestions provided in the previous discussions. Current implementation includes: - Bounded read operation for email messages - Integration with Splittable DoFn (SDF) for parallel processing The implementation is currently focused on bounded read operations. While I've incorporated SDF, I would appreciate feedback on whether the implementation aligns with best practices and Apache Beam patterns. Repository: https://github.com/twosom/beam-mail-io twosom/beam-mail-io: Mail Connector for Apache Beam / Google Cloud Dataflow github.com Looking forward to your feedback and suggestions. Best regards, LDesire