[
https://issues.apache.org/jira/browse/BEAM-46?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Halperin updated BEAM-46:
--------------------------------
Assignee: Ian Zhou
> 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)
