| Mode | Name | Size | |
|---|---|---|---|
| -rw-r--r-- | .gitignore | 1825 | logplain |
| -rw-r--r-- | LICENSE | 1065 | logplain |
| -rw-r--r-- | README.md | 960 | logplain |
| -rw-r--r-- | SentimentAnalyser.py | 1333 | logplain |
| -rw-r--r-- | consumer.py | 2994 | logplain |
| -rw-r--r-- | database_configuration.py | 1469 | logplain |
| -rw-r--r-- | predictor.py | 198 | logplain |
| -rw-r--r-- | producer.py | 1350 | logplain |
| -rw-r--r-- | pySparkExample.py | 671 | logplain |
| -rw-r--r-- | requirements.txt | 91 | logplain |
| -rw-r--r-- | tweets.csv | 10769342 | logplain |
 |
index : KafkaPySpark | |
| Fetching tweets and integrating it with Kafka and PySpark. |
| aboutsummaryrefslogtreecommitdiff |