You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@apex.apache.org by Sandesh Hegde <sa...@datatorrent.com> on 2016/06/16 01:18:35 UTC

Purging the checkpoints from the StreamingContainers

Hello Team,

Purging of the Checkpoints is done in Stram. Why not do that from the
StreamingContainers?

Committed window information is already available in StreamingContainers
and it will also distribute the computation across the containers.

Corner cases can still be handled in Stram. Example: Dynamic partitioning.

Thanks