Input Adapter Algorithm (Out-of-process)

A description of how the algorithm of a typical out-of-process input adapter operates.

  1. Get the URI of the stream to write to.

  2. Connect to that stream.

  3. Connect to the input data source (this is specific to the application).

  4. Read a row of data from the data source.

  5. Instantiate a "row" (tuple/message) and fill its fields with the values received.

  6. Send the row.

  7. 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.