org.apache.flink.streaming.api.lineage

接口 LineageGraph

所有已知实现类:

DefaultLineageGraph

@PublicEvolving
public interface LineageGraph

Job lineage is built according to StreamGraph, users can get sources, sinks and relationships from lineage and manage the relationship between jobs and tables.

方法概要

限定符和类型	方法和说明
List<LineageEdge>	relations()
List<LineageVertex>	sinks()
List<SourceLineageVertex>	sources()

方法详细资料

sources

List<SourceLineageVertex> sources()

sinks

List<LineageVertex> sinks()

relations

List<LineageEdge> relations()