Patent ID: 8856374
Filing Date: 2014-10-07
Classification: G06F,H04L

Abstract:
1. A method of reconfiguring a stream process in a distributed system, the method comprising the steps of: managing the stream process including at least one operator, the at least one operator communicatively associated with at least one stream target, the at least one operator using a partition function to determine the routing of messages to the at least one stream target; determining a safe state within the stream process; and configuring a configuration state of the at least one operator during the safe state, wherein the at least one operator spans a batch window over multiple batches and the partition function of the at least one operator is configured with an old partition function and new partition function, and wherein the at least one operator transmits batches partitioned according to the old partition function and the new partition function based on a time derived from a size of the batch window.