org.openimaj.demos.sandbox.ml.linear.learner.stream.twitter

Class USMFTickMongoDBQueryStream

java.lang.Object

org.openimaj.util.stream.AbstractStream<T>

org.openimaj.demos.sandbox.ml.linear.learner.stream.MongoDBQueryStream<Context>

org.openimaj.demos.sandbox.ml.linear.learner.stream.twitter.USMFTickMongoDBQueryStream

All Implemented Interfaces:

Iterable<Context>, Iterator<Context>, Stream<Context>

public final class USMFTickMongoDBQueryStream
extends MongoDBQueryStream<Context>

Get USMF statuses and financial ticks from a mongodb

Author:

Sina Samangooei (ss@ecs.soton.ac.uk)

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Context	constructObjects(com.mongodb.DBObject next)
String	getCollectionName()
String	getDBName()
com.mongodb.DBObject	getSort()

Methods inherited from class org.openimaj.demos.sandbox.ml.linear.learner.stream.MongoDBQueryStream

getLimit, getProjection, getQuery, hasNext, next

Methods inherited from class org.openimaj.util.stream.AbstractStream

filter, forEach, forEach, forEach, iterator, map, map, parallelForEach, parallelForEach, remove, transform

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

USMFTickMongoDBQueryStream

public USMFTickMongoDBQueryStream(List<com.mongodb.ServerAddress> seeds)
                           throws UnknownHostException

The query stream from the seeds (default collection and db)

Parameters:

seeds -

Throws:

UnknownHostException

USMFTickMongoDBQueryStream

public USMFTickMongoDBQueryStream(List<com.mongodb.ServerAddress> seeds,
                                  String collectionName)
                           throws UnknownHostException

The query stream from the seeds and a specific collection

Parameters:

seeds -

collectionName -

Throws:

UnknownHostException

Method Detail

getCollectionName

public String getCollectionName()

Specified by:

getCollectionName in class MongoDBQueryStream<Context>

Returns:

the name of the collection to query

getSort

public com.mongodb.DBObject getSort()

Overrides:

getSort in class MongoDBQueryStream<Context>

Returns:

how the query show be sorted

getDBName

public String getDBName()

Specified by:

getDBName in class MongoDBQueryStream<Context>

Returns:

the name of the database to query

constructObjects

public Context constructObjects(com.mongodb.DBObject next)

Specified by:

constructObjects in class MongoDBQueryStream<Context>

Returns:

construct the stream's object using the next document from the DBCursor