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.
static Row	toRow(Map<?,?> doc, Schema schema)	Converts a BSON Document (or any Map representing fields) to a Beam Row matching the given Schema.

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.

toRow

public static Row toRow(Map<?,?> doc,
 Schema schema)

Converts a BSON Document (or any Map representing fields) to a Beam Row matching the given Schema.