Hi,
I have tried partitioning block reader by setting the following
properties.
<property>
<name>dt.application.appname.operator.reader.attr.MEMORY_MB
</name>
<value>24576</value>
</property>
property>
<name>dt.application.appname.operator.reader.prop.PARTITIONER</name>
<value>com.datatorrent.lib.partitioner.StatelessPartitioner:4</value>
</property>
<!- Only Downstream operator of reader, It has a port 'input' listening on
output port of reader - This will not unify data -->
<property>
<name>dt.application.appname.operator.console.port.input.attr.PARTITION_PARALLEL</name>
<value>true</value>
</property>
This is reading data into a single operator and not partitioning reader
operator, do I need to add something else for the partitioning to be enabled.
BlockReader has not implemented Partitioner since it is already implemented in
one of its parent classes. Please suggest.
Regards,
Venkatesh.