org.apache.flink.streaming.api.lineage

类 DefaultLineageGraph

java.lang.Object

org.apache.flink.streaming.api.lineage.DefaultLineageGraph

所有已实现的接口:

LineageGraph

@Internal
public class DefaultLineageGraph
extends Object
implements LineageGraph

Default implementation for LineageGraph.

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	DefaultLineageGraph.LineageGraphBuilder Build the default lineage graph from LineageEdge.

方法概要

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

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

方法详细资料

sources

public List<SourceLineageVertex> sources()

指定者:

sources 在接口中 LineageGraph

sinks

public List<LineageVertex> sinks()

指定者:

sinks 在接口中 LineageGraph

relations

public List<LineageEdge> relations()

指定者:

relations 在接口中 LineageGraph

builder

public static DefaultLineageGraph.LineageGraphBuilder builder()