@Experimental(value=SOURCE_SINK)

Package org.apache.beam.sdk.io.mongodb

Transforms for reading and writing from MongoDB.

See: Description

Interface Summary

Interface	Description
MongoDbGridFSIO.Parser<T>	Interface for the parser that is used to parse the GridFSDBFile into the appropriate types.
MongoDbGridFSIO.ParserCallback<T>	Callback for the parser to use to submit data.
MongoDbGridFSIO.WriteFn<T>	Function that is called to write the data to the give GridFS OutputStream.

Class Summary

Class	Description
AggregationQuery	Builds a MongoDB AggregateIterable object.
FindQuery	Builds a MongoDB FindQuery object.
MongoDbGridFSIO	IO to read and write data on MongoDB GridFS.
MongoDbGridFSIO.ConnectionConfiguration	Encapsulate the MongoDB GridFS connection logic.
MongoDbGridFSIO.Read<T>	A PTransform to read data from MongoDB GridFS.
MongoDbGridFSIO.Read.BoundedGridFSSource	A BoundedSource for MongoDB GridFS.
MongoDbGridFSIO.Write<T>	A PTransform to write data to MongoDB GridFS.
MongoDbIO	IO to read and write data on MongoDB.
MongoDbIO.Read	A PTransform to read data from MongoDB.
MongoDbIO.Write	A PTransform to write to a MongoDB database.

Package org.apache.beam.sdk.io.mongodb Description

Transforms for reading and writing from MongoDB.