跨网络执行元组图程序的方法

摘要

编程模型提供了一种用于在分布式架构中执行程序的方法。分布式架构的一个或多个第一分片执行一个或多个操作，并且将元组发送到至少一个第二分片，所述元组是流的一部分并且基于所述一个或多个操作。当流中的元组的发送完成时，一个或多个第一分片向至少一个第二分片发送令牌值。至少一个第二分片确定所述令牌值的总数是否与一个或多个第一分片的数目匹配，并且响应于确定令牌值的总数与一个或多个第一分片的数目匹配而采取第一动作。第一动作可以包括将流标记为完成和/或生成指示流完成的消息。