[ 
https://issues.apache.org/jira/browse/BEAM-46?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15368047#comment-15368047
 ] 

ASF GitHub Bot commented on BEAM-46:
------------------------------------

Github user asfgit closed the pull request at:

    https://github.com/apache/incubator-beam/pull/596


> Unbounded sink for Google Cloud Bigtable
> ----------------------------------------
>
>                 Key: BEAM-46
>                 URL: https://issues.apache.org/jira/browse/BEAM-46
>             Project: Beam
>          Issue Type: New Feature
>          Components: sdk-java-gcp
>            Reporter: Daniel Halperin
>            Assignee: Ian Zhou
>
> Google Cloud Bigtable is currently in Beta. 
> https://cloud.google.com/bigtable/ A bounded sink is included in the initial 
> code for Beam, and uses asynchronous row mutations (with bounded memory) for 
> maximum throughput.
> The unbounded sink code is in principle not too different. The key areas of 
> focus are better connection management, thread management, and fault 
> tolerance (e.g., so connections are not leaked if bundles fail) in the 
> unbounded case in which there are hundreds of active threads and very small 
> bundles.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to