You don't need dynamic partitioning to achieve that topology. You can simply create your DAG as: A --> X --> Y and then set the *PARTITIONER* attribute on X as discussed in the "Advanced Features" section of the TopN words tutorial at: http://docs.datatorrent.com/tutorials/topnwords-c7/
The stanza in your properties file should look something like this (with suitable changes for the application and operator names): *<property>* * <name>dt.application.TopNWordsWithQueries.operator.wordReader.attr.PARTITIONER</name>* * <value>com.datatorrent.common.partitioner.StatelessPartitioner:2</value>* *</property>* The platform will then create two replicas of X. For the rest, could you provide additional details of what you are trying to accomplish, what you tried and what sort of problems you encountered ? That will help us provide more precise answers. Ram On Fri, Jun 10, 2016 at 8:37 AM, Junguk Cho <[email protected]> wrote: > Hi. > > I explore "Dynamic Application Modification" with this example( > https://github.com/DataTorrent/examples/tree/master/tutorials/dynamic-partition > ). > > > To be clear, basically, application developers carefully design a program. > For Dynamic Partitioning, in "dynamic partition" example, it uses > threadhold to adjust partition. In addition, to use Modification of DAG > structure, app developers should make program like java classes to use them > later. > Do I interpret that they are determined "compiling time"? > > How do I use "Load balance and Sticky Key" in Apex? > I would like to create this topology for word counting. > For example, > B operator > A operator -> -> one onperator > C Operator > > A sends the same values like "word" to the same operator ( B or C )? > Can we specify this rule in code and how to make two process for B and C > with one class? > > Thanks, > Junguk >
