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

Class LineageGrpc.LineageStub

  • Enclosing class:
    LineageGrpc
    public static final class LineageGrpc.LineageStub
extends io.grpc.stub.AbstractAsyncStub<LineageGrpc.LineageStub>
    A stub to allow clients to do asynchronous 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 Detail

      • createProcess

        public void createProcess​(CreateProcessRequest request,
                          io.grpc.stub.StreamObserver<Process> responseObserver)
         Creates a new process.

      • updateProcess

        public void updateProcess​(UpdateProcessRequest request,
                          io.grpc.stub.StreamObserver<Process> responseObserver)
         Updates a process.

      • getProcess

        public void getProcess​(GetProcessRequest request,
                       io.grpc.stub.StreamObserver<Process> responseObserver)
         Gets the details of the specified process.

      • listProcesses

        public void listProcesses​(ListProcessesRequest request,
                          io.grpc.stub.StreamObserver<ListProcessesResponse> responseObserver)
         List processes in the given project and location. List order is descending
 by insertion time.

      • deleteProcess

        public void deleteProcess​(DeleteProcessRequest request,
                          io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
         Deletes the process with the specified name.

      • createRun

        public void createRun​(CreateRunRequest request,
                      io.grpc.stub.StreamObserver<Run> responseObserver)
         Creates a new run.

      • updateRun

        public void updateRun​(UpdateRunRequest request,
                      io.grpc.stub.StreamObserver<Run> responseObserver)
         Updates a run.

      • getRun

        public void getRun​(GetRunRequest request,
                   io.grpc.stub.StreamObserver<Run> responseObserver)
         Gets the details of the specified run.

      • listRuns

        public void listRuns​(ListRunsRequest request,
                     io.grpc.stub.StreamObserver<ListRunsResponse> responseObserver)
         Lists runs in the given project and location. List order is descending by
 `start_time`.

      • deleteRun

        public void deleteRun​(DeleteRunRequest request,
                      io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)
         Deletes the run with the specified name.

      • getLineageEvent

        public void getLineageEvent​(GetLineageEventRequest request,
                            io.grpc.stub.StreamObserver<LineageEvent> responseObserver)
         Gets details of a specified lineage event.

      • listLineageEvents

        public void listLineageEvents​(ListLineageEventsRequest request,
                              io.grpc.stub.StreamObserver<ListLineageEventsResponse> responseObserver)
         Lists lineage events in the given project and location. The list order is
 not defined.

      • deleteLineageEvent

        public void deleteLineageEvent​(DeleteLineageEventRequest request,
                               io.grpc.stub.StreamObserver<com.google.protobuf.Empty> responseObserver)
         Deletes the lineage event with the specified name.

      • searchLinks

        public void searchLinks​(SearchLinksRequest request,
                        io.grpc.stub.StreamObserver<SearchLinksResponse> responseObserver)
         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 void batchSearchLinkProcesses​(BatchSearchLinkProcessesRequest request,
                                     io.grpc.stub.StreamObserver<BatchSearchLinkProcessesResponse> responseObserver)
         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.