T
- public abstract class MongoDBQueryStream<T> extends AbstractStream<T>
DBCursor
instantiated from a DBObject
queryConstructor and Description |
---|
MongoDBQueryStream() |
MongoDBQueryStream(List<com.mongodb.ServerAddress> seeds) |
Modifier and Type | Method and Description |
---|---|
abstract T |
constructObjects(com.mongodb.DBObject next) |
abstract String |
getCollectionName() |
abstract String |
getDBName() |
int |
getLimit() |
com.mongodb.DBObject |
getProjection() |
com.mongodb.DBObject |
getQuery()
By Default returns a new and empty
BasicDBObject meaning this
stream goes through all documents in a given collection. |
com.mongodb.DBObject |
getSort() |
boolean |
hasNext() |
T |
next() |
filter, forEach, forEach, forEach, iterator, map, map, parallelForEach, parallelForEach, remove, transform
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
forEach, spliterator
public MongoDBQueryStream() throws UnknownHostException
UnknownHostException
public MongoDBQueryStream(List<com.mongodb.ServerAddress> seeds) throws UnknownHostException
seeds
- UnknownHostException
public int getLimit()
public com.mongodb.DBObject getProjection()
public com.mongodb.DBObject getSort()
public com.mongodb.DBObject getQuery()
BasicDBObject
meaning this
stream goes through all documents in a given collection. Overwrite to alter
queryDBObject
querypublic abstract String getCollectionName()
public boolean hasNext()
public abstract T constructObjects(com.mongodb.DBObject next)
next
- DBCursor