public final class USMFTickMongoDBQueryStream extends MongoDBQueryStream<Context>
Constructor and Description |
---|
USMFTickMongoDBQueryStream(List<com.mongodb.ServerAddress> seeds)
The query stream from the seeds (default collection and db)
|
USMFTickMongoDBQueryStream(List<com.mongodb.ServerAddress> seeds,
String collectionName)
The query stream from the seeds and a specific collection
|
Modifier and Type | Method and Description |
---|---|
Context |
constructObjects(com.mongodb.DBObject next) |
String |
getCollectionName() |
String |
getDBName() |
com.mongodb.DBObject |
getSort() |
getLimit, getProjection, getQuery, hasNext, 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 USMFTickMongoDBQueryStream(List<com.mongodb.ServerAddress> seeds) throws UnknownHostException
seeds
- UnknownHostException
public USMFTickMongoDBQueryStream(List<com.mongodb.ServerAddress> seeds, String collectionName) throws UnknownHostException
seeds
- collectionName
- UnknownHostException
public String getCollectionName()
getCollectionName
in class MongoDBQueryStream<Context>
public com.mongodb.DBObject getSort()
getSort
in class MongoDBQueryStream<Context>
public String getDBName()
getDBName
in class MongoDBQueryStream<Context>
public Context constructObjects(com.mongodb.DBObject next)
constructObjects
in class MongoDBQueryStream<Context>
DBCursor