org.apache.streams.example

Class TwitterHistoryElasticsearch

java.lang.Object

org.apache.streams.example.TwitterHistoryElasticsearch

All Implemented Interfaces:

Runnable

public class TwitterHistoryElasticsearch
extends Object
implements Runnable

Retrieves as many posts from a known list of users as twitter API allows. Converts them to activities, and writes them in activity format to Elasticsearch.

Field Summary

Fields

Modifier and Type	Field and Description
static String	STREAMS_ID

Constructor Summary

Constructors

Constructor and Description
TwitterHistoryElasticsearch()
TwitterHistoryElasticsearch(TwitterHistoryElasticsearchConfiguration config)

Method Summary

Modifier and Type	Method and Description
static void	main(String[] args)
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

STREAMS_ID

public static final String STREAMS_ID

See Also:

Constant Field Values

Constructor Detail

TwitterHistoryElasticsearch

public TwitterHistoryElasticsearch()

TwitterHistoryElasticsearch

public TwitterHistoryElasticsearch(TwitterHistoryElasticsearchConfiguration config)

Method Detail

main

public static void main(String[] args)

run

public void run()

Specified by:

run in interface Runnable