Mailing-List: contact commits-help@beam.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@beam.apache.org
Date: Thu, 30 Mar 2017 17:11:41 +0000 (UTC)
From: "Daniel Halperin (JIRA)" <jira@apache.org>
To: commits@beam.apache.org
Message-ID: <JIRA.13009306.1475520329000.167028.1490893901759@Atlassian.JIRA>
In-Reply-To: <JIRA.13009306.1475520329000@Atlassian.JIRA>
References: <JIRA.13009306.1475520329000@Atlassian.JIRA> <JIRA.13009306.1475520329050@jira-lw-us.apache.org>
Subject: [jira] [Updated] (BEAM-702) Simple pattern for per-bundle and
 per-DoFn Closeable resources
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Thu, 30 Mar 2017 17:11:45 -0000


     [ https://issues.apache.org/jira/browse/BEAM-702?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Daniel Halperin updated BEAM-702:
---------------------------------
    Component/s:     (was: beam-model)
                 sdk-ideas

> Simple pattern for per-bundle and per-DoFn Closeable resources
> --------------------------------------------------------------
>
>                 Key: BEAM-702
>                 URL: https://issues.apache.org/jira/browse/BEAM-702
>             Project: Beam
>          Issue Type: Improvement
>          Components: sdk-ideas
>            Reporter: Eugene Kirpichov
>            Priority: Minor
>
> Dealing with Closeable resources inside a processElement call is easy: simply use try-with-resources.
> However, bundle- or DoFn-scoped resources, such as long-lived database connections, are less convenient to deal with: you have to open them in startBundle and conditionally close in finishBundle (likewise setup/teardown), taking special care if there's multiple resources to close all of them.
> Perhaps we should provide something like Guava's Closer to DoFn's https://github.com/google/guava/wiki/ClosingResourcesExplained. Ideally, the user would need to only write a startBundle() or setup() method, but not write finishBundle() or teardown() - resources would be closed automatically.


--
This message was sent by Atlassian JIRA
(v6.3.15#6346)