Distributing and processing streams over one or more networks for on-the-fly schema evolution
First Claim
1. A computer system comprising:
- a memory;
a processor coupled to the memory;
processor logic coupled to the processor and the memory configured to;
receive a first record comprising one or more first fields from a first source computer;
in response to determining that the first record is of a first type, send the first record to a first node computer that processes records of the first type but is suspended when processing records of a second type;
wherein records of the first type are organized according to a first schema and records of the second type are organized according to a second schema that is different from the first schema;
receive a second record comprising the one or more first fields and one or more second fields from a second source computer;
in response to determining that the second record is of the second type, send the second record to a second node computer that processes records of the second type;
after sending the first record to the first node computer and the second record to the second node computer, determine whether the second type is a first subtype of the first type, without suspending and reconfiguring the first node computer;
in response to determining that the second type is the first subtype of the first type, sending the second record to the first node computer to be processed, without suspending and reconfiguring the first node computer.
1 Assignment
0 Petitions
Accused Products
Abstract
In an embodiment, a method comprises receiving a first record comprising one or more first fields from a first source computer; in response to determining that the first record is a first type and a first node is associated with the first type, sending the first record to the first node to be processed; receiving a second record comprising the one or more first fields and one or more second fields from a second source computer; in response to determining that the second record is a second type and a second node is associated with the second type, sending the second record to the second node; in response to determining that the second type is a first subtype of the first type, sending the second record to the first node to be processed, without suspending the first node.
44 Citations
20 Claims
-
1. A computer system comprising:
-
a memory; a processor coupled to the memory; processor logic coupled to the processor and the memory configured to; receive a first record comprising one or more first fields from a first source computer; in response to determining that the first record is of a first type, send the first record to a first node computer that processes records of the first type but is suspended when processing records of a second type; wherein records of the first type are organized according to a first schema and records of the second type are organized according to a second schema that is different from the first schema; receive a second record comprising the one or more first fields and one or more second fields from a second source computer; in response to determining that the second record is of the second type, send the second record to a second node computer that processes records of the second type; after sending the first record to the first node computer and the second record to the second node computer, determine whether the second type is a first subtype of the first type, without suspending and reconfiguring the first node computer; in response to determining that the second type is the first subtype of the first type, sending the second record to the first node computer to be processed, without suspending and reconfiguring the first node computer. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A method comprising:
-
receiving a first record comprising one or more first fields from a first source computer; in response to determining that the first record is of a first type, sending the first record to a first node computer, which is executed on a first computer, that processes records of the first type but is suspended when processing records of a second type; wherein records of the first type are organized according to a first schema and records of the second type are organized according to a second schema that is different from the first schema; receiving a second record comprising the one or more first fields and one or more second fields from a second source computer; in response to determining that the second record is of the second type, sending the second record to a second node computer, which is executed on a second computer, that processes records of the second type; after sending the first record to the first node computer and the second record to the second node computer, determining whether the second type is a first subtype of the first type, without suspending and reconfiguring the first node computer; in response to determining that the second type is the first subtype of the first type, sending the second record to the first node computer to be processed, without suspending the first node computer; wherein the method is performed by one or more computing devices. - View Dependent Claims (12, 13, 14, 15, 16, 17, 18, 19, 20)
-
Specification