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

Class MongoDbUtils

java.lang.Object

org.apache.beam.sdk.io.mongodb.MongoDbUtils

public class MongoDbUtils
extends Object

Utility methods for MongoDB IO.

Constructor Summary

Constructors

Constructor	Description
MongoDbUtils()

Method Summary

Modifier and Type	Method	Description
static Document	toDocument(Row row)	Converts a Beam Row to a BSON Document.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MongoDbUtils

public MongoDbUtils()

Method Details

toDocument

public static Document toDocument(Row row)

Converts a Beam Row to a BSON Document.