A simple spark streaming handler.
Project description
Spark Streaming Package
Package: SparkStream-pypi
What is it?
It is a handler for processing streaming text data from a kafka topic into cassandra and redis.
How it works?
The stream processing is done by the following steps:
- Read data from kafka topic
- Parse the data into a spark dataframe with a schema
- Clean the data: remove unwanted chars, fix abbreviations, remove stop-words, and remove empty fields
- Save the data into cassandra and redis
How to use it?
Use its API: SparkStream-API github
Dependency
The package requires the following dependency:
- spark-redis_2.12-3.1.0-jar-with-dependencies.jar (mvn Repository)
Its so to be able to write data into redis.
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
SparkStream-1.3.0.tar.gz
(1.2 MB
view hashes)
Built Distribution
Close
Hashes for SparkStream-1.3.0-py3-none-any.whl
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 2ec79c6457dfb826534a17d3e5ecf511a8fdfe97b8b02614c95dc15b7e9de573 |
|
| MD5 | 82ef110612c62b8072b90079d7962c14 |
|
| BLAKE2b-256 | 824d87d7466c45922d4122d8227dc3829d65ba35b60ecfb4e65b2d4696ddb557 |
