org.apache.beam.sdk.io.mongodb

Class FindQuery

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable, ProcessFunction<com.mongodb.client.MongoCollection<org.bson.Document>,com.mongodb.client.MongoCursor<org.bson.Document>>, SerializableFunction<com.mongodb.client.MongoCollection<org.bson.Document>,com.mongodb.client.MongoCursor<org.bson.Document>>

@Experimental(value=SOURCE_SINK)
public abstract class FindQuery
extends java.lang.Object
implements SerializableFunction<com.mongodb.client.MongoCollection<org.bson.Document>,com.mongodb.client.MongoCursor<org.bson.Document>>

Builds a MongoDB FindQuery object.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
FindQuery()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

FindQuery

public FindQuery()

Method Detail

create

public static FindQuery create()

withFilters

public FindQuery withFilters(org.bson.conversions.Bson filters)

Sets the filters to find.

withLimit

public FindQuery withLimit(int limit)

Sets the limit of documents to find.

withProjection

public FindQuery withProjection(java.util.List<java.lang.String> projection)

Sets the projection.

apply

public com.mongodb.client.MongoCursor<org.bson.Document> apply(com.mongodb.client.MongoCollection<org.bson.Document> collection)

Description copied from interface: SerializableFunction

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

Specified by:

apply in interface ProcessFunction<com.mongodb.client.MongoCollection<org.bson.Document>,com.mongodb.client.MongoCursor<org.bson.Document>>

Specified by:

apply in interface SerializableFunction<com.mongodb.client.MongoCollection<org.bson.Document>,com.mongodb.client.MongoCursor<org.bson.Document>>