[
https://issues.apache.org/jira/browse/APEXMALHAR-2049?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15236169#comment-15236169
]
Timothy Farkas commented on APEXMALHAR-2049:
--------------------------------------------
Discussed with [~csingh] and came up with the following design for the code.
- ManagedStateImpl and ManagedTimeStateImpl can support dynamic partitioning.
ManagedTimeUnifiedStateImpl cannot support dynamic partitioning.
- We will create an interface like ManagedStateUser which will return to us a
managed state implementation. This interface will be implemented by operators
that are using managed state.
- We will create an interface like PartitionableManagedState which will be
implemented by ManagedState implementations:
PartitionableManagedState
{
public ... partition(Partition<ManagedStateUser>...);
}
The ManagedStateImpl and ManagedTimeStateImpl classes will implement this
interface.
Also each of these classes will have a pluggable BucketPartitionManager which
will implement this interface as well. The ManagedState Implementations will
pass the partitioning calls onto the BucketPartitionManager which will handle
redistributing buckets and setting partition keys.
> Managed State - add support for distributing buckets to partition
> -----------------------------------------------------------------
>
> Key: APEXMALHAR-2049
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-2049
> Project: Apache Apex Malhar
> Issue Type: Improvement
> Reporter: Timothy Farkas
> Assignee: Timothy Farkas
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
