1. A method executed in a facility, the method comprising: providing a data transformation module for a data integration function in a data integration platform, wherein the data integration function provides real time data integration of data between a plurality of data sources and wherein the data transformation module transforms data in the plurality of data sources from a first form to a second form; providing an interface for the data transformation module; identifying, using a processor, the data transformation module as a service in a registry of services; responsive to identifying the data transformation module in the registry of services, using the interface to access the data transformation module as the service in a services oriented architecture; providing a smart client for the service; identifying the smart client as a service in the registry of services; downloading the smart client to a client; sending a request for the service on the interface in accordance with a set of parameters for the smart client; and responsive to a request for the service on the interface, executing the data integration function in real time, wherein the data integration function supports a batch topology, a real time topology, and a combination of the batch topology and the real time topology; pipelining one or more data integration transactions for delivery to the data integration function; and inserting an end-of-wave marker between one or more pipelined data integration transactions to separate processing the pipelined data integration transactions into a set of distinct transactions.