Package io.github.flink.gcp.connector.base.lineage

Class PhysicalResourceFacet

java.lang.Object
io.github.flink.gcp.connector.base.lineage.PhysicalResourceFacet
All Implemented Interfaces:
Serializable, org.apache.flink.streaming.api.lineage.LineageDatasetFacet
@PublicEvolving public final class PhysicalResourceFacet extends Object implements org.apache.flink.streaming.api.lineage.LineageDatasetFacet, Serializable
Immutable physical resource metadata under the gcp dataset facet key.

A DataStream dataset contains its own resource. A Table dataset contains every configured physical resource of that logical table, even when Flink replaces the dataset name with a catalog identifier. An empty resource list declares no physical resource.

A listener must explicitly consume this facet; its presence does not imply that an unmodified OpenLineage listener understands it. This class and ResourceIdentifier retain their package names in SQL connector jars, and must share a class loader with the listener's copies when accessed through this API.

See Also:

  • Constructor Details

    • PhysicalResourceFacet

      @Internal public PhysicalResourceFacet(List<ResourceIdentifier> resources)
      Constructs a snapshot for connector-internal metadata assembly.

      This public internal constructor also serves relocated helpers. It copies the list, eliminates equal identifiers, and orders by namespace, name, kind, then identity entries.

      Parameters:
      resources - the configured resources; the list and its entries must be non-null

  • Method Details

    • name

      public String name()
      Specified by:
      name in interface org.apache.flink.streaming.api.lineage.LineageDatasetFacet

    • resources

      public List<ResourceIdentifier> resources()
      Returns the immutable, deterministically ordered resource snapshot with equal identifiers removed. A listener can read the canonical physical names here after SQL planning.