[
https://issues.apache.org/jira/browse/FLINK-10245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596278#comment-16596278
]
ASF GitHub Bot commented on FLINK-10245:
----------------------------------------
Clarkkkkk opened a new pull request #6628: [FLINK-10245] [Streaming Connector]
Add Pojo, Tuple, Row and Scala Product DataStream Sink for HBase
URL: https://github.com/apache/flink/pull/6628
## 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:
[email protected]
> Add DataStream HBase Sink
> -------------------------
>
> Key: FLINK-10245
> URL: https://issues.apache.org/jira/browse/FLINK-10245
> Project: Flink
> Issue Type: Sub-task
> Components: Streaming Connectors
> Reporter: Shimin Yang
> Assignee: Shimin Yang
> Priority: Major
> Labels: pull-request-available
>
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
