A description of how the algorithm of a typical out-of-process input adapter operates.
Get the URI of the stream to write to.
Connect to that stream.
Connect to the input data source (this is specific to the application).
Read a row of data from the data source.
Instantiate a "row" (tuple/message) and fill its fields with the values received.
Send the row.
Disconnect.
Steps 4-6 are typically done in a loop that is executed once for each incoming row of data.
Note that if the project (query module) is not running, then the stream won't exist, and the out-of-process adapter won't be able to connect to it.