[
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)