Interface TableSinkLineageVertex
-
- All Superinterfaces:
LineageVertex
- All Known Implementing Classes:
TableSinkLineageVertexImpl
@PublicEvolving public interface TableSinkLineageVertex extends LineageVertex
Sink lineage vertex for table.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ModifyType
modifyType()
Modify type, INSERT/UPDATE/DELETE statement, listener can identify different sink by the type to determine whether the sink should be added to the lineage.-
Methods inherited from interface org.apache.flink.streaming.api.lineage.LineageVertex
datasets
-
-
-
-
Method Detail
-
modifyType
ModifyType modifyType()
Modify type, INSERT/UPDATE/DELETE statement, listener can identify different sink by the type to determine whether the sink should be added to the lineage.
-
-