DG
Size: a a a
DG
DG
DG
DG
DG
K
DG
DG
DG
K
DG
K
K
DG
PL
minIf AggregateFunction(minIf, Float64, UInt8)minIfState(value, isFinite(value)) AS min,SELECT minIfMerge(s) FROM (SELECT minIfState(42, isFinite(NaN)) s);
0PL
if(finite_count > 0, minIfMerge(...), NaN), но может есть что-то лучше?СС
S
AS
val sb = new StringBuilder()
events.map(ev => json.eventToString(ev)).foreach(s => sb.append(s +"\n"))
val stream = new ByteArrayInputStream(sb.toString().getBytes("UTF-8") )
try {
sth.write().sendToTable(table, stream, ClickHouseFormat.JSONStringEachRow)
} catch {
case ex: java.sql.SQLException => log.error("An error occurred when inserting data into clickhouse", ex)
}
К