Replication-based propagation mechanism for pipelines
First Claim
1. In a database pipeline having a plurality of stages, each of the plurality of stages having at least one database associated therewith, said database having one or more input pipes and a plurality of output pipes, a method for processing a plurality of database objects in the database via the database pipeline, said method comprising:
- defining a plurality of output pipes for a database, said database having a plurality of database objects stored therein;
specifying a subset of the plurality of database objects in the database for each of the defined plurality of output pipes;
defining a subscription as a function of the specified subset of the plurality of database objects;
propagating, from a first one of the stages to another one of the stages, the specified subset of the plurality of database objects as a function of the defined subscription; and
creating a publication as a function of the propagated subset of the plurality of database objects.
2 Assignments
0 Petitions
Accused Products
Abstract
Processing database objects via a database pipeline having a plurality of stages. The invention provides a replication mechanism for propagating selected data from a database in one stage to a database in another stage without accessing a file system. Each database stage may have a plurality of input and output pipes. The invention enables a user to select a subset of the database objects in each stage for propagation to a subsequent stage.
-
Citations
20 Claims
-
1. In a database pipeline having a plurality of stages, each of the plurality of stages having at least one database associated therewith, said database having one or more input pipes and a plurality of output pipes, a method for processing a plurality of database objects in the database via the database pipeline, said method comprising:
-
defining a plurality of output pipes for a database, said database having a plurality of database objects stored therein;
specifying a subset of the plurality of database objects in the database for each of the defined plurality of output pipes;
defining a subscription as a function of the specified subset of the plurality of database objects;
propagating, from a first one of the stages to another one of the stages, the specified subset of the plurality of database objects as a function of the defined subscription; and
creating a publication as a function of the propagated subset of the plurality of database objects. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
-
-
12. One or more computer-readable media having computer-executable components for processing a plurality of database objects in a database, said components comprising:
-
a configuration module for defining a plurality of output pipes for one database in a stage in a pipeline, said database having a plurality of database objects stored therein;
a selection module for specifying a subset of the plurality of database objects in the database for each of the plurality of output pipes defined by the configuration module; and
a replication module for propagating, from the stage to another stage, the subset of the plurality of database objects specified by the selection module. - View Dependent Claims (13, 14, 15, 16, 17)
-
-
18. A system representing a pipeline, said system comprising:
-
a configuration service for selecting a subset of a plurality of database objects in a database;
a first stage for executing a first data processing service to output the subset of the plurality of database objects selected by the configuration service, wherein the database is associated with said first stage;
a second stage for executing a second data processing service, said second stage having another database associated therewith;
a data host, communicatively coupled to the first and second stages, for storing the selected subset of the plurality of database objects such that the executing of the first data processing service is asynchronous with respect to the executing of the second data processing service; and
a propagation mechanism for replicating the subset of the plurality of database objects stored in the data host to the other database associated with the second stage. - View Dependent Claims (19, 20)
-
Specification