[
https://issues.apache.org/jira/browse/APEXMALHAR-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15321259#comment-15321259
]
ASF GitHub Bot commented on APEXMALHAR-2102:
--------------------------------------------
GitHub user ilganeli opened a pull request:
https://github.com/apache/apex-malhar/pull/315
[APEXMALHAR-2102][WIP] Support clone partitioner
Created a Clone partitioner similar to the StatelessPartitioner that
assigns all data to all partitions
Added a simple unit test suite to test scale up and scale down
Added a unit test that adds the operator to a DAG and demonstrates that all
parittions get the same data
This references: https://issues.apache.org/jira/browse/APEXMALHAR-2102
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ilganeli/incubator-apex-malhar APEXCORE-146B
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/apex-malhar/pull/315.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #315
----
commit 74f6fd5113a3d488015a9817790018dd63b5e8cb
Author: Ilya Ganelin <[email protected]>
Date: 2016-05-26T19:39:24Z
Added a new partitioner that replicates data across all partitions by
default.
commit aef60461c8d43c8c7cbfa997a5c9cbe185301165
Author: Ilya Ganelin <[email protected]>
Date: 2016-05-26T19:39:24Z
Added a new partitioner that replicates data across all partitions by
default.
Fixed package settings. Deleted unused imports.
commit 580f4af7491842bdf13ca7375dc12c3252f578c8
Author: Ilya Ganelin <[email protected]>
Date: 2016-05-26T20:37:28Z
Merge conflicts resolved.
commit 3d127607c0d0757b68b16b275d64f4c8d1cb73d7
Author: Ilya Ganelin <[email protected]>
Date: 2016-05-26T19:39:24Z
Added a new partitioner that replicates data across all partitions by
default.
Fixed package settings. Deleted unused imports.
Added a test that demonstrates all partitions seeing the same data.
Fixed test failure.
Updated unit test to actually create an application using the
ClonePartitioner and demonstrate that all partitions of an operator see the
same data.
Cleande up tests.
----
> Add A Clone Partitioner Which Sends The Same Data To Each Partition
> -------------------------------------------------------------------
>
> Key: APEXMALHAR-2102
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-2102
> Project: Apache Apex Malhar
> Issue Type: New Feature
> Reporter: Timothy Farkas
> Assignee: Ilya Ganelin
>
> This should go into com.datatorrent.common.partitioner and would be very
> similar to the StatelessPartitioner
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
