You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@apex.apache.org by "Yogi Devendra (JIRA)" <ji...@apache.org> on 2016/08/05 05:42:20 UTC
[jira] [Created] (APEXCORE-501) Sub Partitioning the parallel
partitions
Yogi Devendra created APEXCORE-501:
--------------------------------------
Summary: Sub Partitioning the parallel partitions
Key: APEXCORE-501
URL: https://issues.apache.org/jira/browse/APEXCORE-501
Project: Apache Apex Core
Issue Type: New Feature
Reporter: Yogi Devendra
Hi,
I have a DAG A->B->C.
1. A is kafka input operator reading from 4 different topics configured with ONE_TO_ONE strategy. Thus creating 4 partitons of A.
2. B and C are configured to have parallel partitions w.r.t. their input port. Thus, currently both B, C have 4 partitions.
I am observing B significant latency in B operator. Thus, would like to have 2 partitions for B per partition of A. Since, application is latency intensive, I want to avoid unifiers as far as possible.
How to achieve this partitioning?
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)