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.





Reply via email to