Hi Everyone, When I look at the Apache Flink 1.15 documentation, I can see the Hbase connector under Connectors > Table Api Connectors, but I can't see the Hbase under Connectors > DataStream Connectors. Does Datastream not support Hbase? Doc Link : https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/

Correct

So, In my case : there is a csv file and i need to insert these rows to hbase. Im doing this with table api. Is this correct or sense? cause every time I declare table on streaming job. like : First I read and make env.createtemporarytable(Tabletemp) from file with schema then CREATE TABLE hTable (

rowkey INT,
 family1 ROW<q1 INT>,
 family2 ROW<q2 STRING, q3 BIGINT>,
 family3 ROW<q4 DOUBLE, q5 BOOLEAN, q6 STRING>,
 PRIMARY KEY (rowkey) NOT ENFORCED
) WITH (
 'connector' = 'hbase-1.4',
 'table-name' = 'mytable',
 'zookeeper.quorum' = 'localhost:2181'
);

then I do

INSERT INTO hTable
SELECT rowkey, ROW(f1q1), ROW(f2q2, f2q3), ROW(f3q4, f3q5, f3q6) FROM Tabletemp;

It did not seem logical to me to define this table again for each batch of data in a job that will be streaming. Is there any better way to do this?

Persist the catalog where you register the table