Skip to content

README.md

Latest commit

 

History

History
43 lines (30 loc) · 1.51 KB

README.md

File metadata and controls

43 lines (30 loc) · 1.51 KB

Stream Sorter

An example User Defined Function that sorts the incoming stream by event time.

Applying the Pipeline

To apply the pipeline, use the following command:

  kubectl apply -f pipeline.yaml

Publish messages

Port-forward the HTTP endpoint, and make POST requests using curl. Remember to replace xxxx with the appropriate pod names.

  kubectl port-forward stream-sorter-http-one-0-xxxx 8444:8443

  # Post data to the HTTP endpoint
  curl -kq -X POST -d "101" https://localhost:8444/vertices/http-one -H "X-Numaflow-Event-Time: 60000"
  curl -kq -X POST -d "102" https://localhost:8444/vertices/http-one -H "X-Numaflow-Event-Time: 61000"
  curl -kq -X POST -d "103" https://localhost:8444/vertices/http-one -H "X-Numaflow-Event-Time: 62000"
  curl -kq -X POST -d "104" https://localhost:8444/vertices/http-one -H "X-Numaflow-Event-Time: 63000"
  kubectl port-forward stream-sorter-http-two-0-xxxx 8445:8443

  # Post data to the HTTP endpoint
  curl -kq -X POST -d "105" https://localhost:8445/vertices/http-two -H "X-Numaflow-Event-Time: 70000"
  curl -kq -X POST -d "106" https://localhost:8445/vertices/http-two -H "X-Numaflow-Event-Time: 71000"
  curl -kq -X POST -d "107" https://localhost:8445/vertices/http-two -H "X-Numaflow-Event-Time: 72000"
  curl -kq -X POST -d "108" https://localhost:8445/vertices/http-two -H "X-Numaflow-Event-Time: 73000"

Verify the output

  kubectl logs -f stream-sorter-log-sink-0-xxxx

The output should be sorted by event time.