Patent SG-11201805201X-A (SG)
Title: Recoverable stream processing
Inventor: DOUROS BRYAN PHIL
IPC: G06F11/14
Filed: 2017-01-13
Abstract: INTERNATIONAL APPLICATION PUBLISHED UNDER THE PATENT COOPERATION TREATY (PCT) (19) World Intellectual Property -, Organization MD 1111101110101011111 0101111101110111011101111101fillOIMIOU III International Bureau 0.. .1 j ..... ..or::,„, (10) International Publication Number (43) International Publication Date WO 2017/123849 Al 20 July 2017 (20.07.2017) WIPO I PCT (51) International Patent Classification: (81) Designated States (unless otherwise indicated, for every GO6F 9 / 5 2 (2006.01) GO6F 11/14 (2006.01) kind of national protection available): AE, AG, AL, AM, AO, AT, AU, AZ, BA, BB, BG, BH, BN, BR, BW, BY, (21) International Application Number: BZ, CA, CH, CL, CN, CO, CR, CU, CZ, DE, DJ, DK, DM, PCT/US2017/013309 DO, DZ, EC, EE, EG, ES, FI, GB, GD, GE, GH, GM, GT, (22) International Filing Date: HN, HR, HU, ID, IL, IN, IR, IS, JP, KE, KG, KH, KN, 13 January 2017 (13.01.2017) KP, KR, KW, KZ, LA, LC, LK, LR, LS, LU, LY, MA, MD, ME, MG, MK, MN, MW, MX, MY, MZ, NA, NG, (25) Filing Language: English NI, NO, NZ, OM, PA, PE, PG, PH, PL, PT, QA, RO, RS, (26) Publication Language: English RU, RW, SA, SC, SD, SE, SG, SK, SL, SM, ST, SV, SY, TH, TJ, TM, TN, TR, TT, TZ, UA, UG, US, UZ, VC, VN, (30) Priority Data: ZA, ZM, ZW. 62/278,528 14 January 2016 (14.01.2016) US (84) Designated States (unless otherwise indicated, for every (71) Applicant: AB INITIO TECHNOLOGY LLC [US/US]; kind of regional protection available): ARIPO (BW, GH, 201 Spring Street, Lexington, Massachusetts 02421 (US). GM, KE, LR, LS, MW, MZ, NA, RW, SD, SL, ST, SZ, (72) Inventors: DOUROS, Bryan Phil; 92 Lakeview Road, TZ, UG, ZM, ZW), Eurasian (AM, AZ, BY, KG, KZ, RU, Framingham, Massachusetts 01701 (US). STANFILL, TJ, TM), European (AL, AT, BE, BG, CH, CY, CZ, DE, DK, EE, ES, FI, FR, GB, GR, HR, HU, IE, IS, IT, LT, LU, Craig W.; 43 Huckleberry Hill Road, Lincoln, Massachu- LV, MC, MK, MT, NL, NO, PL, PT, RO, RS, SE, SI, SK, setts 01773 (US). WHOLEY, Joseph Skeffington, III; 11 Hillcrest Road, Belmont, Massachusetts 02478 (US). SM, TR), OAPI (BF, BJ, CF, CG, CI, CM, GA, GN, GQ, GW, KM, ML, MR, NE, SN, TD, TG). Agent: MASON, Elliott J., III; Occhiuti & Rohlicek LLP, (74) Published: 321 Summer Street, Boston, Massachusetts 02210 (US). — with international search report (Art. 21(3)) = (54) Title: RECOVERABLE STREAM PROCESSING = Processing of First Pulse 100 112C 112B 112A 132A M 2 122A ' G%////r, . HUH 122A, 121 1g 131 135 122A121 113A- 121 141 142 11 t:t 7r GC FIG. 7B M \" (57) : A computing system (100) includes nodes (152) executing data processing programs that each process at least one 1-1 ---- stream of data units. A data storage system (156, 157) stores shared data accessible by at least two of the programs. Processing at I r ----- least one stream using a first data processing program includes: processing a first stream of data units that includes multiple subsets 1-1 C of contiguous data units; initiating termination of processing within the first data processing program, between processing a first sub - N set of contiguous data units and processing a second subset of contiguous data units adjacent to the first subset of contiguous data 0 units within the first stream of data units; durably storing at least some changes to the shared data caused by processing the first sub - ,-t set of contiguous data units after determining that the termination of processing within the first data processing program has com- pleted; and resuming processing within the first data processing program.