Skip to content

Instantly share code, notes, and snippets.

View chinmaychandak's full-sized avatar

Chinmay Chandak chinmaychandak

2 followers · 0 following
View GitHub Profile
@chinmaychandak
chinmaychandak / custreamz_distributed_word_count.ipynb
Last active October 30, 2020 17:58
cuStreamz Word Count @ Scale
Loading
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
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
@chinmaychandak
chinmaychandak / custreamz-word-count.ipynb
Created April 21, 2020 18:15
custreamz-word-count
Loading
Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
@chinmaychandak
chinmaychandak / word-count-kafka.py
Last active August 10, 2020 18:27
'''
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