Index

A B C E F G H K L M N O P R S T U V
All Classes and Interfaces|All Packages|Serialized Form

A

aggregate() - Method in class tweetoscope.tweetsAggregator.TwitterKafkaAggregator

Méthode principale d'agrégation qui lit les messages de Kafka et met à jour les hashtags populaires.

B

BEARER_TOKEN - Static variable in class tweetoscope.tweetsFilter.OnlineTweetFilter

Deprecated.

token to access Twitter API endpoint, get from the environment variables

BEARER_TOKEN - Static variable in class tweetoscope.tweetsProducer.OnlineTweetsProducer

Deprecated.

token to access Twitter API endpoint

bootstrapServers - Variable in class tweetoscope.tweetsFilter.TwitterKafkaFilter

C

consumer - Static variable in class tweetoscope.tweetsFilter.TwitterKafkaFilter

countryCode - Variable in class tweetoscope.tweetsFilter.CountryCodeTweetFilter

The targeted country code to match

CountryCodeTweetFilter - Class in tweetoscope.tweetsFilter

Filters Tweets according to their country code

CountryCodeTweetFilter(String) - Constructor for class tweetoscope.tweetsFilter.CountryCodeTweetFilter

Creates a filter that queries the Twitter API to retrieve the country code associated with the "place" tag of a Tweet (if it is set) and tests whether its value equals a given code.

creationYear - Variable in class tweetoscope.tweetsFilter.UserAccountCreationYearTweetFilter

The targeted max creation year (excluded)

E

EmptyTweetFilter - Class in tweetoscope.tweetsFilter

Empty Tweet filter: all Tweets are accepted

EmptyTweetFilter() - Constructor for class tweetoscope.tweetsFilter.EmptyTweetFilter

extractHashtags() - Method in class tweetoscope.tweetsExtractor.TwitterKafkaHashtagsExtractor

F

fileName - Variable in class tweetoscope.tweetsProducer.MockTwitterStreamRecorded

File that holds the recorded Tweets

filteredTopic - Variable in class tweetoscope.tweetsFilter.TwitterKafkaFilter

G

getCountryCode(Tweet) - Method in class tweetoscope.tweetsFilter.CountryCodeTweetFilter

Returns the country code of the place tagged in a Tweet, if any.

getInstance() - Static method in class tweetoscope.tweetsProducer.TwitterSampledStreamReaderSingleton

getInstance(List<String>) - Static method in class tweetoscope.tweetsProducer.TwitterFilteredStreamReaderSingleton

H

HashtagCounter - Class in tweetoscope

Reacts to the reception of a new hashtag by updating how many times it has been seen so far, and sending to its subscribers the updated list of the most popular ones.

HashtagCounter(int) - Constructor for class tweetoscope.HashtagCounter

HashtagExtractor - Class in tweetoscope

Reacts to the reception of a new Tweet by parsing its text to look for hashtags.

HashtagExtractor() - Constructor for class tweetoscope.HashtagExtractor

hashtagOccurrenceMap - Variable in class tweetoscope.HashtagCounter

Map invalid input: '<'Hashtag text - number of occurrences>

K

keywords - Variable in class tweetoscope.tweetsProducer.TwitterFilteredStreamReaderSingleton

Keywords to search for (minimum 1, maximum 5)

L

LangTweetFilter - Class in tweetoscope.tweetsFilter

Filters Tweets according to the detected language.

LangTweetFilter(String) - Constructor for class tweetoscope.tweetsFilter.LangTweetFilter

Creates a filter that tests whether the "language" tag of a Tweet (if it is set) equals a given code.

language - Variable in class tweetoscope.tweetsFilter.LangTweetFilter

target language to match (examples: "fr", "en"...)

LastNTweetFilter - Class in tweetoscope.tweetsFilter

LastNTweetFilter(int) - Constructor for class tweetoscope.tweetsFilter.LastNTweetFilter

M

main(String[]) - Static method in class tweetoscope.tweetsAggregator.TwitterKafkaAggregator

Méthode principale pour exécuter l'agrégation.

main(String[]) - Static method in class tweetoscope.tweetsExtractor.TwitterKafkaHashtagsExtractor

main(String[]) - Static method in class tweetoscope.tweetsFilter.TwitterKafkaFilter

main(String[]) - Static method in class tweetoscope.tweetsProxy.TwitterProxy

Creates the proxy (provoking infinite execution).

main(String[]) - Static method in class tweetoscope.Visualizor

Méthode principale pour exécuter l'application.

match(Tweet) - Method in class tweetoscope.tweetsFilter.CountryCodeTweetFilter

match(Tweet) - Method in class tweetoscope.tweetsFilter.EmptyTweetFilter

match(Tweet) - Method in class tweetoscope.tweetsFilter.LangTweetFilter

match(Tweet) - Method in class tweetoscope.tweetsFilter.LastNTweetFilter

