40 Repositories
Java rtmp-stream Libraries
The goal of this project is to play with Spring Cloud Stream Event Routing and CloudEvents
The goal of this project is to play with Spring Cloud Stream Event Routing and CloudEvents. For it, we will implement a producer and consumer of news & alert events.
Adds support for using InputStream/OutputStream from Spring's web clients
Spring stream interoperability This project offers three integrations: A WebClientHttpRequestFactory that redirects the RestTemplate API calls to a We
The world's top-level live sdk...
目录结构说明 本目录包含 Android 版 移动直播 SDK 的Demo 源代码，主要演示接口如何调用以及最基本的功能。 ├─ MLVB-API-Example // MLVB API Example，包括直播推流，直播播放，互动直播 | ├─ App //
XR3Player - The MOST ADVANCED JavaFX Media Player
Support me joining PI Network app with invitation code AlexKent I am in search for developers to keep on where i left XR3Player :) XR3Player ( Downloa
Hudi manages the storage of large analytical datasets on DFS
Apache Hudi Apache Hudi (pronounced Hoodie) stands for Hadoop Upserts Deletes and Incrementals. Hudi manages the storage of large analytical datasets
JBinanceAPI - An easy to maintain java library that will cover all available Binance endpoints & stream
JBinanceAPI - A full java Binance API (REST + Websockets)
Reference implementation for MINAS (MultI-class learNing Algorithm for data Streams), an algorithm to address novelty detection in data streams multi-class problems.
Reference implementation for MINAS (MultI-class learNing Algorithm for data Streams), an algorithm to address novelty detection in data streams multi-class problems.
DCL-204: Java SE 17 Programming
DCL-204: Java SE 17 Programming These projects are created as part of the following training: DCL-204 "Java SE 17 Programming" Please follow the link
Access paged data as a "stream" with async loading while maintaining order
DataStream What? DataStream is a simple piece of code to access paged data and interface it as if it's a single "list". It only keeps track of queued
RSocket is a binary protocol for use on byte stream transports such as TCP, WebSockets, and Aeron
RSocket RSocket is a binary protocol for use on byte stream transports such as TCP, WebSockets, and Aeron. It enables the following symmetric interact
A template and introduction for the first kafka stream application. The readme file contains all the required commands to run the Kafka cluster from Scrach
Kafka Streams Template Maven Project This project will be used to create the followings: A Kafka Producer Application that will start producing random
Beagle helps you identify keywords, phrases, regexes, and complex search queries of interest in streams of text documents.
Beagle Beagle is a detector of interesting things in text. Its intended use is in-stream search applications. Suppose you need to monitor a stream of
📹 Live stream RTMP Publisher for React Native
react-native-rtmp-publisher 📹 Live stream RTMP publisher for React Native ⚠️ iOS on development Installation npm install react-native-rtmp-publisher
Querystream - Build JPA Criteria queries using a Stream-like API
QueryStream QueryStream allows you to perform JPA queries using a Stream-like API. Just like a Java 8 Stream, a QueryStream is built up in a pipeline,
Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.
Dagger Dagger or Data Aggregator is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processi
This is a simple realization of custom messages pre/post processing in spring-boot HTTP/Stream requests & responses
spring-boot-custom-message-converting-instances This is a simple realization of custom messages converting in spring-boot HTTP requests and responses.
Table-Computing (Simplified as TC) is a distributed light weighted, high performance and low latency stream processing and data analysis framework. Milliseconds latency and 10+ times faster than Flink for complicated use cases.
Table-Computing Welcome to the Table-Computing GitHub. Table-Computing (Simplified as TC) is a distributed light weighted, high performance and low la
Lobby System Template for a multiplayer java game, with chat and other features, using JavaFX and socket TCP (will be extended to UDP).
JavaFX-MultiplayerLobbySystem JavaFX lobby system for multiplayer games with chat, ready toggle and kick buttons, using socket TCP by default. Demo Cr
Realtime Data Processing and Search Engine Implementation.
Mutad The name Mutad is a reverse spelling of datum. Overview An implementation of a real-time data platform/search engine based on various technology
Flutter plugin to listen to the process text intent stream.
Flutter Process Text Plugin Compatibility ✅ Android ❌ iOS (active issue: iOS support) Show some ❤️ and ⭐ the repo Why use Flutter Process Text? Flutte
Flutter plugin to listen to the process text intent stream.
Flutter Process Text Plugin Show some ❤️ and ⭐ the repo Why use Flutter Process Text? Flutter Process Text Plugin is known for : Flutter Process Text
End to End project for Kafka Streams using Spring Cloud Kafka streams
Spring Kafka Streams using Spring Cloud Streams End to End example Endpoint http://localhost:8080/domain/lookup/facebook - to pull all facebook relate
Detect if the system is recording, mirroring, or using AirPlay to stream the contents of the screen.
react-native-is-screen-captured-ios Detect if the system is recording, mirroring, or using AirPlay to stream the contents of the screen. https://devel
A reactive dataflow engine, a data stream processing framework using Vert.x
🐝 NeonBee Core NeonBee is an open source reactive dataflow engine, a data stream processing framework using Vert.x. Description NeonBee abstracts mos
Modern Java - A Guide to Java 8
Modern Java - A Guide to Java 8 This article was originally posted on my blog. You should also read my Java 11 Tutorial (including new language and AP
Apache Heron (Incubating) is a realtime, distributed, fault-tolerant stream processing engine from Twitter
Heron is a realtime analytics platform developed by Twitter. It has a wide array of architectural improvements over it's predecessor. Heron in Apache
Stream summarizer and cardinality estimator.
Description A Java library for summarizing data in streams for which it is infeasible to store all events. More specifically, there are classes for es
Distributed and fault-tolerant realtime computation: stream processing, continuous computation, distributed RPC, and more
IMPORTANT NOTE!!! Storm has Moved to Apache. The official Storm git repository is now hosted by Apache, and is mirrored on github here: https://github
Stream summarizer and cardinality estimator.
Description A Java library for summarizing data in streams for which it is infeasible to store all events. More specifically, there are classes for es
jOOλ - The Missing Parts in Java 8 jOOλ improves the JDK libraries in areas where the Expert Group's focus was elsewhere. It adds tuple support, function support, and a lot of additional functionality around sequential Streams. The JDK 8's main efforts (default methods, lambdas, and the Stream API) were focused around maintaining backwards compatibility and implementing a functional API for parallelism.
jOOλ jOOλ is part of the jOOQ series (along with jOOQ, jOOX, jOOR, jOOU) providing some useful extensions to Java 8 lambdas. It contains these classes
Distributed Stream and Batch Processing
What is Jet Jet is an open-source, in-memory, distributed batch and stream processing engine. You can use it to process large volumes of real-time eve
An extensible Java framework for building XML and non-XML streaming applications
Smooks Framework This is the Git source code repository for the Smooks Project. Build Status Building Pre-requisites JDK 8 Apache Maven 3.2.x Maven gi
Modern Java - A Guide to Java 8
Modern Java - A Guide to Java 8 This article was originally posted on my blog. You should also read my Java 11 Tutorial (including new language and AP
Stream Processing and Complex Event Processing Engine
Siddhi Core Libraries Siddhi is a cloud native Streaming and Complex Event Processing engine that understands Streaming SQL queries in order to captur
Client-side response routing for Spring
Riptide: A next generation HTTP client Riptide noun, /ˈrɪp.taɪd/: strong flow of water away from the shore Riptide is a library that implements client
Enhancing Java Stream API
StreamEx 0.7.3 Enhancing Java Stream API. This library defines four classes: StreamEx, IntStreamEx, LongStreamEx, DoubleStreamEx which are fully compa
Stream utilities for Java 8
protonpack A small collection of Stream utilities for Java 8. Protonpack provides the following: takeWhile and takeUntil skipWhile and skipUntil zip a
jOOλ - The Missing Parts in Java 8 jOOλ improves the JDK libraries in areas where the Expert Group's focus was elsewhere. It adds tuple support, function support, and a lot of additional functionality around sequential Streams. The JDK 8's main efforts (default methods, lambdas, and the Stream API) were focused around maintaining backwards compatibility and implementing a functional API for parallelism.
jOOλ jOOλ is part of the jOOQ series (along with jOOQ, jOOX, jOOR, jOOU) providing some useful extensions to Java 8 lambdas. It contains these classes
ScaleCube Services is a high throughput, low latency reactive microservices library built to scale. it features: API-Gateways, service-discovery, service-load-balancing, the architecture supports plug-and-play service communication modules and features. built to provide performance and low-latency real-time stream-processing. its open and designed to accommodate changes. (no sidecar in a form of broker or any kind)
scalecube-services MICROSERVICES 2.0 An open-source project that is focused on streamlining reactive-programming of Microservices Reactive-systems tha
Speedment is a Stream ORM Java Toolkit and Runtime
Java Stream ORM Speedment is an open source Java Stream ORM toolkit and runtime. The toolkit analyzes the metadata of an existing SQL database and aut