Run Python in Apache Storm topologies. Pythonic API, CLI tooling, and a topology DSL.
-
Updated
Oct 7, 2020 - Python
#
apache-storm
Here are 71 public repositories matching this topic...
Code examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while using Apache Avro as the data serialization format.
-
Updated
Jan 24, 2017 - Scala
Wirbelsturm is a Vagrant and Puppet based tool to perform 1-click local and remote deployments, with a focus on big data tech like Kafka.
-
Updated
Sep 14, 2015 - Shell
Fast Advanced Spam Analysis Tool
python
docker
security
ansible
ansible-playbook
docker-image
smtp
outlook
application-security
mail-analyzer
spam-analyzer
streamparse
apache-storm
dialect
spamscope
-
Updated
Aug 13, 2020 - Python
News crawling with Storm-crawler - stores content as WARC
-
Updated
Sep 21, 2020 - Java
Battle-tested Apache Storm Multi-Lang implementation for Python
-
Updated
Jan 7, 2019 - Python
A curated list of Pulsar tools, integrations and resources.
spark
apache-spark
messaging
prometheus
apache-storm
apache-flink
apache-kafka
pub-sub
grafana-dashboard
spark-sql
elastic-beats
spark-structured-streaming
apache-bookkeeper
apache-pulsar
-
Updated
Dec 25, 2019
Docker image packaging for Apache Storm
-
Updated
Jul 5, 2020 - Dockerfile
A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.
-
Updated
Mar 27, 2020 - Java
This repository focuses on gathering and making a curated list resources to learn Hadoop for FREE.
apache-spark
yarn
hive
hadoop
bigdata
impala
hbase
pig
apache-storm
mapreduce
flume
oozie
apache-kafka
sqoop
apache-solr
hadoop-filesystem
apache-ranger
hiveql
apache-atlas
apache-knox
-
Updated
Jun 10, 2018 - Python
Storm Debian Packaging with dpkg-buildpackage
-
Updated
Jun 18, 2018 - Makefile
Apache Storm cluster on Docker
-
Updated
May 31, 2018 - Java
A dockerized image of Apache Storm (Zookeeper, Nimbus, Supervisor, Ui, Logviewer.)
dockerfile
storm
docker-container
docker-image
apache
supervisor
zookeeper
apache-storm
nimbus
storm-dockerfile
-
Updated
Aug 16, 2018 - Dockerfile
Real time computation system with Apache Storm, Apache Kafka and Google Guice
-
Updated
Jun 10, 2016 - Java
My Talk at IoT Fusion 2018 Philadelphia, PA
-
Updated
Apr 5, 2018 - Python
Investigating the trade-offs of low latency responses over quality when applying machine learning algorithms over lambda architecture.
-
Updated
Jun 3, 2016 - Java
Apache Storm Spout for Redis Streams.
-
Updated
Sep 3, 2020 - Java
A stream processing project that analyzes the chat stream of a Twitch channel. Built on Apache Storm for CS442 Distributed Systems course.
-
Updated
Oct 15, 2019 - Java
Easily and reliably manage complex, distributed infrastructure
nodejs
aws-lambda
topology
serverless
distributed-computing
kinesis
kinesis-stream
apache-storm
cloud-function
-
Updated
Jul 2, 2017 - CoffeeScript
A real-time, dockerized Kafka event processor pipeline (utilizing an Apache Storm topology). The project is running in AWS with automated infrastructure deployment and execution, using Ansible.
docker
ansible
aws-s3
java-8
apache-storm
aws-ec2
apache-kafka
aws-rds
aws-elasticache
apache-zookeeper
-
Updated
Mar 17, 2019 - Java
Dockerfile for SpamScope Elasticsearch
-
Updated
Oct 28, 2018 - Dockerfile
-
Updated
Dec 1, 2017 - Java
Repository for a Apache Storm course I'll give to my co-workers
-
Updated
May 9, 2017 - Java
Apache Storm implementation of real-time flight monitor for top 40 airfields in the U.S.
-
Updated
May 15, 2019 - Java
CISC 5950 Big Data Programming Final Project. Storm cluster tutorial and application.
-
Updated
Dec 20, 2017 - Python
Storm topology debugger/inspector
-
Updated
Feb 21, 2017 - CSS
Ingest live tweets with Apache Storm and stores word count in Postgres database for analysis
-
Updated
Sep 5, 2017 - Python
Improve this page
Add a description, image, and links to the apache-storm topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the apache-storm topic, visit your repo's landing page and select "manage topics."
Just like it's done in ES, we could route the documents in the statusupdaterbolt based on the host / name or IP and in the spouts check that the number of instances is equal to the # of shards and filter the queries per shard accordingly.
At the moment, we can have only one instance of a spout.
https://lucene.apache.org/solr/guide/6_6/shards-and-indexing-data-in-solrcloud.html