From 6cbf144f21b46a1b3d181ea340eba8ef2d3d21bc Mon Sep 17 00:00:00 2001 From: Ahmed Abualsaud <65791736+ahmedabu98@users.noreply.github.com> Date: Wed, 5 Jun 2024 19:34:05 -0400 Subject: [PATCH] fix managed doc (#31521) --- .../src/main/java/org/apache/beam/sdk/managed/Managed.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/Managed.java b/sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/Managed.java index 6f95290e6ee6..911e25cdda14 100644 --- a/sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/Managed.java +++ b/sdks/java/managed/src/main/java/org/apache/beam/sdk/managed/Managed.java @@ -62,7 +62,8 @@ * } * *

Instead of specifying configuration arguments directly in the code, one can provide the - * location to a YAML file that contains this information. Say we have the following YAML file: + * location to a YAML file that contains this information. Say we have the following {@code + * config.yaml} file: * *

{@code
  * foo: "abc"
@@ -74,7 +75,7 @@
  * 
{@code
  * PCollection inputRows = pipeline.apply(Create.of(...));
  *
- * input.apply(Managed.write(ICEBERG).withConfigUrl());
+ * inputRows.apply(Managed.write(ICEBERG).withConfigUrl("path/to/config.yaml"));
  * }
*/ public class Managed {