This is an automated email from the ASF dual-hosted git repository.
zjureel pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 24b6f7cbf94 [FLINK-34517][table]fix environment configs ignored when
calling procedure operation (#24397)
add 6b9c282b509 [FLINK-33210] Introduce lineage graph relevant interfaces
(#23626)
No new revisions were added by this update.
Summary of changes:
.../streaming/api/lineage/DatasetConfigFacet.java | 30 ++++++
.../streaming/api/lineage/DatasetSchemaFacet.java | 30 ++++++
.../streaming/api/lineage/DatasetSchemaField.java | 32 +++++++
.../streaming/api/lineage/DefaultLineageGraph.java | 92 ++++++++++++++++++
.../streaming/api/lineage/LineageDataset.java | 37 ++++++++
.../streaming/api/lineage/LineageDatasetFacet.java | 29 ++++++
.../flink/streaming/api/lineage/LineageEdge.java | 30 ++++++
.../flink/streaming/api/lineage/LineageGraph.java | 41 ++++++++
.../flink/streaming/api/lineage/LineageVertex.java | 34 +++++++
.../streaming/api/lineage/SourceLineageVertex.java | 36 +++++++
.../api/lineage/DefaultLineageGraphTest.java | 104 +++++++++++++++++++++
11 files changed, 495 insertions(+)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/DatasetConfigFacet.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/DatasetSchemaFacet.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/DatasetSchemaField.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/DefaultLineageGraph.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/LineageDataset.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/LineageDatasetFacet.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/LineageEdge.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/LineageGraph.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/LineageVertex.java
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/lineage/SourceLineageVertex.java
create mode 100644
flink-streaming-java/src/test/java/org/apache/flink/streaming/api/lineage/DefaultLineageGraphTest.java
