Package com.google.cloud.datacatalog.lineage.v1

Class LineageGrpc.LineageFutureStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractFutureStub<LineageGrpc.LineageFutureStub>
com.google.cloud.datacatalog.lineage.v1.LineageGrpc.LineageFutureStub
Enclosing class:
LineageGrpc
public static final class LineageGrpc.LineageFutureStub extends io.grpc.stub.AbstractFutureStub<LineageGrpc.LineageFutureStub>
A stub to allow clients to do ListenableFuture-style rpc calls to service Lineage. 
 Lineage is used to track data flows between assets over time. You can
 create [LineageEvents][google.cloud.datacatalog.lineage.v1.LineageEvent]
 to record lineage between multiple sources and a single target, for
 example, when table data is based on data from multiple tables.

  • Method Details

    • build

      protected LineageGrpc.LineageFutureStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<LineageGrpc.LineageFutureStub>

    • processOpenLineageRunEvent

      public com.google.common.util.concurrent.ListenableFuture<ProcessOpenLineageRunEventResponse> processOpenLineageRunEvent(ProcessOpenLineageRunEventRequest request)
       Creates new lineage events together with their parents: process and run.
 Updates the process and run if they already exist.
 Mapped from Open Lineage specification:
 https://github.com/OpenLineage/OpenLineage/blob/main/spec/OpenLineage.json.

    • createProcess

      public com.google.common.util.concurrent.ListenableFuture<Process> createProcess(CreateProcessRequest request)
       Creates a new process.

    • updateProcess

      public com.google.common.util.concurrent.ListenableFuture<Process> updateProcess(UpdateProcessRequest request)
       Updates a process.

    • getProcess

      public com.google.common.util.concurrent.ListenableFuture<Process> getProcess(GetProcessRequest request)
       Gets the details of the specified process.

    • listProcesses

      public com.google.common.util.concurrent.ListenableFuture<ListProcessesResponse> listProcesses(ListProcessesRequest request)
       List processes in the given project and location. List order is descending
 by insertion time.

    • deleteProcess

      public com.google.common.util.concurrent.ListenableFuture<Operation> deleteProcess(DeleteProcessRequest request)
       Deletes the process with the specified name.

    • createRun

      public com.google.common.util.concurrent.ListenableFuture<Run> createRun(CreateRunRequest request)
       Creates a new run.

    • updateRun

      public com.google.common.util.concurrent.ListenableFuture<Run> updateRun(UpdateRunRequest request)
       Updates a run.

    • getRun

      public com.google.common.util.concurrent.ListenableFuture<Run> getRun(GetRunRequest request)
       Gets the details of the specified run.

    • listRuns

      public com.google.common.util.concurrent.ListenableFuture<ListRunsResponse> listRuns(ListRunsRequest request)
       Lists runs in the given project and location. List order is descending by
 `start_time`.

    • deleteRun

      public com.google.common.util.concurrent.ListenableFuture<Operation> deleteRun(DeleteRunRequest request)
       Deletes the run with the specified name.

    • createLineageEvent

      public com.google.common.util.concurrent.ListenableFuture<LineageEvent> createLineageEvent(CreateLineageEventRequest request)
       Creates a new lineage event.

    • getLineageEvent

      public com.google.common.util.concurrent.ListenableFuture<LineageEvent> getLineageEvent(GetLineageEventRequest request)
       Gets details of a specified lineage event.

    • listLineageEvents

      public com.google.common.util.concurrent.ListenableFuture<ListLineageEventsResponse> listLineageEvents(ListLineageEventsRequest request)
       Lists lineage events in the given project and location. The list order is
 not defined.

    • deleteLineageEvent

      public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.Empty> deleteLineageEvent(DeleteLineageEventRequest request)
       Deletes the lineage event with the specified name.

    • searchLinks

      public com.google.common.util.concurrent.ListenableFuture<SearchLinksResponse> searchLinks(SearchLinksRequest request)
       Retrieve a list of links connected to a specific asset.
 Links represent the data flow between **source** (upstream)
 and **target** (downstream) assets in transformation pipelines.
 Links are stored in the same project as the Lineage Events that create
 them.
 You can retrieve links in every project where you have the
 `datalineage.events.get` permission. The project provided in the URL
 is used for Billing and Quota.

    • batchSearchLinkProcesses

      public com.google.common.util.concurrent.ListenableFuture<BatchSearchLinkProcessesResponse> batchSearchLinkProcesses(BatchSearchLinkProcessesRequest request)
       Retrieve information about LineageProcesses associated with specific
 links. LineageProcesses are transformation pipelines that result in data
 flowing from **source** to **target** assets. Links between assets
 represent this operation.
 If you have specific link names, you can use this method to
 verify which LineageProcesses contribute to creating those links.
 See the
 [SearchLinks][google.cloud.datacatalog.lineage.v1.Lineage.SearchLinks]
 method for more information on how to retrieve link name.
 You can retrieve the LineageProcess information in every project where you
 have the `datalineage.events.get` permission. The project provided in the
 URL is used for Billing and Quota.