GitHub - SAI-MOHAN-B/Spark-Structured-Streaming: This repo is for the Structured Streaming and Projects

SAI-MOHAN-B / Spark-Structured-Streaming Public

This repo is for the Structured Streaming and Projects

Notifications

Name		Name	Last commit message	Last commit date
Latest commit History 3 Commits
batch-word-count-data.py		batch-word-count-data.py
batch-word-count-test-suite.py		batch-word-count-test-suite.py
idempotent-kafka-to-bronze.py		idempotent-kafka-to-bronze.py
incremental-streaming-aggregates-testsuite.py		incremental-streaming-aggregates-testsuite.py
incremental-streaming-aggregates.py		incremental-streaming-aggregates.py
invoice-stream-trigger-test-suite.py		invoice-stream-trigger-test-suite.py
invoice-stream-trigger.py		invoice-stream-trigger.py
invoice-streaming-test-suite.py		invoice-streaming-test-suite.py
invoice-streaming.py		invoice-streaming.py
kafka-consumer.py		kafka-consumer.py
kafka-to-bronze-testsuite.py		kafka-to-bronze-testsuite.py
kafka-to-bronze.py		kafka-to-bronze.py
sliding-window-aggregate-testsuite.py		sliding-window-aggregate-testsuite.py
sliding-window-aggregate.py		sliding-window-aggregate.py
stream-word-count-test-suite.py		stream-word-count-test-suite.py
stream-word-count.py		stream-word-count.py
streaming-aggregates-testsuite.py		streaming-aggregates-testsuite.py
streaming-aggregates.py		streaming-aggregates.py
streaming-unbounded-aggregates-testsuite.py		streaming-unbounded-aggregates-testsuite.py
streaming-unbounded-aggregates.py		streaming-unbounded-aggregates.py
streaming-word-count.py		streaming-word-count.py
tumbling-time-window-test-suite.py		tumbling-time-window-test-suite.py
tumbling-time-window.py		tumbling-time-window.py
word-count-ingestion-batch.py		word-count-ingestion-batch.py