From 6dd7e0c83c184f418c3e58730c9c6a617e72b9d2 Mon Sep 17 00:00:00 2001 From: Takaaki Hirano Date: Tue, 17 Oct 2023 23:42:01 +0900 Subject: [PATCH] Update README.MD --- retail/retail-java-applications/README.MD | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/retail/retail-java-applications/README.MD b/retail/retail-java-applications/README.MD index 6a4ebe6f..d3182a73 100644 --- a/retail/retail-java-applications/README.MD +++ b/retail/retail-java-applications/README.MD @@ -131,7 +131,7 @@ badElements.apply(fixItemA).apply(fixItemB) This means that your pipeline might have more serial steps, but fusion should help minimize any processing overhead introduced by this. ### Examples -[ValidateAndCorrectClickStreamEvents.java](data-engineering-dept/business-logic/src/main/java/com/google/dataflow/sample/retail/businesslogic/core/transforms/clickstream/ValidateAndCorrectClickStreamEvents.java) +[ValidateAndCorrectCSEvt.java](data-engineering-dept/business-logic/src/main/java/com/google/dataflow/sample/retail/businesslogic/core/transforms/clickstream/ValidateAndCorrectCSEvt.java) ## Using DoFn.StartBundle to micro-batch calls to external services @@ -144,7 +144,7 @@ Instead, we recommend that you use the StartBundle and FinishBundle lifecycle el One minor downside is that bundle sizes are dynamically determined by the implementation of the runner, based on what's currently happening inside the pipeline and its workers, and in stream mode will often be small in size. Dataflow bundling is influenced by backend factors like sharding usage, how much data is available for a particular key, and the throughput of the pipeline. ### Examples -[ValidateAndCorrectClickStreamEvents.java](data-engineering-dept/business-logic/src/main/java/com/google/dataflow/sample/retail/businesslogic/core/transforms/clickstream/ValidateAndCorrectClickStreamEvents.java) +[ValidateAndCorrectCSEvt.java](data-engineering-dept/business-logic/src/main/java/com/google/dataflow/sample/retail/businesslogic/core/transforms/clickstream/ValidateAndCorrectCSEvt.java) ## Using an appropriate side-input pattern ### Content