org.apache.streams.twitter.provider

Class TwitterUserInformationProvider

java.lang.Object

org.apache.streams.twitter.provider.TwitterUserInformationProvider

All Implemented Interfaces:

Serializable, StreamsOperation, StreamsProvider

public class TwitterUserInformationProvider
extends Object
implements StreamsProvider, Serializable

Retrieve current profile status from a list of user ids or names.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Twitter	client
protected org.joda.time.DateTime	end
protected com.google.common.util.concurrent.ListeningExecutorService	executor
protected List<Long>	ids
protected ReadWriteLock	lock
protected static com.fasterxml.jackson.databind.ObjectMapper	MAPPER
static int	MAX_NUMBER_WAITING
protected List<String>	names
protected Queue<StreamsDatum>	providerQueue
protected AtomicBoolean	running
protected org.joda.time.DateTime	start

Constructor Summary

Constructors

Constructor and Description
TwitterUserInformationProvider() TwitterUserInformationProvider constructor.
TwitterUserInformationProvider(TwitterUserInformationConfiguration config)

Method Summary

Modifier and Type	Method and Description
void	cleanUp()
protected Queue<StreamsDatum>	constructQueue()
TwitterUserInformationConfiguration	getConfig()
String	getId()
Queue<StreamsDatum>	getProviderQueue()
protected Twitter	getTwitterClient()
boolean	isRunning()
static void	main(String[] args) To use from command line: Supply (at least) the following required configuration in application.conf: twitter.oauth.consumerKey twitter.oauth.consumerSecret twitter.oauth.accessToken twitter.oauth.accessTokenSecret twitter.info Launch using: mvn exec:java -Dexec.mainClass=org.apache.streams.twitter.provider.TwitterUserInformationProvider -Dexec.args="application.conf tweets.json"
static ExecutorService	newFixedThreadPoolWithQueueSize(int numThreads, int queueSize)
void	prepare(Object configurationObject)
StreamsResultSet	readCurrent()
StreamsResultSet	readNew(BigInteger sequence)
StreamsResultSet	readRange(org.joda.time.DateTime start, org.joda.time.DateTime end)
void	setConfig(TwitterUserInformationConfiguration config)
void	startStream()
protected void	submitUserInformationThreads(List<Long> ids, List<String> names)

Methods inherited from class java.lang.Object

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

Field Detail

MAPPER

protected static com.fasterxml.jackson.databind.ObjectMapper MAPPER

MAX_NUMBER_WAITING

public static final int MAX_NUMBER_WAITING

See Also:

Constant Field Values

names

protected List<String> names

ids

protected List<Long> ids

lock

protected final ReadWriteLock lock

providerQueue

protected volatile Queue<StreamsDatum> providerQueue

client

protected Twitter client

executor

protected com.google.common.util.concurrent.ListeningExecutorService executor

start

protected org.joda.time.DateTime start

end

protected org.joda.time.DateTime end

running

protected final AtomicBoolean running

Constructor Detail

TwitterUserInformationProvider

public TwitterUserInformationProvider()

TwitterUserInformationProvider constructor. Resolves config from JVM properties 'twitter'.

TwitterUserInformationProvider

public TwitterUserInformationProvider(TwitterUserInformationConfiguration config)

Method Detail

getConfig

public TwitterUserInformationConfiguration getConfig()

setConfig

public void setConfig(TwitterUserInformationConfiguration config)

main

public static void main(String[] args)
                 throws Exception

To use from command line:

Supply (at least) the following required configuration in application.conf:

twitter.oauth.consumerKey twitter.oauth.consumerSecret twitter.oauth.accessToken twitter.oauth.accessTokenSecret twitter.info

Launch using:

mvn exec:java -Dexec.mainClass=org.apache.streams.twitter.provider.TwitterUserInformationProvider -Dexec.args="application.conf tweets.json"

Parameters:

args - args

Throws:

Exception - Exception

newFixedThreadPoolWithQueueSize

public static ExecutorService newFixedThreadPoolWithQueueSize(int numThreads,
                                                              int queueSize)

getProviderQueue

public Queue<StreamsDatum> getProviderQueue()

getId

public String getId()

Specified by:

getId in interface StreamsOperation

prepare

public void prepare(Object configurationObject)

Specified by:

prepare in interface StreamsOperation

submitUserInformationThreads

protected void submitUserInformationThreads(List<Long> ids,
                                            List<String> names)

startStream

public void startStream()

Specified by:

startStream in interface StreamsProvider

readCurrent

public StreamsResultSet readCurrent()

Specified by:

readCurrent in interface StreamsProvider

constructQueue

protected Queue<StreamsDatum> constructQueue()

readNew

public StreamsResultSet readNew(BigInteger sequence)

Specified by:

readNew in interface StreamsProvider

readRange

public StreamsResultSet readRange(org.joda.time.DateTime start,
                                  org.joda.time.DateTime end)

Specified by:

readRange in interface StreamsProvider

isRunning

public boolean isRunning()

Specified by:

isRunning in interface StreamsProvider

getTwitterClient

protected Twitter getTwitterClient()
                            throws InstantiationException

Throws:

InstantiationException

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface StreamsOperation