Repository: apex-malhar Updated Branches: refs/heads/master 9fd29ca27 -> be9f3c8dd
APEXMALHAR-2454 csvformatter documentation xmlrendering issue Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/be9f3c8d Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/be9f3c8d Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/be9f3c8d Branch: refs/heads/master Commit: be9f3c8dd9816ede2467aa16228766918d646d67 Parents: 9fd29ca Author: venkateshDT <[email protected]> Authored: Wed Mar 22 13:34:29 2017 -0700 Committer: venkateshDT <[email protected]> Committed: Wed Mar 22 14:40:44 2017 -0700 ---------------------------------------------------------------------- docs/operators/csvParserOperator.md | 21 +++++++++++---------- 1 file changed, 11 insertions(+), 10 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/be9f3c8d/docs/operators/csvParserOperator.md ---------------------------------------------------------------------- diff --git a/docs/operators/csvParserOperator.md b/docs/operators/csvParserOperator.md index 311c6bb..513e28d 100644 --- a/docs/operators/csvParserOperator.md +++ b/docs/operators/csvParserOperator.md @@ -118,22 +118,23 @@ e.g. ## Partitioning CSV Parser is both statically and dynamically partitionable. ### Static Partitioning -This can be achieved in 2 ways +This can be achieved in 2 ways as shown below. -1. Specifying the partitioner and number of partitions in the populateDAG() method - ```java - CsvParser csvParser = dag.addOperator("csvParser", CsvParser.class); - StatelessPartitioner<CsvParser> partitioner1 = new StatelessPartitioner<CsvParser>(2); - dag.setAttribute(csvParser, Context.OperatorContext.PARTITIONER, partitioner1); - ``` +Specifying the partitioner and number of partitions in the populateDAG() method -2. Specifying the partitioner in properties file. - ```xml +```java + CsvParser csvParser = dag.addOperator("csvParser", CsvParser.class); + StatelessPartitioner<CsvParser> partitioner1 = new StatelessPartitioner<CsvParser>(2); + dag.setAttribute(csvParser, Context.OperatorContext.PARTITIONER, partitioner1); +``` + +Specifying the partitioner in properties file. +```xml <property> <name>dt.operator.{OperatorName}.attr.PARTITIONER</name> <value>com.datatorrent.common.partitioner.StatelessPartitioner:2</value> </property> - ``` +``` where {OperatorName} is the name of the CsvParser operator. Above lines will partition CsvParser statically 2 times. Above value can be changed accordingly to change the number of static partitions.
