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

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

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, "碳酸君" :hi community: I'm trying to write some data to hbase in a stream job ,withflink-connector-hbase-2.2 . I have

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

Hi, There is not a HBase connector for the DataStream API. But we could follow codes in the Table API to learn how to use it. 1. We could know how to build a HBaseTableSchema in HBase2DynamicTableFactory[1]. 2. We could know how to build a RowDataToMutationConverter in HBaseDynamicTableSink[2].

Is there any example that use hbase connector in stream API

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