Source: https://patents.google.com/patent/US9507682B2/en
Timestamp: 2018-04-23 23:35:17
Document Index: 415250705

Matched Legal Cases: ['Application No. 2', 'Application No. 2', 'Application No. 2010', 'Application No. 200680023178', 'Application No. 2014', 'application No. 2013', 'Application No. 10', 'Application No. 10', 'Application No. 10']

US9507682B2 - Dynamic graph performance monitoring - Google Patents
US9507682B2
US9507682B2 US13678921 US201213678921A US9507682B2 US 9507682 B2 US9507682 B2 US 9507682B2 US 13678921 US13678921 US 13678921 US 201213678921 A US201213678921 A US 201213678921A US 9507682 B2 US9507682 B2 US 9507682B2
US13678921
US20140143760A1 (en )
1. A method for processing data in a data processing system, wherein a first dataflow graph is executed, the method including:
receiving multiple units of work that each include one or more records;
determining a characteristic of a first unit of work based on data included in the one or more records of the first unit of work;
identifying, by a component of the first dataflow graph, a second dataflow graph from multiple available dataflow graphs based on the determined characteristic, the multiple available dataflow graphs being stored in a data storage system;
processing the first unit of work using the second dataflow graph based on loading the second dataflow graph into the first dataflow graph;
receiving, by the first dataflow graph, one or more values of one or more performance metrics associated with the processing of the first unit of work using the loaded second dataflow graph;
outputting, by the first dataflow graph to a performance monitoring module, the one or more received values of the one or more performance metrics associated with the processing of the first unit of work using the loaded second dataflow graph, wherein the performance monitoring module receives a plurality of values of one or more performance metrics output by a plurality of dataflow graphs;
selecting, from among the plurality of values of the one or more performance metrics output by the plurality of dataflow graphs, values of one or more performance metrics associated with an identifier for the second dataflow graph; and
aggregating the values selected for the one or more performance metrics associated with the identifier for the second dataflow graph.
7. A non-transitory computer-readable storage medium storing a computer program for processing data in a data processing system, wherein a first dataflow graph is executed, the computer program including instructions for causing a computing system to:
receive multiple units of work that each include one or more records;
determine a characteristic of a first unit of work based on data included in the one or more records of the first unit of work;
identify, by a component of the first dataflow graph, a second dataflow graph from multiple available dataflow graphs based on the determined characteristic, the multiple available dataflow graphs being stored in a data storage system;
process the first unit of work using the second dataflow graph based on loading the second dataflow graph into the first dataflow graph;
receive, by the first dataflow graph, one or more values of one or more performance metrics associated with the processing of the first unit of work using the loaded second dataflow graph;
output, by the first dataflow graph to a performance monitoring module, the one or more received values of the one or more performance metrics associated with the processing of the first unit of work using the loaded second dataflow graph, wherein the performance monitoring module receives a plurality of values of one or more performance metrics output by a plurality of dataflow graphs;
select, from among the plurality of values of the one or more performance metrics output by the plurality of dataflow graphs, values of one or more performance metrics associated with an identifier for the second dataflow graph; and
aggregate the values selected for the one or more performance metrics associated with the identifier for the second dataflow graph.
13. A computing system for processing data, the computing system including:
an input device or port configured to receive multiple units of work that each include one or more records; and
at least one processor configured to process data, the processing including:
identifying, by a component of a first dataflow graph, a second dataflow graph from multiple available dataflow graphs based on the determined characteristic, the multiple available dataflow graphs being stored in a data storage system;
19. A computing system for processing data, the computing system including:
means for receiving multiple units of work that each include one or more records;
means for identifying, by a component of a first dataflow graph, a second dataflow graph from multiple available dataflow graphs based on the determined characteristic, the multiple available dataflow graphs being stored in a data storage system;
means for processing the first unit of work using the second dataflow graph based on loading the second dataflow graph into the first dataflow graph;
means for receiving, by the first dataflow graph, one or more values of one or more performance metrics associated with the processing of the first unit of work using the loaded second dataflow graph;
means for outputting, by the first dataflow graph to a performance monitoring module, the one or more received values of the one or more performance metrics associated with the processing of the first unit of work using the loaded second dataflow graph, wherein the performance monitoring module receives a plurality of values of one or more performance metrics output by a plurality of dataflow graphs;
means for selecting, from among the plurality of values of the one or more performance metrics output by the plurality of dataflow graphs, values of one or more performance metrics associated with an identifier for the second dataflow graph; and
means for aggregating the values selected for the one or more performance metrics associated with the identifier for the second dataflow graph.
US13678921 2012-11-16 2012-11-16 Dynamic graph performance monitoring Active US9507682B2 (en)
KR20157014826A KR20150084892A (en) 2012-11-16 2013-11-15 Dynamic graph performance monitoring
US20140143760A1 true US20140143760A1 (en) 2014-05-22
US9507682B2 true US9507682B2 (en) 2016-11-29
US13678921 Active US9507682B2 (en) 2012-11-16 2012-11-16 Dynamic graph performance monitoring
WO2017141176A1 (en) * 2016-02-18 2017-08-24 New Relic, Inc. Identifying the root cause of an issue observed during application execution
WO2005086906A3 (en) 2004-03-08 2006-11-16 Initio Software Corp Ab Dependency graph parameter scoping
US20090313625A1 (en) * 2008-06-16 2009-12-17 Sharoff Narasimha N Workload management, control, and monitoring
"RASSP Data Flow Graph Design Application Note." International Conference on Parallel Processing, Dec. 2000, Retrieved from Internet <http://www.atl.external.lmco.com/projects/rassp/RASSP-legacy/appnotes/FLOW/APNOTE-FLOW-02>, 5 pages.
Canadian Office Action in Application No. 2,750,279, dated Mar. 24, 2016 (5 pages).
Canadian Office Action in Application No. 2,801,573, dated Apr. 13, 2016 (5 pages).
Chinese Office Action (English Translation) in Application No. 2010-80042716.8, mailed Apr. 8, 2016 (14 pages).
Chinese Office Action in Application No. 200680023178.1, issued Apr. 14, 2016 (10 pages) (English translation).
Chinese Office Action issued in CN 201180039226.7, issued May 4, 2015.
European Examination report issued in EP 06 785 623.7 on Nov. 24, 2014, 5 pages.
Examination Report in Application No. IN 10117/DELNP/2007, dated Dec. 22, 2015 (2 pages).
Examination Report in India Application 250CHENP2009, Aug. 31, 2016 (7 pages).
IBM: "Concepts and Architecture-Version 3.6," Internet citation, http://publibfp.boulder.ibm.com.epubs/pdf/h126857, retrieved Apr. 19, 2007.
International Search Report & Written Opinion received in PCT application No. PCT/US2013/070386, mailed Feb. 12, 2014, 7 pages.
International Search Report & Written Opinion received in PCT application No. PCT/US2013/076416, mailed Apr. 9, 2014, 10 pages.
International Search Report and Written Opinion, PCT/US2014/068754, mailed May 8, 2015 (17 pages).
Japanese Office Action (English Translation) in application No. JP2014-077798, mailed Nov. 11, 2015 (6 pages).
Japanese Office Action in Application No. 2014-159008, mailed May 31, 2015 (English Translation) (4 pages).
Japanese Office Action, with English Translation, JP application No. 2013-515468, mailed Jul. 24, 2015 (4 pages).
Karasawa, K.; Iwata, M.; and Terada, H.-"Direct generation of data-driven program for stream-oriented processing"-Published in: Parallel Architctures and Compilation Techniques., 1997. Proceedings , 1997 International Conference on; Nov. 10-14, 1997 San Francisco, CA-pp. 295-306.
Korean Office Action in Application No. 10-2011-7019122, dated Jan. 18, 2016 (9 pages).
Korean Office action in Application No. 10-2013-7001038, dated Dec. 11, 2015 (4 pages).
Korean Office Action in Application No. 10-2015-7008131, dated Apr. 1, 2016 (4 pages).
Supplemental European Search Report issued in EP 13 80 2160 on Jul. 6, 2016 (6 pages).
Supplemental European Search Report issued in EP10819444, on Jun. 3, 2015 (4 pages).
Transaction History, U.S. Appl. No. 09/627,252.
Transaction History, U.S. Appl. No. 10/268,509.
Transaction History, U.S. Appl. No. 11/167,902.
Transaction History, U.S. Appl. No. 11/169,014.
Transaction History, U.S. Appl. No. 11/467,724.
Transaction History, U.S. Appl. No. 11/733,579.
Transaction History, U.S. Appl. No. 11/836,349.
Transaction History, U.S. Appl. No. 12/180,141.
Transaction History, U.S. Appl. No. 12/638,588.
Transaction History, U.S. Appl. No. 12/704,998.
Transaction History, U.S. Appl. No. 12/977,545.
Transaction History, U.S. Appl. No. 13/161,010.
Transaction History, U.S. Appl. No. 13/678,928.
WO2014078714A3 (en) 2014-07-17 application
US20110078500A1 (en) 2011-03-31 Processing transactions in graph-based applications
Zheng et al. 2013 FlexIO: I/O middleware for location-flexible scientific data analytics
US20120130680A1 (en) 2012-05-24 System and method for capacity planning for systems with multithreaded multicore multiprocessor resources
Free format text: ASSIGNMENT OF ASSIGNORS INTEREST;ASSIGNORS:BUXBAUM, MARK;MULLIGAN, MICHAEL G.;WAKELING, TIM;AND OTHERS;SIGNING DATES FROM 20121216 TO 20121220;REEL/FRAME:029518/0091
Free format text: ASSIGNMENT OF ASSIGNORS INTEREST;ASSIGNOR:AB INITIO SOFTWARE LLC;REEL/FRAME:029848/0509
Free format text: ASSIGNMENT OF ASSIGNORS INTEREST;ASSIGNOR:AB INITIO ORIGINAL WORKS LLC;REEL/FRAME:029848/0547