stream-processing
Here are 639 public repositories matching this topic...
A curated list of awesome big data frameworks, ressources and other awesomeness.
-
Updated
Nov 17, 2020
flink learning blog. http://www.flink-learning.com 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例,还有 Flink 落地应用的大型项目案例(PVUV、日志存储、百亿数据实时去重、监控告警)分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
-
Updated
Nov 11, 2020 - Java
Python Stream Processing
-
Updated
Nov 17, 2020 - Python
Add NULLIF function
It would be useful if ksqlDB had a NULLIF function, as common across SQL in other platforms.
NULLIF(value1, value2)
The NULLIF function returns NULL if and only if value1 and value2 are equal. Otherwise it returns value1.
A curated list of awesome System Design (A.K.A. Distributed Systems) resources.
-
Updated
Nov 3, 2020
A stream processor for mundane tasks written in Go
-
Updated
Nov 24, 2020 - Go
Currently, you are not able to use middleware per handler in "clean way" (you can still manually wrap the handler function, or have separated router).
It would be nice to be able to add middleware per handler.
As a good reference point, you can use chi router: https://github.com/go-chi/chi
Fast and Lightweight Log processor and forwarder for Linux, BSD and OSX
-
Updated
Nov 25, 2020 - C
High-performance time-series aggregation for PostgreSQL
-
Updated
May 1, 2019 - C
fastest JSON encoder/decoder with powerful stream API for Golang
-
Updated
Oct 6, 2020 - Go
a curated list of awesome streaming frameworks, applications, etc
-
Updated
Nov 25, 2020
A Python stream processing engine modeled after Yahoo! Pipes
-
Updated
Aug 14, 2020 - Python
Upserts, Deletes And Incremental Processing on Big Data.
-
Updated
Nov 25, 2020 - Java
It can be very difficult to piece together a reasonably estimate of a history of events from the current workers logs because none of them have timestamps.
So for that end, I think we should add timestamps to the logs.
This has some cons:
- We can't just use
@printflike we have been until now. We need to either include a timestamp in every@printfcall (laborious and error prone) or c
Stream Processing and Complex Event Processing Engine
-
Updated
Nov 18, 2020 - Java
For example, given a simple pipeline such as:
Pipeline p = Pipeline.create();
p.readFrom(TestSources.items("the", "quick", "brown", "fox"))
.aggregate(aggregator)
.writeTo(Sinks.logger());
I'd like aggregator to be something requiring a non-serialisable dependency to do its work.
I know I can do this:
Pipeline p = Pipeline.create();
p.readFrom(TestSource
Wormhole is a SPaaS (Stream Processing as a Service) Platform
-
Updated
Sep 25, 2020 - JavaScript
Lightweight real-time big data streaming engine over Akka
-
Updated
Nov 19, 2020 - Scala
A microservices-based Streaming and Batch data processing in Cloud Foundry and Kubernetes
-
Updated
Nov 25, 2020 - Java
Framework for building Event-Driven Microservices
-
Updated
Nov 25, 2020 - Java
A stream processing API for Go (alpha)
-
Updated
Mar 29, 2020 - Go
equivalent to kafka-streams
-
Updated
Oct 2, 2020 - TypeScript
Streaming System 相关的论文读物
-
Updated
Mar 31, 2018
Go stream processing library
-
Updated
Oct 14, 2020 - Go
Kasper is a lightweight library for processing Kafka topics.
-
Updated
Sep 16, 2017 - Go
A list about Apache Kafka
-
Updated
Nov 17, 2020
Efficient, easy-to-use and fast PHP JSON stream parser
-
Updated
Nov 24, 2020 - PHP
Improve this page
Add a description, image, and links to the stream-processing topic page so that developers can more easily learn about it.
Add this topic to your repo
To associate your repository with the stream-processing topic, visit your repo's landing page and select "manage topics."


Hello, dear Mediapipe guys.
I want to inference the hand pose with Mediapipe model and my own model.
I have my own tf-lite models, it can work on the RGB bitmap.
I try to query the RGB bitmap from input frame with data packet.
My code is