Ram is on the money. Partitioner attribute will do exactly the same.

‹
Chetan


On 11/19/15, 4:07 PM, "Munagala Ramanath" <[email protected]> wrote:

>You can just set the property:
>dt.application.<app-name>.operator.<op-name>.attr.PARTITIONER
>to com.datatorrent.common.partitioner.StatelessPartitioner:N
>where N is the number of desired partitions.
>
> Is that what you're trying to do ?
>
>Ram
>
>On Thu, Nov 19, 2015 at 3:49 PM, Siyuan Hua <[email protected]>
>wrote:
>> Sometimes I want to separate the Partitioner logic from operator and
>>still
>> I want to have default partitioner for the operator (with specifying it
>> from application)
>>
>>
>> Best,
>> Siyuan

Reply via email to