Skip to content

Commit

Permalink
fix: updating example.md (#1262)
Browse files Browse the repository at this point in the history
Signed-off-by: tasneemkoushar <[email protected]>
  • Loading branch information
tasneemkoushar authored Oct 26, 2023
1 parent c1725b1 commit c103427
Showing 1 changed file with 31 additions and 3 deletions.
34 changes: 31 additions & 3 deletions docs/user-guide/user-defined-functions/reduce/examples.md
Original file line number Diff line number Diff line change
Expand Up @@ -4,21 +4,49 @@ Please read [reduce](./reduce.md) to get the best out of these examples.

## Prerequisites

Install the ISB
### Inter-Step Buffer Service (ISB Service)

#### What is ISB Service?
An Inter-Step Buffer Service is described by a [Custom Resource](https://kubernetes.io/docs/concepts/extend-kubernetes/api-extension/custom-resources/), which is used to pass data between vertices of a numaflow pipeline.
Please refer to the doc [Intern-Step Buffer Service](../../../core-concepts/inter-step-buffer.md) for more information on ISB.


#### How to install the ISB Service

```shell
kubectl apply -f https://raw.githubusercontent.com/numaproj/numaflow/stable/examples/0-isbsvc-jetstream.yaml
```

Source used in the examples is an HTTP source producing messages with value 5 and 10 with event time
starting from 60000. Please refer the doc [http source](../../sources/http.md) on how to use an HTTP
The expected output of the above command is shown below:

```shell
$ kubectl get isbsvc

NAME TYPE PHASE MESSAGE AGE
default jetstream Running 3d19h

# Wait for pods to be ready
$ kubectl get pods

NAME READY STATUS RESTARTS AGE
isbsvc-default-js-0 3/3 Running 0 19s
isbsvc-default-js-1 3/3 Running 0 19s
isbsvc-default-js-2 3/3 Running 0 19s
```

---
**NOTE**

The Source used in the examples is an HTTP source producing messages with values 5 and 10 with event time
starting from 60000. Please refer to the doc [http source](../../sources/http.md) on how to use an HTTP
source.
An example will be as follows,

```sh
curl -kq -X POST -H "x-numaflow-event-time: 60000" -d "5" ${http-source-url}
curl -kq -X POST -H "x-numaflow-event-time: 60000" -d "10" ${http-source-url}
```
---

## sum pipeline using fixed window

Expand Down

0 comments on commit c103427

Please sign in to comment.