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

package org.apache.beam.sdk.io.mongodb

Transforms for reading and writing from MongoDB.

Related Packages

Package	Description
org.apache.beam.sdk.io	Defines transforms for reading and writing common storage formats, including invalid reference org.apache.beam.sdk.io.AvroIO , and TextIO.

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.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.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.
MongoDbGridFSIO.WriteFn<T>	Function that is called to write the data to the give GridFS OutputStream.
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.
UpdateConfiguration	Builds a MongoDB UpdateConfiguration object.
UpdateField