hi, song wang
What does flink's preprocessing mean? Does it mean the data of HLL generated by 
flink?
I understand that flink does not need to care about the HLL type. The HLL data 
is generated by HLL_HASH(column) when it is imported. So you only need to 
import the existing data in flink into doris through streamload, and then set 
the corresponding hll field in the header.

for example:
curl --location-trusted -u root: -H "label:label_test_hll_load" \
     -H "column_separator:," \
     -H "columns:dt,id,name,province,os, pv=hll_hash(id)" -T test_hll.csv 
http://fe_IP:8030/api/demo/test_hll/_stream_load

> 2022年7月11日 下午12:43,song wang <sdlcwangson...@gmail.com> 写道:
> 
>   Thank you for your reply, The introduction in the link is very simple,
> I didn't find the pre-processing related to Flink,  Could you explain it in
> more detail?

Reply via email to