Skip to content

Commit

Permalink
Keep string FQN as a way to add lineage information (#32585)
Browse files Browse the repository at this point in the history
  • Loading branch information
rohitsinha54 authored Sep 30, 2024
1 parent 7da6c89 commit 543d2ce
Showing 1 changed file with 9 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -112,7 +112,7 @@ public static String getFqName(String system, Iterable<String> segments) {
* Add a FQN (fully-qualified name) to Lineage. Segments will be processed via {@link #getFqName}.
*/
public void add(String system, @Nullable String subtype, Iterable<String> segments) {
metric.add(getFqName(system, subtype, segments));
add(getFqName(system, subtype, segments));
}

/**
Expand All @@ -122,6 +122,14 @@ public void add(String system, Iterable<String> segments) {
add(system, null, segments);
}

/**
* Adds the given details as Lineage. For asset level lineage the resource location should be
* specified as Dataplex FQN https://cloud.google.com/data-catalog/docs/fully-qualified-names
*/
public void add(String details) {
metric.add(details);
}

/** Query {@link StringSet} metrics from {@link MetricResults}. */
public static Set<String> query(MetricResults results, Type type) {
MetricsFilter filter =
Expand Down

0 comments on commit 543d2ce

Please sign in to comment.