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]. If you need a different converter, you have to implement your own converter class. Best, Hang [1] https://github.com/apache/flink-connector-hbase/blob/main/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/HBase2DynamicTableFactory.java [2] https://github.com/apache/flink-connector-hbase/blob/main/flink-connector-hbase-2.2/src/main/java/org/apache/flink/connector/hbase2/sink/HBaseDynamicTableSink.java 碳酸君 <zw.teii...@gmail.com> 于2023年9月22日周五 13:06写道： > 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 >
