US 12,353,929 B2
System and method for linearizing messages from data sources for optimized high-performance processing in a stream processing system
Shalini Raghavan, Minneapolis, MN (US); Tom J. Traughber, Austin, TX (US); and George Vanecek, Jr., San Jose, CA (US)
Assigned to FAIR ISAAC CORPORATION, Minneapolis, MN (US)
Filed by FAIR ISAAC CORPORATION, Roseville, MN (US)
Filed on Jan. 17, 2024, as Appl. No. 18/415,440.
Application 18/415,440 is a continuation of application No. 17/243,428, filed on Apr. 28, 2021, granted, now 11,900,181.
Application 17/243,428 is a continuation of application No. 15/490,633, filed on Apr. 18, 2017, granted, now 11,016,831, issued on May 25, 2021.
Application 15/490,633 is a continuation of application No. 14/940,095, filed on Nov. 12, 2015, granted, now 9,632,847, issued on Apr. 25, 2017.
Claims priority of provisional application 62/078,336, filed on Nov. 11, 2014.
Prior Publication US 2024/0184651 A1, Jun. 6, 2024
This patent is subject to a terminal disclaimer.
Int. Cl. G06F 9/54 (2006.01); G06F 16/11 (2019.01); G06F 16/2455 (2019.01)
CPC G06F 9/546 (2013.01) [G06F 9/54 (2013.01); G06F 9/541 (2013.01); G06F 16/116 (2019.01); G06F 16/24568 (2019.01)] 17 Claims
OG exemplary drawing
 
1. A computer implemented method comprising:
passing, by at least one programmable processor, a plurality of files to a file staging area of a distributed process, the plurality of files received from a data object including the plurality of files at the distributed process;
generating, by the at least one programmable processor, a tuple from the data object, the tuple comprising a first field and a second field, the first field containing a file reference referring to the plurality of files in the file staging area, and the second field being configured to store a value indicative that the first field contains the file reference; and
unbundling, by the at least one programmable processor and in response to the second field of the tuple failing to store the value indicative that the first field contains the file reference, the plurality of files at the file staging area by an unbundling task, the unbundling task configured to create at least one batch file in the file staging area;
redirecting, by the at least one programmable processor, the tuple to the file staging area instead of to a downstream task, in response to determining the downstream task is unable to process the plurality of files.