stream-processing
Here are 747 public repositories matching this topic...
-
Updated
Dec 25, 2021 - Java
-
Updated
Nov 18, 2021
-
Updated
Dec 28, 2021 - Python
-
Updated
Sep 29, 2021
Is your feature request related to a problem? Please describe.
SQL supports inner/left/right/outer joins including verbose and short syntax. We should consider to support the full verbose syntax, instead of just short syntax.
Describe the solution you'd like
We should support
a [INNER] JOIN b ON
a LEFT [OUTER] JOIN b ON
a RIGHT [OUTER] JOIN b ON
(we don't support `RIGHT
Avoid controlling endless loop with exception in loadAnonymousClasses
, e.g. by extracting loading class to the method:
private boolean tryLoadClass(String innerClassName) {
try {
parent.loadClass(innerClassName);
} catch (ClassNotFoundException ex) {
return false;
}
return true;
}
-
Updated
Dec 30, 2021 - Go
This comment says that the message ID is optional,
but for SQL transport it is a mandatory attribute,
in turn it causes misunderstanding?
Is it possible to fix it or did I get something wrong?
https://github.com/ThreeDotsLabs/watermill/blob/b9928e750ba673cf93d442db88efc04706f67388/message/message.go#L20
https://github.com/ThreeDotsLabs/watermill/blob/b9928e750ba673cf93d442db88efc04706f6
-
Updated
Dec 30, 2021 - C
-
Updated
Dec 30, 2021 - Java
-
Updated
Aug 6, 2021 - C
-
Updated
Jul 26, 2021 - Go
-
Updated
Dec 30, 2021
-
Updated
Dec 28, 2021 - Python
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
Dec 17, 2021 - 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
-
Updated
Dec 14, 2021 - JavaScript
The mapcat
function seems to choke if you pass in a mapping function that returns a stream instead of a sequence:
user> (s/stream->seq (s/mapcat (fn [x] (s/->source [x])) (s/->source [1 2 3])))
()
Aug 18, 2019 2:23:39 PM clojure.tools.logging$eval5577$fn__5581 invoke
SEVERE: error in message propagation
java.lang.IllegalArgumentException: Don't know how to create ISeq from: manifold.
-
Updated
Dec 18, 2021 - Java
-
Updated
Dec 25, 2021 - Go
-
Updated
Nov 22, 2021 - Scala
-
Updated
Dec 14, 2021 - Java
as title
-
Updated
Nov 23, 2021 - TypeScript
-
Updated
Dec 22, 2021 - Go
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."
I figured out a way to get the (x,y,z) data points for each frame from one hand previously. but im not sure how to do that for the new holistic model that they released. I am trying to get the all landmark data points for both hands as well as parts of the chest and face. does anyone know how to extract the holistic landmark data/print it to a text file? or at least give me some directions as to h