Component model for batch computing in a distributed object environment
First Claim
1. A method of batch processing in a distributed object environment, the method comprising:
- providing a batch component for a batch job within the distributed object environment;
initializing the batch component with a set of deployment descriptors; and
managing operation of the batch component within the distributed object environment in accordance with the set of deployment descriptors.
1 Assignment
0 Petitions
Accused Products
Abstract
A batch component model is provided within a distributed object environment. The batch component is designed to capture the iterative logic of a batch program as it reads from one or more input streams, invokes operations on other business component functions, and generates output to one or more output streams. Deployment descriptors express declarative policies for the component that will influence how the component is managed including the streams it uses, business components it depends on, how processing costs are accounted for, the resource demands the job will put on the system, and the like. Input streams and output streams are encapsulated in objects that hide the actual source of input and output data so that the component can be redeployed in different execution environments to different physical data sources without requiring the program to be changed. A batch container enforces the deployment policies declared for the batch component.
-
Citations
62 Claims
-
1. A method of batch processing in a distributed object environment, the method comprising:
-
providing a batch component for a batch job within the distributed object environment;
initializing the batch component with a set of deployment descriptors; and
managing operation of the batch component within the distributed object environment in accordance with the set of deployment descriptors. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
-
-
12. A method of checkpointing a batch job in a distributed object environment, the method comprising:
-
determining a checkpoint interval duration of a checkpoint interval for a batch component;
running the batch component within the checkpoint interval; and
upon completion of the checkpoint interval duration, storing at least one checkpoint cursor. - View Dependent Claims (13, 14, 15, 16, 17, 18, 19, 20, 21)
-
-
22. A method of partitioning a batch job, the method comprising:
-
dividing an input stream into a plurality of partitions of the input stream; and
running a plurality of instances of a batch component, wherein each instance of the batch component within the plurality of instances of the batch component operates on a respective partition of the input stream. - View Dependent Claims (23, 24, 25)
-
-
26. An apparatus for batch processing in a distributed object environment, the apparatus comprising:
-
means for providing a batch component for a batch job within the distributed object environment;
means for initializing the batch component with a set of deployment descriptors; and
means for managing operation of the batch component within the distributed object environment in accordance with the set of deployment descriptors. - View Dependent Claims (27, 28, 29, 30, 31, 32, 33, 34, 35, 36)
-
-
37. An apparatus for checkpointing a batch job in a distributed object environment, the apparatus comprising:
-
means for determining a checkpoint interval duration of a checkpoint interval for a batch component;
means for running the batch component within the checkpoint interval; and
means for storing at least one checkpoint cursor upon completion of the checkpoint interval duration. - View Dependent Claims (38, 39, 40, 41, 42, 43, 44, 45, 46)
-
-
47. An apparatus for partitioning a batch job, the apparatus comprising:
-
means for dividing an input stream into a plurality of partitions of the input stream; and
means for running a plurality of instances of a batch component, wherein each instance of the batch component within the plurality of instances of the batch component operates on a respective partition of the input stream. - View Dependent Claims (48, 49, 50)
-
-
51. A distributed object environment, comprising:
-
a batch component; and
a batch container, wherein the batch container receives a set of deployment descriptors for the batch component and manages the batch component in accordance with the set of deployment descriptors. - View Dependent Claims (52, 53, 54, 55, 56, 57, 58, 59)
-
-
60. A computer program product, in a computer program product, for batch processing in a distributed object environment, the computer program product comprising:
-
instructions for providing a batch component for a batch job within the distributed object environment;
instructions for initializing the batch component with a set of deployment descriptors; and
instructions for managing operation of the batch component within the distributed object environment in accordance with the set of deployment descriptors.
-
-
61. A computer program product, in a computer readable medium, for checkpointing a batch job in a distributed object environment, the computer program product comprising:
-
instructions for determining a checkpoint interval duration of a checkpoint interval for a batch component;
instructions for running the batch component within the checkpoint interval; and
instructions for upon completion of the checkpoint interval duration, storing at least one checkpoint cursor.
-
-
62. A computer program product, in a computer readable medium, for partitioning a batch job, the computer program product comprising:
-
instructions for dividing an input stream into a plurality of partitions of the input stream; and
instructions for running a plurality of instances of a batch component, wherein each instance of the batch component within the plurality of instances of the batch component operates on a respective partition of the input stream.
-
Specification