match(Tweet) - Method in class tweetoscope.tweetsFilter.TweetFilter

Tests the filter conditions

match(Tweet) - Method in class tweetoscope.tweetsFilter.UserAccountCreationYearTweetFilter

return true if the tweet was posted by an account created before 01/01/creationYear

MockTwitterStreamRandom - Class in tweetoscope.tweetsProducer

Mimics the TwitterStreamSampleReaderSingleton class.

MockTwitterStreamRandom() - Constructor for class tweetoscope.tweetsProducer.MockTwitterStreamRandom

Creates a new MockTwitterStreamRandom.

MockTwitterStreamRecorded - Class in tweetoscope.tweetsProducer

Mimics the TwitterStreamSampleReaderSingleton class.

MockTwitterStreamRecorded(String) - Constructor for class tweetoscope.tweetsProducer.MockTwitterStreamRecorded

Creates a MockTwitterStreamRecorded.

MockTwitterStreamScenario - Class in tweetoscope.tweetsProducer

Mimics the TwitterStreamSampleReaderSingleton class.

MockTwitterStreamScenario() - Constructor for class tweetoscope.tweetsProducer.MockTwitterStreamScenario

Creates a MockTwitterStreamScenario.

months_threshold - Variable in class tweetoscope.tweetsFilter.LastNTweetFilter

N

nbLeaders - Variable in class tweetoscope.HashtagCounter

Number of lines to include on the leader board

O

OfflineTweetsProducer - Class in tweetoscope.tweetsProducer

Produces Tweets without connecting to the Twitter API (recorded or crafted Tweets)

OfflineTweetsProducer() - Constructor for class tweetoscope.tweetsProducer.OfflineTweetsProducer

onClosed() - Method in class tweetoscope.tweetsProxy.TwitterProxy

Called if session closed.

onComment(String) - Method in class tweetoscope.tweetsProxy.TwitterProxy

Called if comment.

onComplete() - Method in class tweetoscope.HashtagCounter

onComplete() - Method in class tweetoscope.HashtagExtractor

onComplete() - Method in class tweetoscope.tweetsFilter.TweetFilter

onError(Throwable) - Method in class tweetoscope.HashtagCounter

onError(Throwable) - Method in class tweetoscope.HashtagExtractor

onError(Throwable) - Method in class tweetoscope.tweetsFilter.TweetFilter

onError(Throwable) - Method in class tweetoscope.tweetsProxy.TwitterProxy

Called if error.

OnlineTweetFilter - Class in tweetoscope.tweetsFilter

Deprecated.

Starting April 2023, this class can no longer be used with a "Free" access plan to the Twitter API. *

OnlineTweetFilter() - Constructor for class tweetoscope.tweetsFilter.OnlineTweetFilter

Deprecated.

OnlineTweetsProducer - Class in tweetoscope.tweetsProducer

Deprecated.

Starting April 2023, this class can no longer be used with a "Free" access plan to the Twitter API. It hasn't be tested with the "new" Basic access plan.

onNext(Tweet) - Method in class tweetoscope.HashtagExtractor

Triggered when the upstream component (TweetFilter) passes a new Tweet via Java Flow

onNext(Tweet) - Method in class tweetoscope.tweetsFilter.TweetFilter

onNext(String) - Method in class tweetoscope.HashtagCounter

Triggered by the reception of a new hashtag from a TweetFilter via Java Flow.

onOpen() - Method in class tweetoscope.tweetsProxy.TwitterProxy

Called if session opened.

onSubscribe(Flow.Subscription) - Method in class tweetoscope.HashtagCounter

onSubscribe(Flow.Subscription) - Method in class tweetoscope.HashtagExtractor

onSubscribe(Flow.Subscription) - Method in class tweetoscope.tweetsFilter.TweetFilter

P

previousLeaderMap - Variable in class tweetoscope.HashtagCounter

List of most popular hashtags, used to checked if the list is changed after a new hashtag is received

producer - Static variable in class tweetoscope.tweetsFilter.TwitterKafkaFilter

R

run() - Method in class tweetoscope.tweetsProducer.MockTwitterStreamRandom

Posts random Tweets to the

invalid reference

distributed_tweetoscope.TweetoscopeAppConfig#TWEETS_TOPIC_NAME

Kafka topic.

run() - Method in class tweetoscope.tweetsProducer.MockTwitterStreamRecorded

Reads Tweets from a file and forwards them to the Java Flow subscribers.

run() - Method in class tweetoscope.tweetsProducer.MockTwitterStreamScenario

Crafts a predefined set of Tweets and posts them to the Java Flow

run() - Method in class tweetoscope.tweetsProducer.TwitterFilteredStreamReaderSingleton

run() - Method in class tweetoscope.tweetsProducer.TwitterSampledStreamReaderSingleton

run() - Method in class tweetoscope.tweetsProxy.TwitterProxy

