Hi, For Dynamic Partitioning, please take a look at the example at: https://github.com/DataTorrent/examples/tree/master/tutorials/dynamic-partition
as well as the Malhar class: https://github.com/apache/apex-malhar/blob/master/library/src/main/java/com/datatorrent/lib/partitioner/StatelessThroughputBasedPartitioner.java For dynamically modifying the DAG, you should be able to use the *apexcli* (aka *dtcli*) commandline tool documented here: http://docs.datatorrent.com/apexcli/ Roughly speaking, the process is: 1. Connect to your application id using the *connect* command 2. *begin-logical-plan-change* 3. Use some combination of *remove-stream*, *remove-operator*, *create-operator,* and *create-stream* 4. *submit* Ram On Tue, Jun 7, 2016 at 6:49 AM, Junguk Cho <[email protected]> wrote: > Hi, all. > > I read tutorial in > > https://apex.apache.org/docs/apex/application_development/#running-a-test-application > . > > There are some capabilities from apache apex called "Dynamic > Application Modifications". > > I would like to explore "Dynamic Partitioning" and "Modification of > DAG structure". > How do I test both capabilities? > In addition, are there some example to explore them? > > Thanks in advance. > - Junguk >
