Topic: "stream-processing"
IBMStreams/streamsx.inet
This toolkit supports common internet protocols, such as HTTP and WebSockets
Language: Java - Size: 14.9 MB - Last synced at: 17 days ago - Pushed at: over 4 years ago - Stars: 10 - Forks: 28
codefeedr/codefeedr
CodeFeedr core infrastructure
Language: Scala - Size: 7.79 MB - Last synced at: about 18 hours ago - Pushed at: over 4 years ago - Stars: 10 - Forks: 6
DeathReaper0965/distributed-deeplearning
End to End Distributed Deep Learning Engine, works both with Streaming and Batch Data built using Apache Flink
Language: Java - Size: 278 KB - Last synced at: about 2 years ago - Pushed at: over 4 years ago - Stars: 10 - Forks: 0
DivLoic/xke-ratatouille
:pill:Poison pills and Kafka Streams demo:curry::rat:
Language: Scala - Size: 3.51 MB - Last synced at: over 1 year ago - Pushed at: almost 5 years ago - Stars: 10 - Forks: 2
anicolaspp/minikaf
Minikaf is a minimal implementation of Publish / Subscriber for in memory communication.
Language: Scala - Size: 40 KB - Last synced at: 12 days ago - Pushed at: over 6 years ago - Stars: 10 - Forks: 0
jweinst1/Fire
The Reactive Programming Language
Language: C - Size: 131 KB - Last synced at: 3 days ago - Pushed at: over 7 years ago - Stars: 10 - Forks: 0
AskMeAgain/Event-Meshinery
A new Framework for asynchronous signaling of processes via Kafka/Mysql/anything.
Language: Java - Size: 1.86 MB - Last synced at: 13 days ago - Pushed at: 14 days ago - Stars: 9 - Forks: 0
glassflow/glassflow-python-sdk
GlassFlow Python SDK to publish and consume data to your pipelines at Glassflow.dev
Language: Python - Size: 4.69 MB - Last synced at: 23 days ago - Pushed at: 2 months ago - Stars: 9 - Forks: 0
confluentinc/flink-table-api-java-examples
Java Examples for running Apache Flink® Table API on Confluent Cloud
Language: Java - Size: 98.6 KB - Last synced at: 3 months ago - Pushed at: 3 months ago - Stars: 9 - Forks: 3
glassflow/example-real-time-ai-alerts
Real-Time Alerts with AI, NATs and Streamlit
Language: Python - Size: 261 KB - Last synced at: 20 days ago - Pushed at: 4 months ago - Stars: 9 - Forks: 1
IBMStreams/streamsx.hbase
Integration of IBM Streams and Apache HBase
Language: Java - Size: 3.78 MB - Last synced at: 17 days ago - Pushed at: over 1 year ago - Stars: 9 - Forks: 12
IBMStreams/streamsx.hdfs
This toolkit provides operators and functions for interacting with Hadoop File System.
Language: Java - Size: 152 MB - Last synced at: about 17 hours ago - Pushed at: over 1 year ago - Stars: 9 - Forks: 20
jkrukoff/llists
An Erlang/OTP library for lazily evaluated lists.
Language: Erlang - Size: 307 KB - Last synced at: 7 days ago - Pushed at: almost 2 years ago - Stars: 9 - Forks: 1
sunsided/Graph 📦
.NET pipeline/dataflow data processing framework written in C#
Language: C# - Size: 140 KB - Last synced at: about 1 year ago - Pushed at: almost 4 years ago - Stars: 9 - Forks: 1
patrobinson/go-fish
A Stream Processor written in Golang that support pluggable tasks
Language: Go - Size: 3.35 MB - Last synced at: 10 months ago - Pushed at: about 4 years ago - Stars: 9 - Forks: 2
Zensey/go-data-routing
Pipelined data routing/trasnformation engine
Language: Go - Size: 45.9 KB - Last synced at: 4 days ago - Pushed at: over 4 years ago - Stars: 9 - Forks: 1
segeljakt/swag
Sliding Window Aggregation
Language: Rust - Size: 57.6 KB - Last synced at: 17 days ago - Pushed at: almost 5 years ago - Stars: 9 - Forks: 0
gAmUssA/streaming-movie-ratings-min-0519
A small version of of https://github.com/confluentinc/demo-scene/tree/master/streams-movie-demo
Language: Java - Size: 531 KB - Last synced at: 17 days ago - Pushed at: almost 5 years ago - Stars: 9 - Forks: 2
kimaina/openmrs-etl
openmrs - mysql - debezium - kafka - spark - scala
Language: TSQL - Size: 23.3 MB - Last synced at: over 1 year ago - Pushed at: about 5 years ago - Stars: 9 - Forks: 13
sophatvathana/http-ipcamera
Language: C++ - Size: 232 MB - Last synced at: almost 2 years ago - Pushed at: about 5 years ago - Stars: 9 - Forks: 2
nitely/regexy 📦
:wavy_dash: Linear time regex matching supporting streams and other goodies
Language: Python - Size: 122 KB - Last synced at: 6 months ago - Pushed at: over 5 years ago - Stars: 9 - Forks: 1
DataSystemsGroupUT/Adaptive-Watermarks
An approach to apply concept drifts and ADWIN on the streams event time to reason about the progress of watermarks
Language: Java - Size: 527 KB - Last synced at: about 2 years ago - Pushed at: over 6 years ago - Stars: 9 - Forks: 0
marklogic/kafka-marklogic-connector
A Kafka connector for subscribing to topics and streaming messages into MarkLogic
Language: Java - Size: 33.3 MB - Last synced at: 3 days ago - Pushed at: 4 days ago - Stars: 8 - Forks: 16
Point72/csp-bot
Reactive chat bot framework
Language: Python - Size: 345 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 8 - Forks: 1
Point72/csp-adapter-symphony
A csp adapter for symphony
Language: Python - Size: 126 KB - Last synced at: 2 days ago - Pushed at: 15 days ago - Stars: 8 - Forks: 3
floodplainio/floodplain-library
Kotlin based stream processing framework
Language: Java - Size: 66.1 MB - Last synced at: 26 days ago - Pushed at: 26 days ago - Stars: 8 - Forks: 2
mihaitodor/benthos-playground
Various https://benthos.dev experiments
Language: HTML - Size: 192 KB - Last synced at: 7 days ago - Pushed at: about 2 months ago - Stars: 8 - Forks: 2
mkuthan/stream-processing
Learn how to develop and test stateful streaming and batch data pipelines
Language: Scala - Size: 24.9 MB - Last synced at: 19 days ago - Pushed at: about 2 months ago - Stars: 8 - Forks: 2
IBMStreams/streamsx.sparkMLLib
Toolkit for real-time scoring using Apache Spark MLLib library
Language: Java - Size: 2.23 MB - Last synced at: 17 days ago - Pushed at: over 1 year ago - Stars: 8 - Forks: 15
IBCNServices/StreamingMASSIF Fork of pbonte/StreamingMASSIF
Cascading Stream Reasoning with Streaming MASSIF
Language: Java - Size: 1.11 MB - Last synced at: about 1 year ago - Pushed at: almost 2 years ago - Stars: 8 - Forks: 2
AlexKbit/videostream
Anonymize faces in video stream
Language: Python - Size: 17.7 MB - Last synced at: about 2 years ago - Pushed at: over 2 years ago - Stars: 8 - Forks: 3
IBMStreams/streamsx.documentation
Streams documentation project for writing development guides and documentation
Language: HTML - Size: 70.6 MB - Last synced at: about 1 month ago - Pushed at: over 2 years ago - Stars: 8 - Forks: 24
bastion-rs/bastion-streams
Reactive stream processing framework
Language: Rust - Size: 1.11 MB - Last synced at: 7 days ago - Pushed at: almost 4 years ago - Stars: 8 - Forks: 1
nienie/window
golang sliding or tumbling window stream-processing
Language: Go - Size: 18.6 KB - Last synced at: about 2 years ago - Pushed at: about 4 years ago - Stars: 8 - Forks: 2
IBMStreams/streamsx.tcp
(Incubation) TCPServer is a multi-connection, multi-threaded operator that allows for full duplex TCP communication.
Language: C++ - Size: 268 KB - Last synced at: 17 days ago - Pushed at: over 4 years ago - Stars: 8 - Forks: 8
iravid/stream-processing-with-scala
Stream Processing with Scala - course exercises
Language: Scala - Size: 56.6 KB - Last synced at: 16 days ago - Pushed at: almost 5 years ago - Stars: 8 - Forks: 5
hstream-io/hstream 📦
High Performance Stream Data Processing for IoT in 5G Era
Language: Nix - Size: 6.84 KB - Last synced at: about 2 years ago - Pushed at: over 5 years ago - Stars: 8 - Forks: 0
sedgecloud/ECSNeTpp
ECSNeT++ is a simulation framework built on OMNeT++ for Distributed Stream Processing applications running on Edge and Cloud computing environments.
Language: C++ - Size: 92.8 KB - Last synced at: over 1 year ago - Pushed at: almost 6 years ago - Stars: 8 - Forks: 5
stephenlb/eon-spark
Developers can create lovely visuals from live data streams. EON Spark is the visual representation of live streaming data, the way you would imagine. iOS, Android and web browsers.
Size: 43.9 KB - Last synced at: 25 days ago - Pushed at: about 7 years ago - Stars: 8 - Forks: 0
Point72/csp-adapter-slack
A csp adapter for slack
Language: Python - Size: 80.1 KB - Last synced at: 5 days ago - Pushed at: 5 days ago - Stars: 7 - Forks: 1
dylanmei/statefun-examples
Dylan's Flink Stateful Functions examples
Language: Kotlin - Size: 145 KB - Last synced at: 24 days ago - Pushed at: over 1 year ago - Stars: 7 - Forks: 1
itsubaki/gostream-server 📦
Stream Processing Server written in Go
Language: Go - Size: 77.1 KB - Last synced at: 10 months ago - Pushed at: about 2 years ago - Stars: 7 - Forks: 0
NickDarvey/Qx 📦
Qx is library which extends ASP.NET's SignalR so that clients can query streams using LINQ
Language: C# - Size: 202 KB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 7 - Forks: 1
relloyd/halfpipe 📦
Halfpipe is an ELT utility and microservice that streams data into Snowflake from S3, Oracle, SQL Server, Netezza and more. Continuous data integration patterns wrapped into single commands. ODBC support is available and Postgres is on the roadmap.
Language: Go - Size: 64.2 MB - Last synced at: 10 months ago - Pushed at: about 3 years ago - Stars: 7 - Forks: 3
grtheod/Hammerslide
Hammerslide is an algorithm for sliding window aggregation that uses SIMD instructions.
Language: C++ - Size: 136 KB - Last synced at: over 1 year ago - Pushed at: about 3 years ago - Stars: 7 - Forks: 1
cross-platform/route20
Cross-Platform C++ Dataflow / Pipelining / Stream Processing / Reactive Metaprogramming Framework
Language: C++ - Size: 11.7 KB - Last synced at: about 2 years ago - Pushed at: over 3 years ago - Stars: 7 - Forks: 4
Data-Wrangling-with-JavaScript/Chapter-7
Code examples for Chapter 7 of Data Wrangling with JavaScript
Language: JavaScript - Size: 752 KB - Last synced at: about 1 year ago - Pushed at: over 3 years ago - Stars: 7 - Forks: 3
mikbry/vpiper
Nextgen cross-platform solution to transform, transcode and stream medias in Realtime using hardware acceleration and ML.
Language: JavaScript - Size: 32.2 KB - Last synced at: 10 days ago - Pushed at: almost 4 years ago - Stars: 7 - Forks: 1
RPI-WCL/pilots
PILOTS (ProgrammIng Language for spatiO-Temporal data Streaming applications)
Language: Java - Size: 17.6 MB - Last synced at: 9 months ago - Pushed at: almost 5 years ago - Stars: 7 - Forks: 5
nextorigin/sseries-of-tubes
Takes Express/Connect routes and creates stream.Writable endpoints for Server Sent Events
Language: CoffeeScript - Size: 74.2 KB - Last synced at: 6 days ago - Pushed at: almost 5 years ago - Stars: 7 - Forks: 0
huangyanbin/SmartFlow
Android streaming response （Android 流式响应）
Language: Java - Size: 231 KB - Last synced at: 13 days ago - Pushed at: about 5 years ago - Stars: 7 - Forks: 1
lucylow/l3gacy_fps
Anti-Cheat Detection for Game Streaming
Size: 2.93 KB - Last synced at: 12 months ago - Pushed at: over 5 years ago - Stars: 7 - Forks: 3
metanet-ci/joker
an experimental stream processing engine
Language: Java - Size: 3.53 MB - Last synced at: 11 months ago - Pushed at: about 6 years ago - Stars: 7 - Forks: 3
trbck/streamengine
Python Stream Processing With Redis Streams
Language: Python - Size: 34.2 KB - Last synced at: about 2 years ago - Pushed at: about 6 years ago - Stars: 7 - Forks: 1
asavinov/bistro
A general-purpose data analysis engine radically changing the way batch and stream data is processed
Language: Java - Size: 2.16 MB - Last synced at: 29 days ago - Pushed at: over 6 years ago - Stars: 7 - Forks: 0
trK54Ylmz/musik
Musik: Music recognition application
Language: Java - Size: 3.33 MB - Last synced at: 25 days ago - Pushed at: over 6 years ago - Stars: 7 - Forks: 0
Adsizzlerlabs/mangolaa-streams-processing-flink
Stream processing for the Mangolaa platform using Apache Kafka, Apache Flink, Java 8 and Lombok
Language: Java - Size: 55.7 KB - Last synced at: about 2 years ago - Pushed at: about 7 years ago - Stars: 7 - Forks: 3
dgallitelli/IOTStreamMining-TPT
Official repo for DK904 - IOT Stream Data Mining
Language: Python - Size: 33.5 MB - Last synced at: over 1 year ago - Pushed at: about 7 years ago - Stars: 7 - Forks: 3
graylog-labs/graylog-plugin-riemann
Graylog2 output plugin to send events to a Riemann instance
Language: Java - Size: 27.3 KB - Last synced at: about 2 years ago - Pushed at: over 8 years ago - Stars: 7 - Forks: 1
glassflow/cli
GlassFlow CLI to create and manage real-time data pipelines
Language: Shell - Size: 15.6 KB - Last synced at: 20 days ago - Pushed at: 5 months ago - Stars: 6 - Forks: 0
liflab/beepbeep-3-palettes
A bundle of user-contributed extensions to BeepBeep 3
Language: Java - Size: 4.88 MB - Last synced at: 8 months ago - Pushed at: 8 months ago - Stars: 6 - Forks: 6
martin-majlis/py-probstructs
Collection of probabilistic data structures - CM-Sketch, ECM-Sketch, exponential histogram
Language: C++ - Size: 79.1 KB - Last synced at: 20 days ago - Pushed at: 8 months ago - Stars: 6 - Forks: 1
NeutrinoCorp/streams
:envelope: Streams is a toolkit crafted for data-in-motion ecosystems written in Go.
Language: Go - Size: 760 KB - Last synced at: 10 months ago - Pushed at: over 1 year ago - Stars: 6 - Forks: 3
criblpacks/cribl-knowledge-pack
Examples of best-in-class use cases curated from community members and Cribl Solutions Engineers.
Size: 594 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 6 - Forks: 3
aws-samples/aws-serverless-failure-modes
Serverless failure modes is a sample application that illustrates common patterns and best practices around failure handling between components.
Language: Python - Size: 226 KB - Last synced at: almost 2 years ago - Pushed at: almost 2 years ago - Stars: 6 - Forks: 2
questdb/flink-questdb-connector
QuestDB ILP connector for Apache Flink
Language: Java - Size: 1.07 MB - Last synced at: over 1 year ago - Pushed at: about 2 years ago - Stars: 6 - Forks: 1
GuinsooLab/duskbladesql
A streaming database for real-time applications
Language: Rust - Size: 7.7 MB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 6 - Forks: 0
GuinsooLab/hurricanedb
A real-time distributed OLAP engine
Language: Java - Size: 62.4 MB - Last synced at: about 2 years ago - Pushed at: about 2 years ago - Stars: 6 - Forks: 2
signicode/humanify
Add human touch to otherwise very machined node.js streams.
Language: JavaScript - Size: 2.64 MB - Last synced at: 4 days ago - Pushed at: over 2 years ago - Stars: 6 - Forks: 1
criblpacks/cribl-syslog-input
This Pack enables a variety of functions when LogStream is used to receive data from Syslog senders.
Size: 85 KB - Last synced at: about 1 year ago - Pushed at: over 2 years ago - Stars: 6 - Forks: 1
spencermountain/sunday-driver
be cool with large files
Language: JavaScript - Size: 1.91 MB - Last synced at: 7 days ago - Pushed at: about 3 years ago - Stars: 6 - Forks: 1
hisah/Multilevel-Streaming-Analytics
A Multilevel Streaming Data Analytics Infrastructure for Predictive Analytics
Size: 51.4 MB - Last synced at: about 2 years ago - Pushed at: about 3 years ago - Stars: 6 - Forks: 5
Coursal/FFMPEG-Streaming-Video
A 3-part Java application of video streaming and management using the FFMPEG tool and wrapper.
Language: Java - Size: 862 KB - Last synced at: 11 months ago - Pushed at: over 3 years ago - Stars: 6 - Forks: 1
onlinestats/online-stats
Online algorithms for data exploration and analysis
Language: JavaScript - Size: 33.2 KB - Last synced at: 4 days ago - Pushed at: over 3 years ago - Stars: 6 - Forks: 0
IBMStreams/streamsx.document
(Incubation) This toolkit allows extract text and metadata from documents in a binary formats such as PDF, Word, Office, etc
Language: Java - Size: 59.6 MB - Last synced at: 17 days ago - Pushed at: almost 5 years ago - Stars: 6 - Forks: 1
doganulus/reelay-codegen
A code generator from high-level formal specifications for monitoring and pattern matching sequential/temporal data.
Language: Python - Size: 7.87 MB - Last synced at: 20 days ago - Pushed at: over 5 years ago - Stars: 6 - Forks: 1
fediazgon/flink-vehicle-telematics
Stream processing of simulated on-vehicle sensors data
Language: Java - Size: 1.2 MB - Last synced at: over 1 year ago - Pushed at: over 5 years ago - Stars: 6 - Forks: 2
thomas-chauvet/predict-xgboost-flink
Use xgboost model to score data on Flink's datastream
Language: Scala - Size: 84 KB - Last synced at: over 1 year ago - Pushed at: about 6 years ago - Stars: 6 - Forks: 2
soundvibe/reacto
Functional reactive microservices for the JVM. Uses Observables for composing event streams.
Language: Java - Size: 588 KB - Last synced at: 4 days ago - Pushed at: about 6 years ago - Stars: 6 - Forks: 3
AmmarRashed/EventOrient
A web-based application for monitoring, analyzing and visualizing social networks of Istanbul Sehir University
Language: Jupyter Notebook - Size: 305 MB - Last synced at: 4 months ago - Pushed at: over 6 years ago - Stars: 6 - Forks: 2
alvarag/ConceptDriftMOA
Machine Learning algorithms for MOA designed to cope with concept drift.
Language: Java - Size: 14.2 MB - Last synced at: 22 days ago - Pushed at: about 7 years ago - Stars: 6 - Forks: 2
giobyte8/RTSPViewer
A Dynamic android player for RSTP Streams over network. Very useful to test streamming servers
Language: Java - Size: 662 KB - Last synced at: about 2 years ago - Pushed at: almost 8 years ago - Stars: 6 - Forks: 3
zduey/iex
Near Real-Time Stock Quote Streaming with Bokeh
Language: Python - Size: 13.7 KB - Last synced at: almost 2 years ago - Pushed at: about 8 years ago - Stars: 6 - Forks: 7
zertyz/reactive-mutiny
async Event-Driven Reactive Library for Rust with optimized Stream executors -- loosely inspired on SmallRye's Mutiny Java Library
Language: Rust - Size: 5.14 MB - Last synced at: 6 days ago - Pushed at: 6 days ago - Stars: 5 - Forks: 0
akhenakh/geo-bento
Benthos plugins to transform geographic coordinates from a stream.
Language: Go - Size: 446 KB - Last synced at: 1 day ago - Pushed at: 9 days ago - Stars: 5 - Forks: 0
picotera/lawn
A C implementation of the Lawn data structure
Language: C - Size: 13.8 MB - Last synced at: 9 days ago - Pushed at: 9 days ago - Stars: 5 - Forks: 1
creek-service/creek-kafka
Creek Kafka support
Language: Java - Size: 2.25 MB - Last synced at: 3 days ago - Pushed at: 12 days ago - Stars: 5 - Forks: 0
kfrancischen/pslx
Python Standard Library eXtension
Language: Python - Size: 1.82 MB - Last synced at: 6 months ago - Pushed at: almost 2 years ago - Stars: 5 - Forks: 1
tabletop-labs/tabletop
A curated selection of tools, libraries and services that help tame your dataflow to productively build ambitious, data driven & reactive applications on a streaming lakehouse
Language: Go - Size: 290 KB - Last synced at: about 23 hours ago - Pushed at: almost 2 years ago - Stars: 5 - Forks: 0
qedus/tamar
A super fast stream processing framework that somewhat mirrors Apache Flink's streaming primitives and is designed for simplicity.
Language: Rust - Size: 31.3 KB - Last synced at: 10 days ago - Pushed at: almost 2 years ago - Stars: 5 - Forks: 0
foorenxiang/OHR400Dashboard
UAV Flight Analysis and ML-powered Rolling Launch Control System. Written in Python and q/kdb+. Deployed at:
Language: Python - Size: 168 MB - Last synced at: 2 days ago - Pushed at: about 2 years ago - Stars: 5 - Forks: 1
GuiaBolso/sftp-to-s3-connector
Library to provide easy trasfer from an SFTP server to a Amazon S3 file
Language: Kotlin - Size: 122 KB - Last synced at: 17 days ago - Pushed at: over 2 years ago - Stars: 5 - Forks: 1
rmetzger/flink-utils
Optional utilities for Apache Flink®
Language: Java - Size: 37.1 KB - Last synced at: 1 day ago - Pushed at: almost 3 years ago - Stars: 5 - Forks: 1
IBM/ibm-streams-with-kafka 📦
Build a Kafka streaming app using IBM Streams
Language: Jupyter Notebook - Size: 5.53 MB - Last synced at: 4 months ago - Pushed at: about 4 years ago - Stars: 5 - Forks: 7
IBMStreams/streamsx.monitoring
The com.ibm.streamsx.monitoring toolkit provides capabilities to create applications that monitor IBM Streams and its applications.
Language: Java - Size: 32.8 MB - Last synced at: 17 days ago - Pushed at: over 4 years ago - Stars: 5 - Forks: 5
IBMStreams/streamsx.parquet
(Incubation) Toolkit providing adapters to Parquet
Language: Java - Size: 76.9 MB - Last synced at: 17 days ago - Pushed at: over 4 years ago - Stars: 5 - Forks: 5
IBMStreams/streamsx.visualization
Real-Time Visual Analytics
Language: JavaScript - Size: 16 MB - Last synced at: 17 days ago - Pushed at: almost 5 years ago - Stars: 5 - Forks: 4
jo-jstrm/DBPro-EKF-SLAM
This is our project on implementing an Extended Kalman Filter for Simultaneous Localization and Mapping of a moving car through a distributed streaming engine, in this case Apache Flink.
Language: Java - Size: 41.9 MB - Last synced at: about 1 year ago - Pushed at: almost 5 years ago - Stars: 5 - Forks: 3
IBMStreams/streamsx.regex
(Incubation) This toolkit provides support for RE2 regular expression library
Language: C++ - Size: 5.21 MB - Last synced at: 17 days ago - Pushed at: almost 5 years ago - Stars: 5 - Forks: 7
1e14/1e14
Tools for building function graphs
Language: TypeScript - Size: 306 KB - Last synced at: 5 days ago - Pushed at: almost 6 years ago - Stars: 5 - Forks: 0
