摘要:
A method is provided for tracing dataflow in a distributed computing application. For example, the method includes incrementally advancing a dataflow in a dataflow path of one or more dataflow paths according to two or more directives encoded in two or more data messages. The method further includes performing the two or more directives. The dataflow path includes one or more operators including at least one merge operator operative to merge the two or more data messages and merge the two or more directives. One or more of the incrementally advancing of the dataflow and the performing of the two or more directives are implemented as instruction code performed on a processor device.
摘要:
A schema diagrammer aids a database administrator or other user in maintaining and managing a database in a computer system. The schema diagrammer allows the user to define “user-defined relationships” between objects in the database. The schema diagrammer generates a graphical schema diagram or map that indicates the objects and their relationships to one another. The relationships that are displayed include both the formal relationships defined programmatically by the database itself and the user-defined relationships.
摘要:
A method and computer program product are provided for implementing translatable text in user modifiable standard query language (SQL) scripts. A set of multiple queries are generated including comments and associated delimited names. The comments and associated delimited names are translated into multiple language versions. A user selected national language is identified. The user selected national language version of the translated comments and associated delimited names are utilized for generating a query. In accordance with features of the invention, the user is given the option to view the query and to make any desired modifications.
摘要:
An embodiment of the invention provides a method of displaying a data flow, wherein a description of a data flow application to be displayed is received. The data flow application includes nodes and edges connecting the nodes, wherein the nodes represent operators and the edges represent data connections for data flowing between the operations. A reason that a user is to view the data flow and/or a user constraint on a complexity of the data flow application to be displayed is determined with a processor; and, the time required to render a display of the data flow application is estimated. A transformed representation of the data flow application is created with the processor. The transformed representation is created based upon the user reason, the user constraint, the estimated time of rendering, and/or a layout strategy. The transformed representation is displayed on a graphical user interface.
摘要:
A data stream processing system is provided that utilizes independent sites to process user-defined inquires over dynamic, continuous streams of data. A mechanism is provided for processing these inquiries over the continuous streams of data by matching new inquiries to previously submitted inquiries. The job plans containing sets of processing elements that were created for both the new inquiry and the previous inquiries are compared for consistency in input and output formatting and commonality of processing elements used. In accordance with the comparison, the new job plan, previous job plans or a combination of the new and previous job plans are used to process the new inquiry. Based on the results of processing the new inquiry, a determination is made regarding which job plans are used for future inquiries.
摘要:
Embodiments of the invention provide a method for reducing instability in a heterogeneous job plan of a stream processing application. In one embodiment, a job manager may be configured to select a job plan with the objective of minimizing the potential instability of the job plan. Each job plan may provide a directed graph connecting processing elements (both native and non-native). That is, each job plan illustrates data flow through the stream application framework. The job plan may be selected from multiple available job plans, or may be generated by replacing processing elements of a given job plan. Further, the job plan may be selected on the basis of other objectives in addition to an objective of minimizing the potential instability of the job plan, such as minimizing cost, minimizing execution time, minimizing resource usage, etc.
摘要:
A data stream processing system is provided that utilizes independent sites to process user-defined inquires over dynamic, continuous streams of data. A mechanism is provided for processing these inquiries over the continuous streams of data by matching new inquiries to previously submitted inquiries. The job plans containing sets of processing elements that were created for both the new inquiry and the previous inquiries are compared for consistency in input and output formatting and commonality of processing elements used. In accordance with the comparison, the new job plan, previous job plans or a combination of the new and previous job plans are used to process the new inquiry. Based on the results of processing the new inquiry, a determination is made regarding which job plans are used for future inquiries.
摘要:
An apparatus and method for generating and displaying a schema diagram of a database includes a schema diagrammer that automatically queries a database to determine its objects and relationships, and generates a graphical representation of the database in the form of a schema diagram that is displayed to the user. The schema diagrammer may optionally include a search filter to potentially constrain which objects and relationships in the database are included in a diagram data file, and a display filter to potentially constrain which objects and relationships stored in the diagram data file are displayed in the schema diagram.