| 主权项 |
1. A mediation system for processing event records that are configured to have a mutual relation, the system comprising:
at least two independent node components, each of the independent node components having settings according to which the node component operates independently of other components of the system, the at least two independent node components being configured to handle event records in series such that a first independent node component outputs event record data into a buffer and a second independent node component reads the event record data from the buffer, the event records comprising a first record, at least one intermediate record, and a last record; at least one host, the at least one host including a processor and a memory and being configured to execute the at least two independent node components for processing the event records; an in-memory database configured to store data on the event records and configured to store said mutual relation, wherein at least one of the at least two independent node components comprises a subsystem including:
a database interface layer comprising a module providing an interface to the in-memory database,a basic functionality layer comprising at least one module configured to perform basic functions on the data in the in-memory database via the module at the database interface layer, anda mediation functionality layer comprising at least two modules each configured to perform at least one mediation function on the data in the in-memory database selectively either via the modules at both the database interface layer and the basic functionality layer or directly via the modules at the database interface layer; andthe mediation system further comprising processing logic structured to operate the subsystem to receive the first record and the last record and to select a process for processing the first record and the last record, the selected process configured to:
extract information from the first record, select a module at the database interface layer, basic functionality layer, or mediation functionality layer, for processing the information extracted from the first record, send the information extracted from the first record to the selected module for performing a function on the information extracted from the first record and for storing into the in-memory database, extract information from the last record, retrieve from the in-memory database information relating to the first record and any intermediate records, create a new record based on the function and the retrieved information relating to the first record and any intermediate records, and return the new record to the processing logic. |
