Populate use_sdf_read in ExpansionService.

apache · May 27, 2021 · 1fd191d · 1fd191d
1 parent 99aa83d
commit 1fd191d
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/...pansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java b/...pansion-service/src/main/java/org/apache/beam/sdk/expansion/service/ExpansionService.java
@@ -394,6 +394,9 @@ private Map<String, TransformProvider> loadRegisteredTransforms() {
     Pipeline pipeline = Pipeline.create();
     ExperimentalOptions.addExperiment(
         pipeline.getOptions().as(ExperimentalOptions.class), "beam_fn_api");
+    // TODO(BEAM-10670): Remove this when we address performance issue.
+    ExperimentalOptions.addExperiment(
+        pipeline.getOptions().as(ExperimentalOptions.class), "use_sdf_read");
 
     ClassLoader classLoader = Environments.class.getClassLoader();
     if (classLoader == null) {