Add ingestion docs to implement a connector

This commit is contained in:
Suresh Srinivas 2021-08-16 15:58:44 -07:00
parent 4d74050884
commit 192672f1a5

View File

@ -19,8 +19,8 @@ It consists of [Source](./source.md) ,[Processor](./processor.md), [Sink](./sink
Workflow execution happens in serial fashion. Workflow execution happens in serial fashion.
1. It runs **source** component first. Source component retrieves a record from external sources and emits the record downstream. 1. It runs **source** component first. **Source** component retrieves a record from external sources and emits the record downstream.
2. if **processor** component is configured it sends the record to processor first 2. if the **processor** component is configured **workflow** sends the record to processor next
3. There can be multiple processors attached to the workflow it passes them in the order they are configurd 3. There can be multiple processors attached to the workflow it passes them in the order they are configurd
4. Once the **processors** finished , it sends the modified to record to Sink. 4. Once the **processors** finished , it sends the modified to record to Sink.
5. The above steps repeats per record emitted from source component 5. The above steps repeats per record emitted from source component