stream-processing
Here are 630 public repositories matching this topic...
A curated list of awesome big data frameworks, ressources and other awesomeness.
-
Updated
Oct 14, 2020
flink learning blog. http://www.flink-learning.com 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例,还有 Flink 落地应用的大型项目案例(PVUV、日志存储、百亿数据实时去重、监控告警)分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
-
Updated
Oct 17, 2020 - Java
Python Stream Processing
-
Updated
Oct 30, 2020 - Python
Describe the bug
It's possible to create a stream or table with no value columns using a CREATE TABLE or CREATE STREAM statement. No error is returned.
However, if you try and use the stream or table in a downstream CREATE TABLE AS or CREATE STREAM AS statement you get a error message.
i.e. the table/stream created with no columns isn't useful.
To Reproduce
A curated list of awesome System Design (A.K.A. Distributed Systems) resources.
-
Updated
Oct 26, 2020
A stream processor for mundane tasks written in Go
-
Updated
Nov 2, 2020 - Go
High-performance time-series aggregation for PostgreSQL
-
Updated
May 1, 2019 - C
Fast and Lightweight Log processor and forwarder for Linux, BSD and OSX
-
Updated
Nov 2, 2020 - C
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
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 3, 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 3, 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
Oct 14, 2020 - Java
Jobs in 4.3 log start time in ISO8601 format and duration
Start time: 2020-10-04T20:55:01.701
Duration: 73,142,855 ms
It would be useful to log the end time in ISO8601 and/or the duration in days/hours/minutes/seconds, as it's not immediately obvious how long is 73 million milliseconds.
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
Oct 17, 2020 - Scala
A microservices-based Streaming and Batch data processing in Cloud Foundry and Kubernetes
-
Updated
Nov 3, 2020 - Java
Framework for building Event-Driven Microservices
-
Updated
Oct 30, 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
Oct 19, 2020
All exceptions in namespace JsonMachine\Exception should extend one common exception, say JsonMachineException, so that userland code can catch for only one type and catch anything from this library. Fell free to create pull request and participate :)
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