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
