com.northconcepts.datapipeline.twitter

Class TwitterFilterStreamReader

java.lang.Object

TwitterStreamReader

com.northconcepts.datapipeline.twitter.TwitterFilterStreamReader

public class TwitterFilterStreamReader
extends TwitterStreamReader

Continuously reads tweets matching several criteria (hashtag, user, language, etc.)

Constructor Summary

Constructors

Constructor and Description
TwitterFilterStreamReader(String consumerKey, String consumerSecret)
TwitterFilterStreamReader(String consumerKey, String consumerSecret, String accessToken, String accessTokenSecret)
TwitterFilterStreamReader(TwitterStreamProvider provider)

Method Summary

Modifier and Type	Method and Description
DataException	addExceptionProperties(DataException exception)
void	close()
long[]	getFollow()
String[]	getLanguage()
double[][]	getLocations()
long	getMissedTweets()
String[]	getTrack()
boolean	isFailOnLimitationNotice()
protected void	listen(TwitterStream twitterStream)
TwitterFilterStreamReader	setFailOnLimitationNotice(boolean failOnLimitationNotice)
TwitterFilterStreamReader	setFollow(long... follow)
TwitterFilterStreamReader	setLanguage(String... language)
TwitterFilterStreamReader	setLocations(double[]... locations)
TwitterFilterStreamReader	setTrack(String... track)

Methods inherited from class java.lang.Object

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

Constructor Detail

TwitterFilterStreamReader

public TwitterFilterStreamReader(TwitterStreamProvider provider)

TwitterFilterStreamReader

public TwitterFilterStreamReader(String consumerKey,
                                 String consumerSecret)

TwitterFilterStreamReader

public TwitterFilterStreamReader(String consumerKey,
                                 String consumerSecret,
                                 String accessToken,
                                 String accessTokenSecret)

Method Detail

getFollow

public long[] getFollow()

setFollow

public TwitterFilterStreamReader setFollow(long... follow)

getTrack

public String[] getTrack()

setTrack

public TwitterFilterStreamReader setTrack(String... track)

getLocations

public double[][] getLocations()

setLocations

public TwitterFilterStreamReader setLocations(double[]... locations)

getLanguage

public String[] getLanguage()

setLanguage

public TwitterFilterStreamReader setLanguage(String... language)

isFailOnLimitationNotice

public boolean isFailOnLimitationNotice()

setFailOnLimitationNotice

public TwitterFilterStreamReader setFailOnLimitationNotice(boolean failOnLimitationNotice)

getMissedTweets

public long getMissedTweets()

listen

protected void listen(TwitterStream twitterStream)

close

public void close()
           throws DataException

Throws:

DataException

addExceptionProperties

public DataException addExceptionProperties(DataException exception)