Thanks for the valuable feedback, Leonard.

I have discussed with Leonard off-line. We have reached some conclusions
about these issues and I have updated the FLIP as follows:

1. Simplify the `LineageEdge` interface by creating an edge from one source
vertex to sink vertex.
2. Remove the `TableColumnSourceLineageVertex` interface and update
`TableColumnLineageEdge` to create an edge from columns in one source to
each sink column.
3. Rename `SupportsLineageVertex` to `LineageVertexProvider`
4. Add method `addLineageEdges(LineageEdge ... edges)` in
`StreamExecutionEnviroment` for datastream job and remove previous methods
in `DataStreamSource` and `DataStreamSink`.

Looking forward to your feedback, thanks.

Best,
Shammon FY

Reply via email to