[
https://issues.apache.org/jira/browse/BEAM-452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Groh resolved BEAM-452.
------------------------------
Resolution: Fixed
Fix Version/s: 0.3.0-incubating
https://github.com/apache/incubator-beam/pull/690
https://github.com/apache/incubator-beam/pull/893
> Implement DoFn per-instance setup and teardown methods
> ------------------------------------------------------
>
> Key: BEAM-452
> URL: https://issues.apache.org/jira/browse/BEAM-452
> Project: Beam
> Issue Type: Bug
> Components: runner-dataflow, runner-direct, runner-flink,
> runner-spark, sdk-java-core
> Reporter: Thomas Groh
> Assignee: Thomas Groh
> Fix For: 0.3.0-incubating
>
>
> https://docs.google.com/document/d/1LLQqggSePURt3XavKBGV7SZJYQ4NW8yCu63lBchzMRk/edit
> BEAM-38 permits DoFns to be reused across bundles. DoFn instances may need to
> do per-instance setup and teardown, and to avoid redoing the work per-bundle,
> the system should provide hooks to call before a DoFn is first used and after
> it will no longer be used.
> DoFn#setup is called before any other calls to DoFn methods. DoFn#teardown is
> called after any method throws an exception, or when the runner will no
> longer use a DoFn instance (e.g. when it evicts it from a cache).
> Runners must call these methods appropriately in all cases (including if a
> DoFn is used exactly once, for a single bundle, and discarded).
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
