A source worker has at least one data output port, but no input ports. It typically extracts data from an external source, e.g. a database or a file, and sends data rows to its output port(s). It can also generate data rows from scratch, e.g. a random number generator.
- The type parameters describe what ports the transform has, e.g.
*Error*means it has an error output port
Func callback once, which sends rows to the downstream worker.
Execute an SQL query on a database, and pass result set rows to the downstream worker.
- Worker: AdbDataReaderSource<TOutput>
IEnumerable with rows (or rows specified in the constructor), and pass them
to the downstream worker.
- Worker: EnumerableSource<TOutput>
Read delimited (e.g. CSV) or fixed format rows from one or more files, streams, or strings, and output them to the downstream worker. Also see FileHelper Flat Files.
Pass rows from a parent worker input port to a child worker output port. Used when encapsulating dataflow workers inside parent dataflow workers.
- Worker: PortPassThroughSource<TOutput>
Generates an arbitrary number of rows from a set of template rows, via cloning, and pass them to the downstream worker.
- Worker: RepeatRowsSource<TOutput>
Repeatedly execute a
Func callback (that sends rows to the downstream worker) when there is
row demand on the Output port.
- Worker: RowsActionSource<TOutput>
Single row synchronous processing, with automatic checks for output demand, which simplifies the implementation. Must be inherited.
- Worker: RowSourceBase<TOutput>
Automatically checks for output demand, which simplifies the implementation. Supports synchronous and asynchronous code. Must be inherited.
Has an Output port and optional ErrorOutput port, for creating dataflow sources. Must be inherited.
Reads an XLSX spreadsheet file and outputs rows to downstream workers. Does not require any driver installation. Also see EPPlus XLSX Files.
- Worker: XlsxSource<TOutput>