Clarkkkkk opened a new pull request #6627: [FLINK-10245] [Streaming Connector] Add Pojo, Tuple, Row and Scala Pr… URL: https://github.com/apache/flink/pull/6627 ## What is the purpose of the change This PR introduce the HBase sink for Datastream which can support Pojo, Row, Tuple and Scala Product. ## Brief change log - Add a HBaseSink to provide a common interface for all subtypes. - Add HBasePojoSink, HBaseTupleSink, HBaseRowSink, HBaseScalaProductSink - Add a HBaseTableMapper for record the mapping between Datastream element and hbase colum related infos. - Add a HBaseTableBuilder to establishes the connection to hbase cluster as well as gets a table handle to communicate with hbase table. ## Verifying this change This change added tests and can be verified as follows: - Add Integration tests for HBasePojoSink, HBaseTupleSink, HBaseRowSink, HBaseScalaProductSink. - Add HBasePojoSinkExample, HBaseTupleSinkExample, HBaseRowSinkExample and HBaseScalaProductSinkExample. ## Does this pull request potentially affect one of the following parts: - Dependencies (does it add or upgrade a dependency): no - The public API, i.e., is any changed class annotated with `@Public(Evolving)`: no - The serializers: no - The runtime per-record code paths (performance sensitive): no - Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Yarn/Mesos, ZooKeeper: yes - The S3 file system connector: no ## Documentation - Does this pull request introduce a new feature? No, just support new sink.
---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services
