Interface FindPublisher<TResult>
-
- Type Parameters:
TResult- The type of the result.
- All Superinterfaces:
org.reactivestreams.Publisher<TResult>
public interface FindPublisher<TResult> extends org.reactivestreams.Publisher<TResult>Publisher interface for find.- Since:
- 1.0
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description FindPublisher<TResult>batchSize(int batchSize)Sets the number of documents to return per batch.FindPublisher<TResult>collation(Collation collation)Sets the collation optionsFindPublisher<TResult>comment(String comment)Sets the comment to the query.FindPublisher<TResult>cursorType(CursorType cursorType)Sets the cursor type.FindPublisher<TResult>filter(Bson filter)Sets the query filter to apply to the query.org.reactivestreams.Publisher<TResult>first()Helper to return a publisher limited to the first result.FindPublisher<TResult>hint(Bson hint)Sets the hint for which index to use.FindPublisher<TResult>hintString(String hint)Sets the hint for which index to use.FindPublisher<TResult>limit(int limit)Sets the limit to apply.FindPublisher<TResult>max(Bson max)Sets the exclusive upper bound for a specific index.FindPublisher<TResult>maxAwaitTime(long maxAwaitTime, TimeUnit timeUnit)The maximum amount of time for the server to wait on new documents to satisfy a tailable cursor query.FindPublisher<TResult>maxTime(long maxTime, TimeUnit timeUnit)Sets the maximum execution time on the server for this operation.FindPublisher<TResult>min(Bson min)Sets the minimum inclusive lower bound for a specific index.FindPublisher<TResult>noCursorTimeout(boolean noCursorTimeout)The server normally times out idle cursors after an inactivity period (10 minutes) to prevent excess memory use.FindPublisher<TResult>oplogReplay(boolean oplogReplay)Users should not set this under normal circumstances.FindPublisher<TResult>partial(boolean partial)Get partial results from a sharded cluster if one or more shards are unreachable (instead of throwing an error).FindPublisher<TResult>projection(Bson projection)Sets a document describing the fields to return for all matching documents.FindPublisher<TResult>returnKey(boolean returnKey)Sets the returnKey.FindPublisher<TResult>showRecordId(boolean showRecordId)Sets the showRecordId.FindPublisher<TResult>skip(int skip)Sets the number of documents to skip.FindPublisher<TResult>sort(Bson sort)Sets the sort criteria to apply to the query.
-
-
-
Method Detail
-
first
org.reactivestreams.Publisher<TResult> first()
Helper to return a publisher limited to the first result.- Returns:
- a Publisher which will contain a single item.
-
filter
FindPublisher<TResult> filter(Bson filter)
Sets the query filter to apply to the query.- Parameters:
filter- the filter, which may be null.- Returns:
- this
- MongoDB documentation
- Filter
-
limit
FindPublisher<TResult> limit(int limit)
Sets the limit to apply.- Parameters:
limit- the limit, which may be null- Returns:
- this
- MongoDB documentation
- Limit
-
skip
FindPublisher<TResult> skip(int skip)
Sets the number of documents to skip.- Parameters:
skip- the number of documents to skip- Returns:
- this
- MongoDB documentation
- Skip
-
maxTime
FindPublisher<TResult> maxTime(long maxTime, TimeUnit timeUnit)
Sets the maximum execution time on the server for this operation.- Parameters:
maxTime- the max timetimeUnit- the time unit, which may not be null- Returns:
- this
- MongoDB documentation
- Max Time
-
maxAwaitTime
FindPublisher<TResult> maxAwaitTime(long maxAwaitTime, TimeUnit timeUnit)
The maximum amount of time for the server to wait on new documents to satisfy a tailable cursor query. This only applies to a TAILABLE_AWAIT cursor. When the cursor is not a TAILABLE_AWAIT cursor, this option is ignored. On servers >= 3.2, this option will be specified on the getMore command as "maxTimeMS". The default is no value: no "maxTimeMS" is sent to the server with the getMore command. On servers < 3.2, this option is ignored, and indicates that the driver should respect the server's default value A zero value will be ignored.- Parameters:
maxAwaitTime- the max await timetimeUnit- the time unit to return the result in- Returns:
- the maximum await execution time in the given time unit
- Since:
- 1.2
- MongoDB documentation
- Max Time
-
projection
FindPublisher<TResult> projection(Bson projection)
Sets a document describing the fields to return for all matching documents.- Parameters:
projection- the project document, which may be null.- Returns:
- this
- MongoDB documentation
- Projection
-
sort
FindPublisher<TResult> sort(Bson sort)
Sets the sort criteria to apply to the query.- Parameters:
sort- the sort criteria, which may be null.- Returns:
- this
- MongoDB documentation
- Sort
-
noCursorTimeout
FindPublisher<TResult> noCursorTimeout(boolean noCursorTimeout)
The server normally times out idle cursors after an inactivity period (10 minutes) to prevent excess memory use. Set this option to prevent that.- Parameters:
noCursorTimeout- true if cursor timeout is disabled- Returns:
- this
-
oplogReplay
FindPublisher<TResult> oplogReplay(boolean oplogReplay)
Users should not set this under normal circumstances.- Parameters:
oplogReplay- if oplog replay is enabled- Returns:
- this
-
partial
FindPublisher<TResult> partial(boolean partial)
Get partial results from a sharded cluster if one or more shards are unreachable (instead of throwing an error).- Parameters:
partial- if partial results for sharded clusters is enabled- Returns:
- this
-
cursorType
FindPublisher<TResult> cursorType(CursorType cursorType)
Sets the cursor type.- Parameters:
cursorType- the cursor type- Returns:
- this
-
collation
FindPublisher<TResult> collation(Collation collation)
Sets the collation optionsA null value represents the server default.
- Parameters:
collation- the collation options to use- Returns:
- this
- Since:
- 1.3
- Since server release
- 3.4
-
comment
FindPublisher<TResult> comment(String comment)
Sets the comment to the query. A null value means no comment is set.- Parameters:
comment- the comment- Returns:
- this
- Since:
- 1.6
-
hint
FindPublisher<TResult> hint(Bson hint)
Sets the hint for which index to use. A null value means no hint is set.- Parameters:
hint- the hint- Returns:
- this
- Since:
- 1.6
-
hintString
FindPublisher<TResult> hintString(String hint)
Sets the hint for which index to use. A null value means no hint is set.- Parameters:
hint- the name of the index which should be used for the operation- Returns:
- this
- Since:
- 1.13
-
max
FindPublisher<TResult> max(Bson max)
Sets the exclusive upper bound for a specific index. A null value means no max is set.- Parameters:
max- the max- Returns:
- this
- Since:
- 1.6
-
min
FindPublisher<TResult> min(Bson min)
Sets the minimum inclusive lower bound for a specific index. A null value means no max is set.- Parameters:
min- the min- Returns:
- this
- Since:
- 1.6
-
returnKey
FindPublisher<TResult> returnKey(boolean returnKey)
Sets the returnKey. If true the find operation will return only the index keys in the resulting documents.- Parameters:
returnKey- the returnKey- Returns:
- this
- Since:
- 1.6
-
showRecordId
FindPublisher<TResult> showRecordId(boolean showRecordId)
Sets the showRecordId. Set to true to add a field$recordIdto the returned documents.- Parameters:
showRecordId- the showRecordId- Returns:
- this
- Since:
- 1.6
-
batchSize
FindPublisher<TResult> batchSize(int batchSize)
Sets the number of documents to return per batch.Overrides the
Subscription.request(long)value for setting the batch size, allowing for fine grained control over the underlying cursor.- Parameters:
batchSize- the batch size- Returns:
- this
- Since:
- 1.8
- MongoDB documentation
- Batch Size
-
-