Package org.apache.beam.sdk.lineage

Interface LineageBase

@Internal public interface LineageBase
Plugin interface for lineage implementations.

This is the core contract that lineage plugins must implement. Custom implementations are selected via the --lineageType pipeline option (see LineageOptions).

Implementations must provide a public constructor accepting (PipelineOptions, Lineage.LineageDirection).

End users should use the Lineage facade class instead of implementing this interface directly.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    add(Iterable<String> rollupSegments)
    Adds the given FQN as lineage.

  • Method Details

    • add

      void add(Iterable<String> rollupSegments)
      Adds the given FQN as lineage.
      Parameters:
      rollupSegments - should be an iterable of strings whose concatenation is a valid Dataplex FQN which is already escaped.

      In particular, this means they will often have trailing delimiters.