SYSTEM AND METHOD FOR DYNAMIC TRANSACTIONAL DATA STREAMING

• US 20150199482A1
• Filed: 08/22/2014
• Published: 07/16/2015
• Est. Priority Date: 01/14/2014
• Status: Active Grant

• Current Assignee: Change Healthcare Holdings, LLC (UnitedHealth Group Incorporated)
• Original Assignee: PokitDok, Inc. (UnitedHealth Group Incorporated)
• Inventors: CORBIN, Brian Scott, WHITMIRE, Thomas Dixon IV, TANNER, Theodore Calhoun Jr.
• Granted Patent: US 11,126,627 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06Q 10/10 Office automation; Time management
• CPC Class Codes: G16H 40/67 for remote operation

Abstract

A system and method for dynamic transactional data streaming are provided.

Claims

1. A dynamic transactional data streaming system, comprising:

a data streaming system;

the data streaming system having a storage device that stores a plurality of rule sets, wherein each rule set processes a transactional datastream having a particular set of transactional data;

the data streaming system having a data stream examination component configured to receive a transactional datastream having a plurality of segments wherein each segment has a plurality of data elements, the data stream examination component also configured to identify each of the segments in the transactional datastream; and

the data streaming system having a data stream segment processing component configured to receive each segment of the transactional datastream identified by the data stream examination component, configured to select a rule set from the plurality of rule sets based on the data elements in each segment of the transactional datastream and configured to generate a set of translated data based on the selected rule set and the plurality of segments and the plurality of data elements of the transactional datastream.

2. The system of claim 1, wherein the data stream segment processing component is configured to parse each data element in each segment based on a parse expression to generate a parsed data element and configured to apply the selected rule set to the parsed data element.

3. The system of claim 2, wherein the set of translated data is stored in a graph.

4. The system of claim 1, wherein the data stream examination component that is configured to identify each of the segments in the transactional datastream is further configured to identify an element delimiter that separates each data element and a segment terminator that separates each segment in the transactional datastream.

5. The system of claim 1 further comprising a data stream output component configured to load a stream generation rule based on the set of translated data and configured to generate an output datastream using the stream generation rule and the set of translated data.

6. The system of claim 5, wherein the data stream output component loads the stream generation rules based on a set of translated data stored in graph.

7. The system of claim 1, wherein the transactional datastream is a healthcare transactional datastream.

8. The system of claim 7, wherein the healthcare transactional datastream uses an ASC X12 5010 standard delimited format.

9. The system of claim 1, wherein the data stream system further comprises a data processing component having a plurality of processing channels wherein each processing channel processes a segment of the transactional data so that the data segments of the transactional datastream are processed in parallel.

10. The system of claim 9, wherein each processing channel has a message queue so that each processing channel communicates with the other processing channels.

11. The system of claim 9, wherein each processing channel is a thread executed by a processor.

12. The system of claim 9, wherein each processing channel has a rule set processor that performs the operations of the data stream segment processing component for each segment assigned to the processing channel.

13. A dynamic transactional data streaming method, comprising:

storing, in a storage device, a plurality of rule sets, wherein each rule set processes a transactional datastream having a particular set of transactional data;

receiving, by a computer system coupled to the storage device, a transactional datastream having a plurality of segments wherein each segment has a plurality of data elements;

identifying, by the computer system, each of the segments in the transactional datastream;

selecting, by the computer system, a rule set from the plurality of rule sets based on the data elements in each segment of the transactional datastream; and

generating, by the computer system, a set of translated data based on the selected rule set and the plurality of segments and the plurality of data elements of the transactional datastream.

14. The method of claim 13 further comprising parsing, by the computer system, each data element in each segment based on a parse expression to generate a parsed data element and applying, by the computer system, the selected rule set to the parsed data element.

15. The method of claim 14 further comprising storing the set of translated data in a graph.

16. The method of claim 13, wherein identifying each segment further comprises identifying, by the computer system, an element delimiter that separates each data element and a segment terminator that separates each segment in the transactional datastream.

17. The method of claim 13 further comprising loading, by the computer system, a stream generation rule based on the set of translated data and generating, by the computer system, an output datastream using the stream generation rule and the set of translated data.

18. The method of claim 17, wherein loading the stream generation rules further comprising loading, by the computer system, the stream generation rule based on a set of translated data stored in graph.

19. The method of claim 13, wherein the transactional datastream is a healthcare transactional datastream.

20. The method of claim 19, wherein the healthcare transactional datastream uses an ASC X12 5010 standard delimited format.