SPL File ActiveReplicasManual3.spl

com.ibm.streamsx.plumbing > redundant 1.0.1 > com.ibm.streamsx.plumbing.sample.redundant.active > ActiveReplicasManual3.spl

Content

Operators

• ActiveReplicasManual3: Execution of three copies of Flow() to provide two levels of redundancy.

Composites

composite ActiveReplicasManual3

Execution of three copies of Flow() to provide two levels of redundancy. The flows are separated into three separate host pools (Rack_0, Rack_1, Rack2) to allow each flow to be executed on a different set of hosts. In this case the pools are defined by host tags, requiring three distinct sets of hosts, tagged with rack_0, rack_1 and rack_2.

SPL Source Code

 public composite ActiveReplicasManual3
 {
     graph
       () as RedundantFlow_0 = Flow()
       {
         config placement: host(Rack_0);
       }
 
       () as RedundantFlow_1 = Flow()
       {
         config placement: host(Rack_1);
       }
 
       () as RedundantFlow_2 = Flow()
       {
         config placement: host(Rack_2);
       }
 
     config
        // Pools are created shared to allow
        // other applications to use the same hosts.
        hostPool:
             Rack_0 = createPool({tags=["rack_0"]}, Sys.Shared),
             Rack_1 = createPool({tags=["rack_1"]}, Sys.Shared),
             Rack_2 = createPool({tags=["rack_2"]}, Sys.Shared);      
 }