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.
1 maintainer
Release files for SparkStream 1.3.0
For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.
Source distribution (sdist)
| File | Size | Uploaded | |
|---|---|---|---|
| SparkStream-1.3.0.tar.gz | 1.2 MB | Details |
Built distribution (wheel)
| File | Interpreter | ABI | Platform | Reset |
|---|---|---|---|---|
| SparkStream-1.3.0-py3-none-any.whl | Python 3 | none | any | Details |
Total release size: 1.2 MB
Release files / SparkStream-1.3.0.tar.gz
| Download URL | SparkStream-1.3.0.tar.gz |
|---|---|
| Size | 1.2 MB |
| Tags | Source |
|
SHA-256 checksum How to use checksums |
21f469564de160ada453493268819a8eb7657703cc8b5db4f767a4f10cc3f509
|
|
BLAKE2b-256 checksum How to use checksums |
b00d85c90186cfa7cb1e011e4c33ad4db6ae90903b7dbcca9670b8b2bfe77d1c
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/4.0.1 CPython/3.9.12
|
Release files / SparkStream-1.3.0-py3-none-any.whl
| Download URL | SparkStream-1.3.0-py3-none-any.whl |
|---|---|
| Size | 8.0 kB |
| Tags | Python 3 |
|
SHA-256 checksum How to use checksums |
2ec79c6457dfb826534a17d3e5ecf511a8fdfe97b8b02614c95dc15b7e9de573
|
|
BLAKE2b-256 checksum How to use checksums |
824d87d7466c45922d4122d8227dc3829d65ba35b60ecfb4e65b2d4696ddb557
|
| Upload date | |
|
Uploaded using Trusted Publishing? What is trusted publishing? |
No |
| Uploaded via |
twine/4.0.1 CPython/3.9.12
|