S

subscribe(Flow.Subscriber<? super Tweet>) - Method in class tweetoscope.tweetsFilter.TweetFilter

subscribe(Flow.Subscriber<? super Tweet>) - Method in class tweetoscope.tweetsProducer.TweetsProducer

subscribe(Flow.Subscriber<? super String>) - Method in class tweetoscope.HashtagExtractor

subscribe(Flow.Subscriber<? super Map<String, Integer>>) - Method in class tweetoscope.HashtagCounter

subscribers - Variable in class tweetoscope.HashtagCounter

List of objects to notify when the map is updated (downstream component = Visualizor)

subscribers - Variable in class tweetoscope.HashtagExtractor

List of objects to notify when a hashtag is extracted (downstream component = HashtagCounter)

subscribers - Variable in class tweetoscope.tweetsFilter.TweetFilter

List of objects to notify when a new Tweet passes the filter (downstream component = HashtagExtractor)

subscribers - Variable in class tweetoscope.tweetsProducer.TweetsProducer

List of objects to notify when a new Tweet is received (downstream components = TweetFilter)

T

TweetFilter - Class in tweetoscope.tweetsFilter

Reacts to the reception of a new Tweet, if the Tweet matches the filter condition, downstream subscribers are notified, otherwise the process is silent.

TweetFilter() - Constructor for class tweetoscope.tweetsFilter.TweetFilter

Creates a new Tweet filter

tweetoscope - package tweetoscope

tweetoscope.tweetsAggregator - package tweetoscope.tweetsAggregator

tweetoscope.tweetsExtractor - package tweetoscope.tweetsExtractor

tweetoscope.tweetsFilter - package tweetoscope.tweetsFilter

tweetoscope.tweetsProducer - package tweetoscope.tweetsProducer

tweetoscope.tweetsProxy - package tweetoscope.tweetsProxy

tweetsFilter - Variable in class tweetoscope.tweetsFilter.TwitterKafkaFilter

TweetsProducer - Class in tweetoscope.tweetsProducer

Introduces Tweets into the system.

TweetsProducer() - Constructor for class tweetoscope.tweetsProducer.TweetsProducer

tweetTopic - Variable in class tweetoscope.tweetsFilter.TwitterKafkaFilter

twitterApiInstance - Static variable in class tweetoscope.tweetsFilter.OnlineTweetFilter

Deprecated.

Twitter API instance

TwitterFilteredStreamReaderSingleton - Class in tweetoscope.tweetsProducer

Connects to the Twitter search stream endpoint and search for Tweets with given keywords (minimum 1, maximum 5).

TwitterKafkaAggregator - Class in tweetoscope.tweetsAggregator

Classe pour agréger les hashtags provenant d'un topic Kafka et afficher les meilleurs hashtags.

TwitterKafkaAggregator(String, String, String, int) - Constructor for class tweetoscope.tweetsAggregator.TwitterKafkaAggregator

Constructeur de la classe.

TwitterKafkaFilter - Class in tweetoscope.tweetsFilter

Reacts to the reception of a new Tweet, if the Tweet matches the filter condition, downstream subscribers are notified, otherwise the process is silent.

TwitterKafkaFilter(String, String, String, String, String) - Constructor for class tweetoscope.tweetsFilter.TwitterKafkaFilter

TwitterKafkaHashtagsExtractor - Class in tweetoscope.tweetsExtractor

TwitterKafkaHashtagsExtractor(String, String, String) - Constructor for class tweetoscope.tweetsExtractor.TwitterKafkaHashtagsExtractor

TwitterProxy - Class in tweetoscope.tweetsProxy

Acts as a proxy to Twitter changes web stream for a Kafka-based application: Reads the stream of Tweets flow and writes them to a Kafka topic.

TwitterProxy(String, String, String) - Constructor for class tweetoscope.tweetsProxy.TwitterProxy

Class constructor : Creates a web stream listener and a Kafka producer, the producer publishes to the Kafka topic the events received from the web stream (until it is interrupted).

TwitterSampledStreamReaderSingleton - Class in tweetoscope.tweetsProducer

Connects to the Twitter sampled stream endpoint that delivers a roughly 1% random sample of publicly available Tweets in read-time.

U

UserAccountCreationYearTweetFilter - Class in tweetoscope.tweetsFilter

Filter Tweets according to the creation year of the author's account

UserAccountCreationYearTweetFilter(int) - Constructor for class tweetoscope.tweetsFilter.UserAccountCreationYearTweetFilter

V

Visualizor - Class in tweetoscope

Classe pour visualiser les hashtags populaires en utilisant des données d'un topic Kafka.

Visualizor(String, String, int) - Constructor for class tweetoscope.Visualizor

Constructeur de la classe Visualizor.

A B C E F G H K L M N O P R S T U V
All Classes and Interfaces|All Packages|Serialized Form