[
https://issues.apache.org/jira/browse/APEXMALHAR-2065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15258484#comment-15258484
]
Timothy Farkas commented on APEXMALHAR-2065:
--------------------------------------------
[~thw] Currently in managed state WindowDataManager functions as the write
ahead log, and each partition writes the data for all its buckets to the same
WAL. In order to support dynamic repartitioning when new partitions are
redeployed they must read all the data from all the WALs of the previous
partitions and pick out the data belonging to their buckets. In order to do
this each new partition must know the windowIds for which there is WAL data
across all the partitions. Currently WindowDataManager only supports retrieving
the windowIds for which there is data for a single Operator Id
> Add getWindows() method to WindowDataManager
> --------------------------------------------
>
> Key: APEXMALHAR-2065
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-2065
> Project: Apache Apex Malhar
> Issue Type: Bug
> Reporter: Timothy Farkas
> Assignee: Timothy Farkas
>
> This method will return all the windows id's across all partitions for which
> there is data.
> This method is required for dynamic repartitioning of Managed State because
> the data for all the partitions must be loaded.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
