You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by "Sam McVeety (JIRA)" <ji...@apache.org> on 2016/08/15 14:31:20 UTC
[jira] [Created] (BEAM-551) Support Dynamic PipelineOptions
Sam McVeety created BEAM-551:
--------------------------------
Summary: Support Dynamic PipelineOptions
Key: BEAM-551
URL: https://issues.apache.org/jira/browse/BEAM-551
Project: Beam
Issue Type: New Feature
Components: beam-model
Reporter: Sam McVeety
Assignee: Frances Perry
Priority: Minor
During the graph construction phase, the given SDK generates an initial
execution graph for the program. At execution time, this graph is
executed, either locally or by a service. Currently, Beam only supports
parameterization at graph construction time. Both Flink and Spark supply
functionality that allows a pre-compiled job to be run without SDK
interaction with updated runtime parameters.
In its current incarnation, Dataflow can read values of PipelineOptions at
job submission time, but this requires the presence of an SDK to properly
encode these values into the job. We would like to build a common layer
into the Beam model so that these dynamic options can be properly provided
to jobs.
Please see
https://docs.google.com/document/d/1I-iIgWDYasb7ZmXbGBHdok_IK1r1YAJ90JG5Fz0_28o/edit
for the high-level model, and
https://docs.google.com/document/d/17I7HeNQmiIfOJi0aI70tgGMMkOSgGi8ZUH-MOnFatZ8/edit
for
the specific API proposal.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)