Re: Is there any example that use hbase connector in stream API

[碳酸君]

HI Антон,Hang

Thanks Reply

I implemented the RichSinkFunction with HbaseClient ,it works well.
I plan to copy some code from
org.apache.flink.connector.hbase.sink.HBaseSinkFunction mainly the
scheduled batch submit ,but except the converter part .

I think I can read from TableAPI and write with RichSinkFunction.

Is that a routine operation in flink ? mix TableAPI and StreamAPI

On Tue, Sep 26, 2023 at 9:25 PM Антон <anton...@yandex.ru> wrote:
>
> Hi,
>
> I wrote to hbase using map extending RichMapFunction. I initialized the 
> connection in overrided open method and wrote to hbase in overrided map 
> method.
>
> 22.09.2023, 05:01, "碳酸君" <zw.teii...@gmail.com>:
>
> hi community:
>
>      I'm trying to write some data to hbase in a stream job ,with
> flink-connector-hbase-2.2 .
>      I have no idea about instantiate
> org.apache.flink.connector.hbase.util.HBaseTableSchema and
> org.apache.flink.connector.hbase.sink.HBaseMutationConverter .
>
>
> Regards,
> Teii