address comments

sdks/java/core/src/main/java/org/apache/beam/sdk/options/InitializePipelineOptionsFactory.java

@@ -0,0 +1,29 @@
+package org.apache.beam.sdk.options;
+
+import java.util.Iterator;
+import java.util.ServiceLoader;
+import org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.Iterators;
+import org.checkerframework.checker.initialization.qual.Initialized;
+import org.checkerframework.checker.nullness.qual.Nullable;
+
+
+@SuppressWarnings("rawtypes")
+/**
+ * Interface to support offspring wire-in for Li: if input class meets some requirements,
+ * the customized pipelineOptions will be initialized.
+ *
+ */
+public interface InitializePipelineOptionsFactory<T> {
+  T initializePipelineOptions(T pipelineOptions, Class<T> clazz);
+
+  interface Registrar {
+    InitializePipelineOptionsFactory create();
+  }
+
+
+  static @Initialized @Nullable InitializePipelineOptionsFactory getFactory() {
+    final Iterator<InitializePipelineOptionsFactory.Registrar>
+        factories = ServiceLoader.load(InitializePipelineOptionsFactory.Registrar.class).iterator();
+    return factories.hasNext() ? Iterators.getOnlyElement(factories).create() : null;
+  }
+}

sdks/java/core/src/main/java/org/apache/beam/sdk/options/ProxyInvocationHandler.java

@@ -305,8 +305,8 @@ <T extends PipelineOptions> T as(Class<T> iface, PipelineOptions pipelineOptions
           computedProperties =
               computedProperties.updated(iface, existingOption, propertyDescriptors);
           // Linkedin specific change: initialize the offspring generator
-          if (pipelineOptions != null && InvokePipelineOptionsFactory.getFactory() != null) {
-            InvokePipelineOptionsFactory.getFactory().getPipelineOptions(existingOption, iface);
+          if (pipelineOptions != null && InitializePipelineOptionsFactory.getFactory() != null) {
+            InitializePipelineOptionsFactory.getFactory().initializePipelineOptions(existingOption, iface);
           }
         }
       }