-
Updated
Oct 2, 2020
stream-processing
Here are 625 public repositories matching this topic...
-
Updated
Aug 11, 2020 - Java
-
Updated
Sep 30, 2020 - Python
Describe the bug
A clear and concise description of what the bug is.
KSQLDB fails to start if ssl.keystore.type=pkcs12 instead of ssl.keystore.type=PKCS12
To Reproduce
Steps to reproduce the behavior, include:
- The version of KSQL.
- Sample source data.
- Any SQL statements you ran
Latest version of KSQLDB with Java 11 and FIPS support enabled.
Expected behavior
A
-
Updated
Sep 9, 2020
-
Updated
Oct 3, 2020 - Go
-
Updated
May 1, 2019 - C
-
Updated
Oct 3, 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
-
Updated
Sep 10, 2020 - Go
-
Updated
Sep 13, 2020
-
Updated
Aug 14, 2020 - Python
-
Updated
Oct 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
@printf
like we have been until now. We need to either include a timestamp in every@printf
call (laborious and error prone) or c
-
Updated
Sep 25, 2020 - Java
-
Updated
Sep 25, 2020 - JavaScript
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
-
Updated
Sep 20, 2020 - Scala
-
Updated
Oct 3, 2020 - Java
-
Updated
Oct 2, 2020 - Java
-
Updated
Mar 29, 2020 - Go
-
Updated
Oct 2, 2020 - TypeScript
-
Updated
Mar 31, 2018
-
Updated
Aug 24, 2020 - Go
-
Updated
Sep 16, 2017 - Go
-
Updated
Sep 16, 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