Package com.mongodb.client

Interface ChangeStreamIterable<TResult>

Type Parameters:
TResult - The type of the result.
All Superinterfaces:
Iterable<ChangeStreamDocument<TResult>>, MongoIterable<ChangeStreamDocument<TResult>>
public interface ChangeStreamIterable<TResult> extends MongoIterable<ChangeStreamDocument<TResult>>
Iterable for change streams.

Note: the ChangeStreamDocument class will not be applicable for all change stream outputs. If using custom pipelines that radically change the result, then the withDocumentClass(Class) method can be used to provide an alternative document format.

Since:
3.6
Since server release
3.6

  • Method Details

    • cursor

      MongoChangeStreamCursor<ChangeStreamDocument<TResult>> cursor()
      Returns a cursor used for iterating over elements of type ChangeStreamDocument<TResult>. The cursor has a covariant return type to additionally provide a method to access the resume token in change stream batches.
      Specified by:
      cursor in interface MongoIterable<TResult>
      Returns:
      the change stream cursor
      Since:
      3.11

    • fullDocument

      ChangeStreamIterable<TResult> fullDocument(FullDocument fullDocument)
      Sets the fullDocument value.
      Parameters:
      fullDocument - the fullDocument
      Returns:
      this

    • fullDocumentBeforeChange

      ChangeStreamIterable<TResult> fullDocumentBeforeChange(FullDocumentBeforeChange fullDocumentBeforeChange)
      Sets the fullDocumentBeforeChange value.
      Parameters:
      fullDocumentBeforeChange - the fullDocumentBeforeChange
      Returns:
      this
      Since:
      4.7
      Since server release
      6.0

    • resumeAfter

      ChangeStreamIterable<TResult> resumeAfter(BsonDocument resumeToken)
      Sets the logical starting point for the new change stream.
      Parameters:
      resumeToken - the resume token
      Returns:
      this

    • batchSize

      ChangeStreamIterable<TResult> batchSize(int batchSize)
      Sets the number of documents to return per batch.
      Specified by:
      batchSize in interface MongoIterable<TResult>
      Parameters:
      batchSize - the batch size
      Returns:
      this
      MongoDB documentation
      Batch Size

    • maxAwaitTime

      ChangeStreamIterable<TResult> maxAwaitTime(long maxAwaitTime, TimeUnit timeUnit)
      Sets the maximum await execution time on the server for this operation.
      Parameters:
      maxAwaitTime - the max await time. A zero value will be ignored, and indicates that the driver should respect the server's default value
      timeUnit - the time unit, which may not be null
      Returns:
      this

    • collation

      ChangeStreamIterable<TResult> collation(@Nullable Collation collation)
      Sets the collation options

      A null value represents the server default.

      Parameters:
      collation - the collation options to use
      Returns:
      this

    • withDocumentClass

      <TDocument> MongoIterable<TDocument> withDocumentClass(Class<TDocument> clazz)
      Returns a MongoIterable containing the results of the change stream based on the document class provided.
      Type Parameters:
      TDocument - the result type
      Parameters:
      clazz - the class to use for the raw result.
      Returns:
      the new Mongo Iterable

    • startAtOperationTime

      ChangeStreamIterable<TResult> startAtOperationTime(BsonTimestamp startAtOperationTime)
      The change stream will only provide changes that occurred at or after the specified timestamp.

      Any command run against the server will return an operation time that can be used here.

      The default value is an operation time obtained from the server before the change stream was created.

      Parameters:
      startAtOperationTime - the start at operation time
      Returns:
      this
      Since:
      3.8
      MongoDB documentation
      reference/method/db.runCommand/
      Since server release
      4.0

    • startAfter

      ChangeStreamIterable<TResult> startAfter(BsonDocument startAfter)
      Similar to resumeAfter, this option takes a resume token and starts a new change stream returning the first notification after the token.

      This will allow users to watch collections that have been dropped and recreated or newly renamed collections without missing any notifications.

      Note: The server will report an error if both startAfter and resumeAfter are specified.

      Parameters:
      startAfter - the startAfter resumeToken
      Returns:
      this
      Since:
      3.11
      MongoDB documentation
      changeStreams/#change-stream-start-after
      Since server release
      4.2

    • comment

      ChangeStreamIterable<TResult> comment(@Nullable String comment)
      Sets the comment for this operation. A null value means no comment is set.
      Parameters:
      comment - the comment
      Returns:
      this
      Since:
      4.6
      Since server release
      3.6

    • comment

      ChangeStreamIterable<TResult> comment(@Nullable BsonValue comment)
      Sets the comment for this operation. A null value means no comment is set.

      The comment can be any valid BSON type for server versions 4.4 and above. Server versions between 3.6 and 4.2 only support string as comment, and providing a non-string type will result in a server-side error.

      Parameters:
      comment - the comment
      Returns:
      this
      Since:
      4.6
      Since server release
      3.6

    • showExpandedEvents

      ChangeStreamIterable<TResult> showExpandedEvents(boolean showExpandedEvents)
      Sets whether to include expanded change stream events, which are: createIndexes, dropIndexes, modify, create, shardCollection, reshardCollection, refineCollectionShardKey. False by default.
      Parameters:
      showExpandedEvents - true to include expanded events
      Returns:
      this
      Since:
      4.7
      Since server release
      6.0