apache-beam-io-extras

The missing I/O PTransforms of Apache Beam in python; which already exist in Java SDK based but not yet supported in the official apache-beam module.

The support information can be viewed from here https://beam.apache.org/documentation/io/built-in/

Note: This module is in alpha, may contain breaking changes

Installation

pip install git+https://github.com/invanalabs/apache-beam-io-extras

Todo

The plan to write ptranforms for the following database solutions.

• MongoDB
• Solr
• Elasticsearch