tanjialiang created FLINK-33208:
-----------------------------------

             Summary: Support the timestamp writable metadata for hbase 
connector
                 Key: FLINK-33208
                 URL: https://issues.apache.org/jira/browse/FLINK-33208
             Project: Flink
          Issue Type: New Feature
          Components: Connectors / HBase
    Affects Versions: hbase-3.0.1
            Reporter: tanjialiang


Currently, the hbase sink does not support write data with `timestamp`, which 
may cause the data to be written out of order. I suggest to support the 
timestamp writable metadata for hbase connector so that we can set the 
`timestamp` when we writing.
{code:java}
CREATE TABLE hTable (
 rowkey INT,
 family1 ROW<q1 INT>,
 version TIMESTAMP_LTZ(3) METADATA FROM 'timestamp',
 PRIMARY KEY (rowkey) NOT ENFORCED
) WITH (
 'connector' = 'hbase-2.2',
 'table-name' = 'mytable',
 'zookeeper.quorum' = 'localhost:2181'
);{code}



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to