numaproj / numaflow-go

Numaflow Golang SDK
Apache License 2.0
46 stars 11 forks source link

Add a user defined source data transformer example for numaflow e2e test #33

Closed KeranYang closed 1 year ago

KeranYang commented 1 year ago

Event Time Filter

This is a simple User Defined Function example which receives a message, applies the following data transformation, and returns the message.

Data Transformation

Signed-off-by: Keran Yang yangkr920208@gmail.com

vigith commented 1 year ago

Please make sure for images, the image name starts with mapT; we have a convention for the example image names, https://quay.io/organization/numaio