Checkpointing a set of stream computing data
First Claim
1. A computer-implemented method for checkpointing a set of stream computing data with respect to a stream computing environment having a set of windowed stream operators including both a first windowed stream operator and a second windowed stream operator, the method comprising:
- modifying, based on both the first windowed stream operator having a first subset of the set of stream computing data and the second windowed stream operator having the first subset of the set of stream computing data, a set of checkpoint access permissions to authorize the first windowed stream operator to perform a checkpointing operation with respect to the first subset of the set of stream computing data;
checkpointing the first subset of the set of stream computing data using the first windowed stream operator based on the modified set of checkpoint access permissions; and
preventing the second windowed stream operator from checkpointing the first subset of the set of stream computing data based on the modified set of checkpoint access permissions.
1 Assignment
0 Petitions
Accused Products
Abstract
Disclosed aspects relate to checkpointing a set of stream computing data with respect to a stream computing environment having a set of windowed stream operators including both a first windowed stream operator and a second windowed stream operator. It may be identified that the first windowed stream operator has a first subset of the set of stream computing data. It may be identified that the second windowed stream operator has the first subset of the set of stream computing data. It may be determined to checkpoint the first subset of the set of stream computing data without a redundant checkpoint related to the first and second windowed stream operators. The set of stream computing data may be checkpointed without the redundant checkpoint of the first subset of the set of stream computing data.
15 Citations
18 Claims
-
1. A computer-implemented method for checkpointing a set of stream computing data with respect to a stream computing environment having a set of windowed stream operators including both a first windowed stream operator and a second windowed stream operator, the method comprising:
-
modifying, based on both the first windowed stream operator having a first subset of the set of stream computing data and the second windowed stream operator having the first subset of the set of stream computing data, a set of checkpoint access permissions to authorize the first windowed stream operator to perform a checkpointing operation with respect to the first subset of the set of stream computing data; checkpointing the first subset of the set of stream computing data using the first windowed stream operator based on the modified set of checkpoint access permissions; and preventing the second windowed stream operator from checkpointing the first subset of the set of stream computing data based on the modified set of checkpoint access permissions. - View Dependent Claims (2, 3, 4, 5, 6)
-
-
7. A system for checkpointing a set of stream computing data with respect to a stream computing environment having a set of windowed stream operators including both a first windowed stream operator and a second windowed stream operator, the system comprising:
-
a memory; and at least one processor communicatively coupled to the memory and configured to; modify, based on both the first windowed stream operator having a first subset of the set of stream computing data and the second windowed stream operator having the first subset of the set of stream computing data, a set of checkpoint access permissions to authorize the first windowed stream operator to perform a checkpointing operation with respect to the first subset of the set of stream computing data; checkpoint the first subset of the set of stream computing data using the first windowed stream operator based on the modified set of checkpoint access permissions; and prevent the second windowed stream operator from checkpointing the first subset of the set of stream computing data based on the modified set of checkpoint access permissions. - View Dependent Claims (8, 9, 10, 11, 12)
-
-
13. A computer program product for checkpointing a set of stream computing data with respect to a stream computing environment having a set of windowed stream operators including both a first windowed stream operator and a second windowed stream operator, the computer program product comprising a computer readable storage medium having program instructions embodied thereon, wherein the computer readable storage medium is not a transitory signal per se, the program instructions executable by a processor to cause the processor to:
-
modify, based on both the first windowed stream operator having a first subset of the set of stream computing data and the second windowed stream operator having the first subset of the set of stream computing data, a set of checkpoint access permissions to authorize the first windowed stream operator to perform a checkpointing operation with respect to the first subset of the set of stream computing data; checkpoint the first subset of the set of stream computing data using the first windowed stream operator based on the modified set of checkpoint access permissions; and prevent the second windowed stream operator from checkpointing the first subset of the set of stream computing data based on the modified set of checkpoint access permissions. - View Dependent Claims (14, 15, 16, 17, 18)
-
Specification