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

Class FindQuery

java.lang.Object

org.apache.beam.sdk.io.mongodb.FindQuery

All Implemented Interfaces:

Serializable, ProcessFunction<MongoCollection<Document>,MongoCursor<Document>>, SerializableFunction<MongoCollection<Document>,MongoCursor<Document>>

public abstract class FindQuery
extends Object
implements SerializableFunction<MongoCollection<Document>,MongoCursor<Document>>

Builds a MongoDB FindQuery object.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FindQuery()

Method Summary

Modifier and Type	Method	Description
MongoCursor<Document>	apply(MongoCollection<Document> collection)	Returns the result of invoking this function on the given input.
static FindQuery	create()
FindQuery	withFilters(Bson filters)	Sets the filters to find.
FindQuery	withLimit(int limit)	Sets the limit of documents to find.
FindQuery	withProjection(List<String> projection)	Sets the projection.

Methods inherited from class java.lang.Object

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

Constructor Details

FindQuery

public FindQuery()

Method Details

create

public static FindQuery create()

withFilters

public FindQuery withFilters(Bson filters)

Sets the filters to find.

withLimit

public FindQuery withLimit(int limit)

Sets the limit of documents to find.

withProjection

public FindQuery withProjection(List<String> projection)

Sets the projection.

apply

public MongoCursor<Document> apply(MongoCollection<Document> collection)

Description copied from interface: SerializableFunction

Returns the result of invoking this function on the given input.

Specified by:

apply in interface ProcessFunction<MongoCollection<Document>,MongoCursor<Document>>

Specified by:

apply in interface SerializableFunction<MongoCollection<Document>,MongoCursor<Document>>