Patent SG-11201809097W-A (SG)
Title: Reconfigurable distributed processing
Inventor: NEWBERN JEFFREY
IPC: G06F9/50
Filed: 2017-05-17
Abstract: 123 123 130 140 100 121 Accept Group Accept Group 130 123 123 1 190 191 Partition Group 120 FIG. 1B 192 193 Partition Group 120 194 121 131 131 195 J Work Group 140 132 Work Group 140 132 140 140 (12) INTERNATIONAL APPLICATION PUBLISHED UNDER THE PATENT COOPERATION TREATY (PCT) (19) World Intellectual Property Organization International Bureau (43) International Publication Date 23 November 2017 (23.11.2017) WIPO I PCT ill~~~~~~~~ 011101tIIl two H01°111°1 Oil olo Imo oimIE (10) International Publication Number WO 2017/201127 Al (51) International Patent Classification: GOOF 9 / 50 (2006.01) GOOF 9 / 4 4 (2006.01) (21) International Application Number: PCT/US2017/033033 (22) International Filing Date: 17 May 2017 (17.05.2017) (25) Filing Language: English (26) Publication Language: English (30) Priority Data: 62/337,422 17 May 2016 (17.05.2016) US (71) Applicant: AB INITIO TECHNOLOGY LLC [US/US]; 201 Spring Street, Lexington, Massachusetts 02421 (US). (72) Inventors: NEWBERN, Jeffrey; 20 Kendall Road, Sud- bury, Massachusetts 01776 (US). STANFILL, Craig W.; 43 Huckleberry Hill Road, Lincoln, Massachusetts 01773 (US). (74) Agent: MASON, III, Elliott J.; Occhiuti & Rohlicek LLP, 321 Summer Street, Boston, Massachusetts 02210 (US). (81) Designated States (unless otherwise indicated, for every kind of national protection available): AE, AG, AL, AM, AO, AT, AU, AZ, BA, BB, BG, BH, BN, BR, BW, BY, BZ, CA, CH, CL, CN, CO, CR, CU, CZ, DE, DJ, DK, DM, DO, DZ, EC, EE, EG, ES, FL GB, GD, GE, GH, GM, GT, HN, HR, HU, ID, IL, IN, IR, IS, JP, KE, KG, KH, KN, KP, KR, KW, KZ, LA, LC, LK, LR, LS, LU, LY, MA, MD, ME, MG, MK, MN, MW, MX, MY, MZ, NA, NG, NI, NO, NZ, OM, PA, PE, PG, PH, PL, PT, QA, RO, RS, 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, ZA, ZM, ZW. (54) Title: RECONFIGURABLE DISTRIBUTED PROCESSING (57) : Distributed processing of a data collection includes receiving information for configuring a distributed processing N system. A first configuration of components is formed including sources (110) of data elements and workers (240) configured to process data elements, distributed among computing resources (190-194). Each data element includes a partition value that identifies a subset of the workers according to a partition rule. Data elements are accepted from the sources for a first part of the data collection in a first O processing epoch and the data elements are routed through the first configuration. After accepting a first part of the data collection, change of configuration is initiated to a second configuration. A succession of two or more transitions between configurations of N components is performed to a succession of modified configurations, a last of which corresponds to the second configuration. Further O data elements are accepted from sources of the second configuration in a second processing epoch. [Continued on next page] WO 2017/201127 Al MIDEDIMOMOIDEIROIDEM0010101R1OHOIDERVOIMIE (84) Designated States (unless otherwise indicated, for every kind of regional protection available): ARIPO (BW, GH, GM, KE, LR, LS, MW, MZ, NA, RW, SD, SL, ST, SZ, TZ, UG, ZM, ZW), Eurasian (AM, AZ, BY, KG, KZ, RU, 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, LV, MC, MK, MT, NL, NO, PL, PT, RO, RS, SE, SI, SK, SM, TR), OAPI (BF, BJ, CF, CG, CI, CM, GA, GN, GQ, GW, KM, ML, MR, NE, SN, TD, TG). Published: — with international search report (Art. 21(3))