Data Flow

Tweepy -> Spark Runing on Hadoop [Count] -> Kafak Producer[Topic For Each HashTag ] -> Kafak Consumers

Tech used

Kafka Zookeeper Spark Hadoop

Name		Name	Last commit message	Last commit date
Latest commit History 3 Commits
.gitignore		.gitignore
README.md		README.md
consumer.py		consumer.py
read_stream.py		read_stream.py
requirements.txt		requirements.txt
result.csv		result.csv
stream.py		stream.py
test.py		test.py