Awesome Open Source
Search
Programming Languages
Languages
All Categories
Categories
About
Search results for java stream processing
java
x
stream-processing
x
84 search results found
Flink Learning
⭐
13,801
flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例,还有 Flink 落地应用的大型项目案例(PVUV、日志存储、百亿数据实时去重、监控告警)分享。欢迎大家支持我的专栏《 Flink 实战与性能优化》
Ksql
⭐
5,739
The database purpose-built for stream processing applications.
Hazelcast
⭐
5,738
Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.
Hudi
⭐
4,901
Upserts, Deletes And Incremental Processing on Big Data.
Awesome Streaming
⭐
2,447
a curated list of awesome streaming frameworks, applications, etc
Siddhi
⭐
1,490
Stream Processing and Complex Event Processing Engine
Hazelcast Jet
⭐
1,065
Distributed Stream and Batch Processing
Spring Cloud Dataflow
⭐
1,052
A microservices-based Streaming and Batch data processing in Cloud Foundry and Kubernetes
Manifold
⭐
997
A compatibility layer for event-driven abstractions
Spring Cloud Stream
⭐
956
Framework for building Event-Driven Microservices
Smooks
⭐
377
Extensible data integration Java framework for building XML and non-XML fragment-based applications
Kafka Tutorials
⭐
291
Tutorials and Recipes for Apache Kafka
Pulsar Flink
⭐
255
Elastic data processing with Apache Pulsar and Apache Flink
Examples Java
⭐
238
Stream Processing with Apache Flink - Java Examples
Kafka Streams In Action
⭐
183
Source code for the Kafka Streams in Action Book
Remotecodecompiler
⭐
117
An online code compiler supporting 11 programming languages (Java, Kotlin, Scala, C, C++, C#, Golang, Python, Ruby, Rust and Haskell) for competitive programming and coding interviews.
Stream Registry
⭐
113
Stream Discovery and Stream Orchestration
Logisland
⭐
106
Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.
Kafka Spark Streaming Example
⭐
96
Simple examle for Spark Streaming over Kafka topic
Flink Connectors
⭐
93
Apache Flink connectors for Pravega.
Tensorflow Serving Java Grpc Kafka Streams
⭐
85
Kafka Streams + Java + gRPC + TensorFlow Serving => Stream Processing combined with RPC / Request-Response
Kafka Streams Real Time Stream Processing
⭐
76
This is the central repository for all materials related to Kafka Streams : Real-time Stream Processing! Book by Prashant Pandey.
Fluxtion
⭐
74
core fluxtion static event processor generator tool and runtime components
Scotty Window Processor
⭐
71
This repository provides Scotty, a framework for efficient window aggregations for out-of-order Stream Processing.
Hash4j
⭐
66
Dynatrace hash library for Java
Eventstoredb Client Java
⭐
55
Official Asynchronous Java 8+ Client Library for EventStoreDB 20.6+
Vertx Reactive Streams
⭐
48
Tnt4j
⭐
44
Track and Trace 4 Java API, Application event streaming and logging framework for correlation, diagnostics and tracking of application activities.
Infoworld Post
⭐
43
Code examples for a blog post on infoworld.com
Storm Dynamic Spout
⭐
41
A framework for building spouts for Apache Storm and a Kafka based spout for dynamically skipping messages to be processed later.
Samples
⭐
40
This repository contains open-source sample applications for IBM Streams.
Streamsx.health
⭐
34
(Incubation) Streams Healthcare Analytics Platform - To enable and inspire the next generation healthcare solutions
Theodolite
⭐
33
Theodolite is a framework for benchmarking the horizontal and vertical scalability of cloud-native applications.
H264j
⭐
31
Pure Java implementation of H264 decoder to replace Xuggler
Streamsx.messaging
⭐
30
This toolkit is focused on interacting with popular messaging systems such as Kafka, JMS, XMS, and MQTT. After release v5.4.2 the complete toolkit will be deprecated. See the README.md file for hints to alternative toolkits.
Rsp4j
⭐
29
RSP4J a library for RDF Stream Processing
Table Computing
⭐
29
Table-Computing (Simplified as TC) is a high performance and low latency computing framework, 10x faster than Flink for complicated use cases, distributed and light weighted, relational operation, simple to use, write less and do more.
Kafka Workers
⭐
28
Kafka Workers is a client library which unifies records consuming from Kafka and processing them by user-defined WorkerTasks.
Football Events
⭐
27
Event-Driven microservices with Kafka Streams
Akka_streams_tutorial
⭐
27
A collection of runnable and self-contained examples inspired by various akka-streams (pekko-streams) and Alpakka (Pekko connectors) docs, tutorials and blogs
Streampipes Extensions
⭐
25
Apache StreamPipes - A self-service (Industrial) IoT toolbox to enable non-technical users to connect, analyze and explore IoT data streams. This repository contains ready-to-use pipeline elements and adapters for StreamPipes Connect
Streams Bootstrap
⭐
25
Utility functions and base classes for Kafka Streams applications
Redis Stream Demo
⭐
21
Demo for Redis Streams
Beepbeep 3
⭐
20
An event stream processor anyone can use
Hazelcast Jet Contrib
⭐
19
Extension modules for Hazelcast Jet
Kahpp Oss
⭐
18
Kafka Streams made easy with a YAML file
Storm Ml
⭐
17
an online learning algorithm library for Storm
Dspbench
⭐
17
a suite of benchmark applications for distributed data stream processing systems
Esperiot
⭐
17
Small and simple stream-based CEP tool for IoT devices connected to an MQTT broker
Proxima Platform
⭐
17
The Proxima platform.
Ksml
⭐
17
Kafka Streams for Low Code Environments
Glink
⭐
16
A Spatial Extension of Apache Flink
Mist
⭐
16
MIST: High-performance IoT Stream Processing
Pysiddhi
⭐
15
Python wrapper for Siddhi engine
Flamestream
⭐
14
Distributed stream processing model and its implementation
Streamsx.kafka
⭐
13
Repository for integration with Apache Kafka
Wearedevs 2018
⭐
12
Code for my talk "Stateful & Reactive Streaming Applications Without a Database" at WeAreDevelopers 2018
Kafka Streams Cassandra State Store
⭐
11
'Drop-in' Kafka Streams State Store implementation that persists data to Apache Cassandra / ScyllaDB
Framework
⭐
11
The Beamline streaming process mining framework
Streamsx.inet
⭐
10
This toolkit supports common internet protocols, such as HTTP and WebSockets
Newton
⭐
10
Extend Muon into the world of Spring. Implement Muon apis, especially around events to provide DDD patterns natively in Spring Boot
Streamsx.hdfs
⭐
9
This toolkit provides operators and functions for interacting with Hadoop File System.
Streamsx.sparkmllib
⭐
8
Toolkit for real-time scoring using Apache Spark MLLib library
Event Meshinery
⭐
8
A new Framework for asynchronous signaling of processes via Kafka/Mysql/anything.
Floodplain Library
⭐
8
Kotlin based stream processing framework
Kafka Marklogic Connector
⭐
8
A Kafka connector for subscribing to topics and streaming messages into MarkLogic
Streamsx.hbase
⭐
8
Integration of IBM Streams and Apache HBase
Flink Fault Tolerant Stream Example
⭐
8
An example of using Flink for Fault-Tolerant Stream Processing
Streamprocessor
⭐
8
Flink Sql Practice
⭐
7
Flink SQL 实战 -中文博客专栏
Streamsx.iot
⭐
7
(Incubation) Provide the ability to have an IBM Streams application easily interact with IoTF, either in Bluemix (Streaming Analytics Service) or on-premises (IBM Streams).
Beepbeep 3 Palettes
⭐
6
A bundle of user-contributed extensions to BeepBeep 3
Streap
⭐
6
Stateful Stream Processing with Project Reactor
Graylog Plugin Riemann
⭐
6
Graylog2 output plugin to send events to a Riemann instance
Flink Questdb Connector
⭐
6
QuestDB ILP connector for Apache Flink
Mangolaa Streams Processing Flink
⭐
6
Stream processing for the Mangolaa platform using Apache Kafka, Apache Flink, Java 8 and Lombok
Kafka Streams Interactive Queries
⭐
6
Interactive Queries in Kafka Streams
Reacto
⭐
6
Functional reactive microservices for the JVM. Uses Observables for composing event streams.
Hurricanedb
⭐
6
A real-time distributed OLAP engine
Cqels
⭐
5
A fork of CQELS (Continuous Query Evaluation over Linked Data)
Iudx Adaptor Framework
⭐
5
A data ingestion adaptor to plug data from source to sink with a configuration based pipeline
Streamsx.monitoring
⭐
5
The com.ibm.streamsx.monitoring toolkit provides capabilities to create applications that monitor IBM Streams and its applications.
Musik
⭐
5
Musik: Music recognition application
Streamsx.parquet
⭐
5
(Incubation) Toolkit providing adapters to Parquet
Tnt4j Streams
⭐
5
TNT4J Streams allows data streaming, parsing from various data sources into TNT4J event sinks
Related Searches
Java Spring (21,350)
Java Spring Boot (11,982)
Java Video Game (8,093)
Java Gradle (8,072)
Java Docker (6,071)
Java Database (6,015)
Java Sdk (5,864)
Javascript Java (5,468)
Java Rest (4,956)
Java Algorithms (4,705)
1-84 of 84 search results
Privacy
|
About
|
Terms
|
Follow Us On Twitter
Copyright 2018-2024 Awesome Open Source. All rights reserved.