November 2017
Beginner to intermediate
290 pages
7h 34m
English
The simplest way of triggering static partitioning of an operator named, say, OpA, is to add a suitable value for the PARTITIONER attribute in the configuration file (typically an XML file named properties.xml), for example:
<property> <name>apex.operator.OpA.attr.PARTITIONER</name> <value>com.datatorrent.common.partitioner.StatelessPartitioner:2</value></property>
The number following the colon (2 in this example) is the desired number of partitions. The StatelessPartitioner class is already present in the platform and so can be used directly here. This class is part of Apex core and is discussed further later in this chapter.
Alternatively, this attribute can also be set in Java code within the body ...
Read now
Unlock full access