File tree Expand file tree Collapse file tree
core/src/main/java/feast/core/job/option Expand file tree Collapse file tree Original file line number Diff line number Diff line change 2222import java .util .List ;
2323import java .util .Map ;
2424
25+ /**
26+ * Value class containing the application-default configuration for a runner.
27+ * When a job is started by core, all fields in the object will be converted into
28+ * --key=value args to seed the beam pipeline options.
29+ *
30+ */
2531public abstract class RunnerConfig {
32+
33+ /**
34+ * Converts the fields in this class to a list of --key=value args to be
35+ * passed to a {@link org.apache.beam.sdk.options.PipelineOptionsFactory}.
36+ *
37+ * Ignores values that are proto-default (e.g. empty string, 0).
38+ *
39+ * @return Array of string args in the format --key=value.
40+ * @throws IllegalAccessException
41+ */
2642 public String [] toArgs () throws IllegalAccessException {
2743 List <String > args = new ArrayList <>();
2844 for (Field field : this .getClass ().getFields ()) {
You can’t perform that action at this time.
0 commit comments