Page History

...

1. First, we need to define a new S4 subcluster for that app:

   Code Block
   S4:myApp$ ./s4 newCluster -c=cluster2 -nbTasks=1 -flp=13000

2. Then we can start the adapter, and we use "names" for identifying the output stream (this is the same name used as input by the myApp app)

   Code Block
   ./s4 adapter -appClass=hello.HelloInputAdapter -c=cluster2 -namedStringParameters=adapter.output.stream:names

3. Now let's just provide some data to the external stream:

   Code Block
   S4:~$ echo "Bob" | nc localhost 15000

4. Nodes should output in their console:

   Code Block
   Hello Bob!

both nodes display the same messages because we did not specify any partitioning scheme for the "names" stream in the producer.

What happened?

The following figures illustrate the various steps we have taken.

...