Skip to content

Instantly share code, notes, and snippets.

@chinmaychandak
chinmaychandak / custreamz_distributed_word_count.ipynb
Last active October 30, 2020 17:58
cuStreamz Word Count @ Scale
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
@chinmaychandak
chinmaychandak / custreamz-CCU-state-management.ipynb
Created April 24, 2020 17:54
custreamz-CCU-state-management
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
'''
To stream from Kafka, please refer to the streamz API here: https://streamz.readthedocs.io/en/latest/api.html#sources
You can refer to https://kafka.apache.org/quickstart to start a local Kafka cluster.
Below is an example snippet to start a stream from Kafka.
'''
from custreamz import kafka
# Kafka topic to read streaming data from