Operators: redundant 1.0.1

Operators

ActiveReplicasLeader: Active replica flow as a single job with leadership election.
ActiveReplicasManual2: Execution of two copies of Flow() to provide a single level of redundancy.
ActiveReplicasManual3: Execution of three copies of Flow() to provide two levels of redundancy.
ActiveReplicasManual3DeDup: Example application demonstrating use of redundant flows and de-duplicators, with leadership election using ZooKeeper.
ActiveReplicasUDP: Execution of redundant copies of Flow() using @parallel.
Analytics: The "analytics" portion of the application including the source.
Flow: Simple flow to be executed multiple times to provide redundant copies.
SendSMS: The sink of the application.
Source
SourceAnalyticsFlow