Nicu Reut

icon indicating a website link https://nicu.dev icon indicating an email [email protected]

icon location Zurich icon location Passionate about Scala and functional programming, with a lot of love for distributed systems, machine learning and simplicity.

Results 5 issues of Nicu Reut

Add Committer flowWithContext which emits the elements downstream

3 comment

### Short description For the `Committer` add a committing FlowWithContext which emits the elements dowstream but drops the committable context (the current one emits no useful value). ### Details -...

Clickhouse sink stream request to clickhouse instead of buffering in memory

Currently the `ClickhouseSink` uses `groupWithin` to buffer the items which need to be inserted into clickhouse. This causes a larger memory footprint and also bursts of data being sent to...

Add algebraic operations between dates

2 comment

We have a number of operations which can be executed between dates and numbers, but no support to subtract two dates. This should produce a column of int as result.

enhancement
dsl

Query streaming progress should publish the result as streaming parts

Currently we offer progress sources which contain only the query status and the query result is returned as the materialized value of the source. In certain cases we want the...

Batch inserts failure due to an error in one entry should not fail the entire batch

Currently when using the batch actor to stream insert data, if one entry in the batch causes the insert to fail then the entire batch is discarded, which leads to...

bug
help wanted