StreamingMASSIF

Data stream processor

A Java-based platform for efficient processing of data streams by performing cascading reasoning and complex event processing.

Cascading Stream Reasoning with Streaming MASSIF

GitHub

10 stars
4 watching
2 forks
Language: Java
last commit: over 3 years ago
reasoningstream-processingstreamreasoning

Related projects:

RepositoryDescriptionStars
olacabs/fabricA real-time stream processing framework designed to handle high-volume event ingestion and complex data processing tasks with guaranteed availability and scalability.55
bytewax/bytewaxA Python framework for stateful stream and event processing with built-in connectors and flexible dataflow capabilities.1,585
confluentinc/ksqlA database for real-time stream processing applications built on top of Apache Kafka.133
jpcik/morph-streamsA tool for processing and analyzing continuous data streams using query languages16
bkirwi/coastA streaming data processing framework with strong ordering and exactly-once semantics60
apache/samzaA distributed stream processing framework for handling high-volume data streams with fault tolerance and durability guarantees817
raystack/daggerA cloud-native framework for stateful processing of real-time streaming data268
lmco/streamflowA tool designed to simplify stream processing workflow development and management253
weblyzard/streaming-sparqlProvides a robust, incremental processing of streaming results from SPARQL servers.6
nanosai/stream-ops-javaA Java-based data streaming engine and stream processing API designed to be embeddable in various applications.48
scramjetorg/framework-jsA reactive stream programming framework that enables concurrent execution of asynchronous operations on data streams.38
lsds/saberA hybrid stream processing engine designed to optimize data processing on heterogeneous architectures.38
dataartisans/yahoo-streaming-benchmarkExtending Yahoo's Streaming Benchmark with Flink and Storm implementations107
maki-nage/makinageStream Processing Library and Framework38
jivesoftware/miruA multi-tenant search engine designed for efficient handling of time-ordered data streams with optional aggregation and filtering capabilities.15