From 5dd1bf7592f9a02e71b31a9f956ce04de0cb6719 Mon Sep 17 00:00:00 2001 From: Vigith Maurice Date: Tue, 13 Aug 2024 10:54:30 -0700 Subject: [PATCH 1/2] chore: add transfomer to the MonoVertex eg Signed-off-by: Vigith Maurice --- examples/21-simple-mono-vertex.yaml | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/examples/21-simple-mono-vertex.yaml b/examples/21-simple-mono-vertex.yaml index be625c41d2..5e6f156404 100644 --- a/examples/21-simple-mono-vertex.yaml +++ b/examples/21-simple-mono-vertex.yaml @@ -7,6 +7,10 @@ spec: udsource: container: image: quay.io/numaio/numaflow-java/source-simple-source:stable + # transformer is an optional container to do any transformation to the incoming data before passed to the sink + transformer: + container: + image: quay.io/numaio/numaflow-rs/source-transformer-now:stable sink: udsink: container: From 3b086eb4041749adae47801405510814f555a6f7 Mon Sep 17 00:00:00 2001 From: Vigith Maurice Date: Tue, 13 Aug 2024 10:55:05 -0700 Subject: [PATCH 2/2] chore: add transformer to the MonoVertex Signed-off-by: Vigith Maurice --- examples/21-simple-mono-vertex.yaml | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/21-simple-mono-vertex.yaml b/examples/21-simple-mono-vertex.yaml index 5e6f156404..98192aa8fd 100644 --- a/examples/21-simple-mono-vertex.yaml +++ b/examples/21-simple-mono-vertex.yaml @@ -7,7 +7,7 @@ spec: udsource: container: image: quay.io/numaio/numaflow-java/source-simple-source:stable - # transformer is an optional container to do any transformation to the incoming data before passed to the sink + # transformer is an optional container to do any transformation to the incoming data before passing to the sink transformer: container: image: quay.io/numaio/numaflow-rs/source-transformer-now:stable