org.apache.flink.streaming.api.lineage

接口 SourceLineageVertex

所有超级接口:

LineageVertex

@PublicEvolving
public interface SourceLineageVertex
extends LineageVertex

Lineage vertex for source which has Boundedness to indicate whether the data for the source is bounded.

方法概要

限定符和类型	方法和说明
org.apache.flink.api.connector.source.Boundedness	boundedness() The boundedness for the source connector, users can get boundedness for each sources in the lineage and determine the job execution mode with RuntimeExecutionMode.

从接口继承的方法 org.apache.flink.streaming.api.lineage.LineageVertex

datasets

方法详细资料

boundedness

org.apache.flink.api.connector.source.Boundedness boundedness()

The boundedness for the source connector, users can get boundedness for each sources in the lineage and determine the job execution mode with RuntimeExecutionMode.