Class LineageClient (0.8.0)

public class LineageClient implements BackgroundResource

Service Description: Lineage is used to track data flows between assets over time. You can create LineageEvents to record lineage between multiple sources and a single target, for example, when table data is based on data from multiple tables.

This class provides the ability to make remote calls to the backing service through method calls that map to API methods. Sample code to get started:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   Process process = Process.newBuilder().build();
   Process response = lineageClient.createProcess(parent, process);
 }

Note: close() needs to be called on the LineageClient object to clean up resources such as threads. In the example above, try-with-resources is used, which automatically calls close().

The surface of this class includes several types of Java methods for each of the API's methods:

A "flattened" method. With this type of method, the fields of the request type have been converted into function parameters. It may be the case that not all fields are available as parameters, and not every API method will have a flattened method entry point.
A "request object" method. This type of method only takes one parameter, a request object, which must be constructed before the call. Not every API method will have a request object method.
A "callable" method. This type of method takes no parameters and returns an immutable API callable object, which can be used to initiate calls to the service.

See the individual methods for example code.

Many parameters require resource names to be formatted in a particular way. To assist with these names, this class includes a format method for each type of name, and additionally a parse method to extract the individual identifiers contained within names that are returned.

This class can be customized by passing in a custom instance of LineageSettings to create(). For example:

To customize credentials:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 LineageSettings lineageSettings =
     LineageSettings.newBuilder()
         .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
         .build();
 LineageClient lineageClient = LineageClient.create(lineageSettings);

To customize the endpoint:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 LineageSettings lineageSettings = LineageSettings.newBuilder().setEndpoint(myEndpoint).build();
 LineageClient lineageClient = LineageClient.create(lineageSettings);

To use REST (HTTP1.1/JSON) transport (instead of gRPC) for sending and receiving requests over the wire:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 LineageSettings lineageSettings = LineageSettings.newHttpJsonBuilder().build();
 LineageClient lineageClient = LineageClient.create(lineageSettings);

Please refer to the GitHub repository's samples for more quickstart code snippets.

Inheritance

java.lang.Object > LineageClient

Implements

BackgroundResource

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Static Methods

create()

public static final LineageClient create()

Constructs an instance of LineageClient with default settings.

Returns
Type	Description
`LineageClient`

Exceptions
Type	Description
`IOException`

create(LineageSettings settings)

public static final LineageClient create(LineageSettings settings)

Constructs an instance of LineageClient, using the given settings. The channels are created based on the settings passed in, or defaults for any settings that are not set.

Parameter
Name	Description
`settings`	`LineageSettings`

Returns
Type	Description
`LineageClient`

Exceptions
Type	Description
`IOException`

create(LineageStub stub)

public static final LineageClient create(LineageStub stub)

Constructs an instance of LineageClient, using the given stub for making calls. This is for advanced usage - prefer using create(LineageSettings).

Parameter
Name	Description
`stub`	`LineageStub`

Returns
Type	Description
`LineageClient`

Constructors

LineageClient(LineageSettings settings)

protected LineageClient(LineageSettings settings)

Constructs an instance of LineageClient, using the given settings. This is protected so that it is easy to make a subclass, but otherwise, the static factory methods should be preferred.

Parameter
Name	Description
`settings`	`LineageSettings`

LineageClient(LineageStub stub)

protected LineageClient(LineageStub stub)

Parameter
Name	Description
`stub`	`LineageStub`

Methods

awaitTermination(long duration, TimeUnit unit)

public boolean awaitTermination(long duration, TimeUnit unit)

Parameters
Name	Description
`duration`	`long`
`unit`	`TimeUnit`

Returns
Type	Description
`boolean`

Exceptions
Type	Description
`InterruptedException`

batchSearchLinkProcesses(BatchSearchLinkProcessesRequest request)

public final LineageClient.BatchSearchLinkProcessesPagedResponse 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 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.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   BatchSearchLinkProcessesRequest request =
       BatchSearchLinkProcessesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .addAllLinks(new ArrayList<String>())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   for (ProcessLinks element : lineageClient.batchSearchLinkProcesses(request).iterateAll()) {
     // doThingsWith(element);
   }
 }

Parameter
Name	Description
`request`	`BatchSearchLinkProcessesRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`LineageClient.BatchSearchLinkProcessesPagedResponse`

batchSearchLinkProcessesCallable()

public final UnaryCallable<BatchSearchLinkProcessesRequest,BatchSearchLinkProcessesResponse> batchSearchLinkProcessesCallable()

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.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   BatchSearchLinkProcessesRequest request =
       BatchSearchLinkProcessesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .addAllLinks(new ArrayList<String>())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   while (true) {
     BatchSearchLinkProcessesResponse response =
         lineageClient.batchSearchLinkProcessesCallable().call(request);
     for (ProcessLinks element : response.getProcessLinksList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }

Returns
Type	Description
`UnaryCallable<BatchSearchLinkProcessesRequest,BatchSearchLinkProcessesResponse>`

batchSearchLinkProcessesPagedCallable()

public final UnaryCallable<BatchSearchLinkProcessesRequest,LineageClient.BatchSearchLinkProcessesPagedResponse> batchSearchLinkProcessesPagedCallable()

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.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   BatchSearchLinkProcessesRequest request =
       BatchSearchLinkProcessesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .addAllLinks(new ArrayList<String>())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   ApiFuture<ProcessLinks> future =
       lineageClient.batchSearchLinkProcessesPagedCallable().futureCall(request);
   // Do something.
   for (ProcessLinks element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }

Returns
Type	Description
`UnaryCallable<BatchSearchLinkProcessesRequest,BatchSearchLinkProcessesPagedResponse>`

close()

public final void close()

createLineageEvent(CreateLineageEventRequest request)

public final LineageEvent createLineageEvent(CreateLineageEventRequest request)

Creates a new lineage event.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   CreateLineageEventRequest request =
       CreateLineageEventRequest.newBuilder()
           .setParent(RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]").toString())
           .setLineageEvent(LineageEvent.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   LineageEvent response = lineageClient.createLineageEvent(request);
 }

Parameter
Name	Description
`request`	`CreateLineageEventRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`LineageEvent`

createLineageEvent(RunName parent, LineageEvent lineageEvent)

public final LineageEvent createLineageEvent(RunName parent, LineageEvent lineageEvent)

Creates a new lineage event.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   RunName parent = RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
   LineageEvent lineageEvent = LineageEvent.newBuilder().build();
   LineageEvent response = lineageClient.createLineageEvent(parent, lineageEvent);
 }

Parameters
Name	Description
`parent`	`RunName` Required. The name of the run that should own the lineage event.
`lineageEvent`	`LineageEvent` Required. The lineage event to create.

Returns
Type	Description
`LineageEvent`

createLineageEvent(String parent, LineageEvent lineageEvent)

public final LineageEvent createLineageEvent(String parent, LineageEvent lineageEvent)

Creates a new lineage event.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   String parent = RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]").toString();
   LineageEvent lineageEvent = LineageEvent.newBuilder().build();
   LineageEvent response = lineageClient.createLineageEvent(parent, lineageEvent);
 }

Parameters
Name	Description
`parent`	`String` Required. The name of the run that should own the lineage event.
`lineageEvent`	`LineageEvent` Required. The lineage event to create.

Returns
Type	Description
`LineageEvent`

createLineageEventCallable()

public final UnaryCallable<CreateLineageEventRequest,LineageEvent> createLineageEventCallable()

Creates a new lineage event.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   CreateLineageEventRequest request =
       CreateLineageEventRequest.newBuilder()
           .setParent(RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]").toString())
           .setLineageEvent(LineageEvent.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<LineageEvent> future =
       lineageClient.createLineageEventCallable().futureCall(request);
   // Do something.
   LineageEvent response = future.get();
 }

Returns
Type	Description
`UnaryCallable<CreateLineageEventRequest,LineageEvent>`

createProcess(CreateProcessRequest request)

public final Process createProcess(CreateProcessRequest request)

Creates a new process.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   CreateProcessRequest request =
       CreateProcessRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setProcess(Process.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   Process response = lineageClient.createProcess(request);
 }

Parameter
Name	Description
`request`	`CreateProcessRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`Process`

createProcess(LocationName parent, Process process)

public final Process createProcess(LocationName parent, Process process)

Creates a new process.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   Process process = Process.newBuilder().build();
   Process response = lineageClient.createProcess(parent, process);
 }

Parameters
Name	Description
`parent`	`LocationName` Required. The name of the project and its location that should own the process.
`process`	`Process` Required. The process to create.

Returns
Type	Description
`Process`

createProcess(String parent, Process process)

public final Process createProcess(String parent, Process process)

Creates a new process.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   Process process = Process.newBuilder().build();
   Process response = lineageClient.createProcess(parent, process);
 }

Parameters
Name	Description
`parent`	`String` Required. The name of the project and its location that should own the process.
`process`	`Process` Required. The process to create.

Returns
Type	Description
`Process`

createProcessCallable()

public final UnaryCallable<CreateProcessRequest,Process> createProcessCallable()

Creates a new process.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   CreateProcessRequest request =
       CreateProcessRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setProcess(Process.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Process> future = lineageClient.createProcessCallable().futureCall(request);
   // Do something.
   Process response = future.get();
 }

Returns
Type	Description
`UnaryCallable<CreateProcessRequest,Process>`

createRun(CreateRunRequest request)

public final Run createRun(CreateRunRequest request)

Creates a new run.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   CreateRunRequest request =
       CreateRunRequest.newBuilder()
           .setParent(ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]").toString())
           .setRun(Run.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   Run response = lineageClient.createRun(request);
 }

Parameter
Name	Description
`request`	`CreateRunRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`Run`

createRun(ProcessName parent, Run run)

public final Run createRun(ProcessName parent, Run run)

Creates a new run.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   ProcessName parent = ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]");
   Run run = Run.newBuilder().build();
   Run response = lineageClient.createRun(parent, run);
 }

Parameters
Name	Description
`parent`	`ProcessName` Required. The name of the process that should own the run.
`run`	`Run` Required. The run to create.

Returns
Type	Description
`Run`

createRun(String parent, Run run)

public final Run createRun(String parent, Run run)

Creates a new run.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   String parent = ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]").toString();
   Run run = Run.newBuilder().build();
   Run response = lineageClient.createRun(parent, run);
 }

Parameters
Name	Description
`parent`	`String` Required. The name of the process that should own the run.
`run`	`Run` Required. The run to create.

Returns
Type	Description
`Run`

createRunCallable()

public final UnaryCallable<CreateRunRequest,Run> createRunCallable()

Creates a new run.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   CreateRunRequest request =
       CreateRunRequest.newBuilder()
           .setParent(ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]").toString())
           .setRun(Run.newBuilder().build())
           .setRequestId("requestId693933066")
           .build();
   ApiFuture<Run> future = lineageClient.createRunCallable().futureCall(request);
   // Do something.
   Run response = future.get();
 }

Returns
Type	Description
`UnaryCallable<CreateRunRequest,Run>`

deleteLineageEvent(DeleteLineageEventRequest request)

public final void deleteLineageEvent(DeleteLineageEventRequest request)

Deletes the lineage event with the specified name.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   DeleteLineageEventRequest request =
       DeleteLineageEventRequest.newBuilder()
           .setName(
               LineageEventName.of(
                       "[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]")
                   .toString())
           .setAllowMissing(true)
           .build();
   lineageClient.deleteLineageEvent(request);
 }

Parameter
Name	Description
`request`	`DeleteLineageEventRequest` The request object containing all of the parameters for the API call.

deleteLineageEvent(LineageEventName name)

public final void deleteLineageEvent(LineageEventName name)

Deletes the lineage event with the specified name.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   LineageEventName name =
       LineageEventName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]");
   lineageClient.deleteLineageEvent(name);
 }

Parameter
Name	Description
`name`	`LineageEventName` Required. The name of the lineage event to delete.

deleteLineageEvent(String name)

public final void deleteLineageEvent(String name)

Deletes the lineage event with the specified name.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   String name =
       LineageEventName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]")
           .toString();
   lineageClient.deleteLineageEvent(name);
 }

Parameter
Name	Description
`name`	`String` Required. The name of the lineage event to delete.

deleteLineageEventCallable()

public final UnaryCallable<DeleteLineageEventRequest,Empty> deleteLineageEventCallable()

Deletes the lineage event with the specified name.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   DeleteLineageEventRequest request =
       DeleteLineageEventRequest.newBuilder()
           .setName(
               LineageEventName.of(
                       "[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]")
                   .toString())
           .setAllowMissing(true)
           .build();
   ApiFuture<Empty> future = lineageClient.deleteLineageEventCallable().futureCall(request);
   // Do something.
   future.get();
 }

Returns
Type	Description
`UnaryCallable<DeleteLineageEventRequest,Empty>`

deleteProcessAsync(DeleteProcessRequest request)

public final OperationFuture<Empty,OperationMetadata> deleteProcessAsync(DeleteProcessRequest request)

Deletes the process with the specified name.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   DeleteProcessRequest request =
       DeleteProcessRequest.newBuilder()
           .setName(ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]").toString())
           .setAllowMissing(true)
           .build();
   lineageClient.deleteProcessAsync(request).get();
 }

Parameter
Name	Description
`request`	`DeleteProcessRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`OperationFuture<Empty,OperationMetadata>`

deleteProcessAsync(ProcessName name)

public final OperationFuture<Empty,OperationMetadata> deleteProcessAsync(ProcessName name)

Deletes the process with the specified name.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   ProcessName name = ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]");
   lineageClient.deleteProcessAsync(name).get();
 }

Parameter
Name	Description
`name`	`ProcessName` Required. The name of the process to delete.

Returns
Type	Description
`OperationFuture<Empty,OperationMetadata>`

deleteProcessAsync(String name)

public final OperationFuture<Empty,OperationMetadata> deleteProcessAsync(String name)

Deletes the process with the specified name.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   String name = ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]").toString();
   lineageClient.deleteProcessAsync(name).get();
 }

Parameter
Name	Description
`name`	`String` Required. The name of the process to delete.

Returns
Type	Description
`OperationFuture<Empty,OperationMetadata>`

deleteProcessCallable()

public final UnaryCallable<DeleteProcessRequest,Operation> deleteProcessCallable()

Deletes the process with the specified name.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   DeleteProcessRequest request =
       DeleteProcessRequest.newBuilder()
           .setName(ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]").toString())
           .setAllowMissing(true)
           .build();
   ApiFuture<Operation> future = lineageClient.deleteProcessCallable().futureCall(request);
   // Do something.
   future.get();
 }

Returns
Type	Description
`UnaryCallable<DeleteProcessRequest,Operation>`

deleteProcessOperationCallable()

public final OperationCallable<DeleteProcessRequest,Empty,OperationMetadata> deleteProcessOperationCallable()

Deletes the process with the specified name.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   DeleteProcessRequest request =
       DeleteProcessRequest.newBuilder()
           .setName(ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]").toString())
           .setAllowMissing(true)
           .build();
   OperationFuture<Empty, OperationMetadata> future =
       lineageClient.deleteProcessOperationCallable().futureCall(request);
   // Do something.
   future.get();
 }

Returns
Type	Description
`OperationCallable<DeleteProcessRequest,Empty,OperationMetadata>`

deleteRunAsync(DeleteRunRequest request)

public final OperationFuture<Empty,OperationMetadata> deleteRunAsync(DeleteRunRequest request)

Deletes the run with the specified name.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   DeleteRunRequest request =
       DeleteRunRequest.newBuilder()
           .setName(RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]").toString())
           .setAllowMissing(true)
           .build();
   lineageClient.deleteRunAsync(request).get();
 }

Parameter
Name	Description
`request`	`DeleteRunRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`OperationFuture<Empty,OperationMetadata>`

deleteRunAsync(RunName name)

public final OperationFuture<Empty,OperationMetadata> deleteRunAsync(RunName name)

Deletes the run with the specified name.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   RunName name = RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
   lineageClient.deleteRunAsync(name).get();
 }

Parameter
Name	Description
`name`	`RunName` Required. The name of the run to delete.

Returns
Type	Description
`OperationFuture<Empty,OperationMetadata>`

deleteRunAsync(String name)

public final OperationFuture<Empty,OperationMetadata> deleteRunAsync(String name)

Deletes the run with the specified name.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   String name = RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]").toString();
   lineageClient.deleteRunAsync(name).get();
 }

Parameter
Name	Description
`name`	`String` Required. The name of the run to delete.

Returns
Type	Description
`OperationFuture<Empty,OperationMetadata>`

deleteRunCallable()

public final UnaryCallable<DeleteRunRequest,Operation> deleteRunCallable()

Deletes the run with the specified name.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   DeleteRunRequest request =
       DeleteRunRequest.newBuilder()
           .setName(RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]").toString())
           .setAllowMissing(true)
           .build();
   ApiFuture<Operation> future = lineageClient.deleteRunCallable().futureCall(request);
   // Do something.
   future.get();
 }

Returns
Type	Description
`UnaryCallable<DeleteRunRequest,Operation>`

deleteRunOperationCallable()

public final OperationCallable<DeleteRunRequest,Empty,OperationMetadata> deleteRunOperationCallable()

Deletes the run with the specified name.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   DeleteRunRequest request =
       DeleteRunRequest.newBuilder()
           .setName(RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]").toString())
           .setAllowMissing(true)
           .build();
   OperationFuture<Empty, OperationMetadata> future =
       lineageClient.deleteRunOperationCallable().futureCall(request);
   // Do something.
   future.get();
 }

Returns
Type	Description
`OperationCallable<DeleteRunRequest,Empty,OperationMetadata>`

getHttpJsonOperationsClient()

public final OperationsClient getHttpJsonOperationsClient()

Returns the OperationsClient that can be used to query the status of a long-running operation returned by another API method call.

Returns
Type	Description
`OperationsClient`

getLineageEvent(GetLineageEventRequest request)

public final LineageEvent getLineageEvent(GetLineageEventRequest request)

Gets details of a specified lineage event.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   GetLineageEventRequest request =
       GetLineageEventRequest.newBuilder()
           .setName(
               LineageEventName.of(
                       "[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]")
                   .toString())
           .build();
   LineageEvent response = lineageClient.getLineageEvent(request);
 }

Parameter
Name	Description
`request`	`GetLineageEventRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`LineageEvent`

getLineageEvent(LineageEventName name)

public final LineageEvent getLineageEvent(LineageEventName name)

Gets details of a specified lineage event.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   LineageEventName name =
       LineageEventName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]");
   LineageEvent response = lineageClient.getLineageEvent(name);
 }

Parameter
Name	Description
`name`	`LineageEventName` Required. The name of the lineage event to get.

Returns
Type	Description
`LineageEvent`

getLineageEvent(String name)

public final LineageEvent getLineageEvent(String name)

Gets details of a specified lineage event.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   String name =
       LineageEventName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]")
           .toString();
   LineageEvent response = lineageClient.getLineageEvent(name);
 }

Parameter
Name	Description
`name`	`String` Required. The name of the lineage event to get.

Returns
Type	Description
`LineageEvent`

getLineageEventCallable()

public final UnaryCallable<GetLineageEventRequest,LineageEvent> getLineageEventCallable()

Gets details of a specified lineage event.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   GetLineageEventRequest request =
       GetLineageEventRequest.newBuilder()
           .setName(
               LineageEventName.of(
                       "[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]", "[LINEAGE_EVENT]")
                   .toString())
           .build();
   ApiFuture<LineageEvent> future = lineageClient.getLineageEventCallable().futureCall(request);
   // Do something.
   LineageEvent response = future.get();
 }

Returns
Type	Description
`UnaryCallable<GetLineageEventRequest,LineageEvent>`

getOperationsClient()

public final OperationsClient getOperationsClient()

Returns the OperationsClient that can be used to query the status of a long-running operation returned by another API method call.

Returns
Type	Description
`OperationsClient`

getProcess(GetProcessRequest request)

public final Process getProcess(GetProcessRequest request)

Gets the details of the specified process.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   GetProcessRequest request =
       GetProcessRequest.newBuilder()
           .setName(ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]").toString())
           .build();
   Process response = lineageClient.getProcess(request);
 }

Parameter
Name	Description
`request`	`GetProcessRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`Process`

getProcess(ProcessName name)

public final Process getProcess(ProcessName name)

Gets the details of the specified process.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   ProcessName name = ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]");
   Process response = lineageClient.getProcess(name);
 }

Parameter
Name	Description
`name`	`ProcessName` Required. The name of the process to get.

Returns
Type	Description
`Process`

getProcess(String name)

public final Process getProcess(String name)

Gets the details of the specified process.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   String name = ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]").toString();
   Process response = lineageClient.getProcess(name);
 }

Parameter
Name	Description
`name`	`String` Required. The name of the process to get.

Returns
Type	Description
`Process`

getProcessCallable()

public final UnaryCallable<GetProcessRequest,Process> getProcessCallable()

Gets the details of the specified process.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   GetProcessRequest request =
       GetProcessRequest.newBuilder()
           .setName(ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]").toString())
           .build();
   ApiFuture<Process> future = lineageClient.getProcessCallable().futureCall(request);
   // Do something.
   Process response = future.get();
 }

Returns
Type	Description
`UnaryCallable<GetProcessRequest,Process>`

getRun(GetRunRequest request)

public final Run getRun(GetRunRequest request)

Gets the details of the specified run.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   GetRunRequest request =
       GetRunRequest.newBuilder()
           .setName(RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]").toString())
           .build();
   Run response = lineageClient.getRun(request);
 }

Parameter
Name	Description
`request`	`GetRunRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`Run`

getRun(RunName name)

public final Run getRun(RunName name)

Gets the details of the specified run.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   RunName name = RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
   Run response = lineageClient.getRun(name);
 }

Parameter
Name	Description
`name`	`RunName` Required. The name of the run to get.

Returns
Type	Description
`Run`

getRun(String name)

public final Run getRun(String name)

Gets the details of the specified run.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   String name = RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]").toString();
   Run response = lineageClient.getRun(name);
 }

Parameter
Name	Description
`name`	`String` Required. The name of the run to get.

Returns
Type	Description
`Run`

getRunCallable()

public final UnaryCallable<GetRunRequest,Run> getRunCallable()

Gets the details of the specified run.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   GetRunRequest request =
       GetRunRequest.newBuilder()
           .setName(RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]").toString())
           .build();
   ApiFuture<Run> future = lineageClient.getRunCallable().futureCall(request);
   // Do something.
   Run response = future.get();
 }

Returns
Type	Description
`UnaryCallable<GetRunRequest,Run>`

getSettings()

public final LineageSettings getSettings()

Returns
Type	Description
`LineageSettings`

getStub()

public LineageStub getStub()

Returns
Type	Description
`LineageStub`

isShutdown()

public boolean isShutdown()

Returns
Type	Description
`boolean`

isTerminated()

public boolean isTerminated()

Returns
Type	Description
`boolean`

listLineageEvents(ListLineageEventsRequest request)

public final LineageClient.ListLineageEventsPagedResponse listLineageEvents(ListLineageEventsRequest request)

Lists lineage events in the given project and location. The list order is not defined.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   ListLineageEventsRequest request =
       ListLineageEventsRequest.newBuilder()
           .setParent(RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   for (LineageEvent element : lineageClient.listLineageEvents(request).iterateAll()) {
     // doThingsWith(element);
   }
 }

Parameter
Name	Description
`request`	`ListLineageEventsRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`LineageClient.ListLineageEventsPagedResponse`

listLineageEvents(RunName parent)

public final LineageClient.ListLineageEventsPagedResponse listLineageEvents(RunName parent)

Lists lineage events in the given project and location. The list order is not defined.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   RunName parent = RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]");
   for (LineageEvent element : lineageClient.listLineageEvents(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }

Parameter
Name	Description
`parent`	`RunName` Required. The name of the run that owns the collection of lineage events to get.

Returns
Type	Description
`LineageClient.ListLineageEventsPagedResponse`

listLineageEvents(String parent)

public final LineageClient.ListLineageEventsPagedResponse listLineageEvents(String parent)

Lists lineage events in the given project and location. The list order is not defined.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   String parent = RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]").toString();
   for (LineageEvent element : lineageClient.listLineageEvents(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }

Parameter
Name	Description
`parent`	`String` Required. The name of the run that owns the collection of lineage events to get.

Returns
Type	Description
`LineageClient.ListLineageEventsPagedResponse`

listLineageEventsCallable()

public final UnaryCallable<ListLineageEventsRequest,ListLineageEventsResponse> listLineageEventsCallable()

Lists lineage events in the given project and location. The list order is not defined.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   ListLineageEventsRequest request =
       ListLineageEventsRequest.newBuilder()
           .setParent(RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   while (true) {
     ListLineageEventsResponse response =
         lineageClient.listLineageEventsCallable().call(request);
     for (LineageEvent element : response.getLineageEventsList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }

Returns
Type	Description
`UnaryCallable<ListLineageEventsRequest,ListLineageEventsResponse>`

listLineageEventsPagedCallable()

public final UnaryCallable<ListLineageEventsRequest,LineageClient.ListLineageEventsPagedResponse> listLineageEventsPagedCallable()

Lists lineage events in the given project and location. The list order is not defined.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   ListLineageEventsRequest request =
       ListLineageEventsRequest.newBuilder()
           .setParent(RunName.of("[PROJECT]", "[LOCATION]", "[PROCESS]", "[RUN]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   ApiFuture<LineageEvent> future =
       lineageClient.listLineageEventsPagedCallable().futureCall(request);
   // Do something.
   for (LineageEvent element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }

Returns
Type	Description
`UnaryCallable<ListLineageEventsRequest,ListLineageEventsPagedResponse>`

listProcesses(ListProcessesRequest request)

public final LineageClient.ListProcessesPagedResponse listProcesses(ListProcessesRequest request)

List processes in the given project and location. List order is descending by insertion time.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   ListProcessesRequest request =
       ListProcessesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   for (Process element : lineageClient.listProcesses(request).iterateAll()) {
     // doThingsWith(element);
   }
 }

Parameter
Name	Description
`request`	`ListProcessesRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`LineageClient.ListProcessesPagedResponse`

listProcesses(LocationName parent)

public final LineageClient.ListProcessesPagedResponse listProcesses(LocationName parent)

List processes in the given project and location. List order is descending by insertion time.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   LocationName parent = LocationName.of("[PROJECT]", "[LOCATION]");
   for (Process element : lineageClient.listProcesses(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }

Parameter
Name	Description
`parent`	`LocationName` Required. The name of the project and its location that owns this collection of processes.

Returns
Type	Description
`LineageClient.ListProcessesPagedResponse`

listProcesses(String parent)

public final LineageClient.ListProcessesPagedResponse listProcesses(String parent)

List processes in the given project and location. List order is descending by insertion time.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   String parent = LocationName.of("[PROJECT]", "[LOCATION]").toString();
   for (Process element : lineageClient.listProcesses(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }

Parameter
Name	Description
`parent`	`String` Required. The name of the project and its location that owns this collection of processes.

Returns
Type	Description
`LineageClient.ListProcessesPagedResponse`

listProcessesCallable()

public final UnaryCallable<ListProcessesRequest,ListProcessesResponse> listProcessesCallable()

List processes in the given project and location. List order is descending by insertion time.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   ListProcessesRequest request =
       ListProcessesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   while (true) {
     ListProcessesResponse response = lineageClient.listProcessesCallable().call(request);
     for (Process element : response.getProcessesList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }

Returns
Type	Description
`UnaryCallable<ListProcessesRequest,ListProcessesResponse>`

listProcessesPagedCallable()

public final UnaryCallable<ListProcessesRequest,LineageClient.ListProcessesPagedResponse> listProcessesPagedCallable()

List processes in the given project and location. List order is descending by insertion time.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   ListProcessesRequest request =
       ListProcessesRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   ApiFuture<Process> future = lineageClient.listProcessesPagedCallable().futureCall(request);
   // Do something.
   for (Process element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }

Returns
Type	Description
`UnaryCallable<ListProcessesRequest,ListProcessesPagedResponse>`

listRuns(ListRunsRequest request)

public final LineageClient.ListRunsPagedResponse listRuns(ListRunsRequest request)

Lists runs in the given project and location. List order is descending by start_time.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   ListRunsRequest request =
       ListRunsRequest.newBuilder()
           .setParent(ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   for (Run element : lineageClient.listRuns(request).iterateAll()) {
     // doThingsWith(element);
   }
 }

Parameter
Name	Description
`request`	`ListRunsRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`LineageClient.ListRunsPagedResponse`

listRuns(ProcessName parent)

public final LineageClient.ListRunsPagedResponse listRuns(ProcessName parent)

Lists runs in the given project and location. List order is descending by start_time.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   ProcessName parent = ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]");
   for (Run element : lineageClient.listRuns(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }

Parameter
Name	Description
`parent`	`ProcessName` Required. The name of process that owns this collection of runs.

Returns
Type	Description
`LineageClient.ListRunsPagedResponse`

listRuns(String parent)

public final LineageClient.ListRunsPagedResponse listRuns(String parent)

Lists runs in the given project and location. List order is descending by start_time.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   String parent = ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]").toString();
   for (Run element : lineageClient.listRuns(parent).iterateAll()) {
     // doThingsWith(element);
   }
 }

Parameter
Name	Description
`parent`	`String` Required. The name of process that owns this collection of runs.

Returns
Type	Description
`LineageClient.ListRunsPagedResponse`

listRunsCallable()

public final UnaryCallable<ListRunsRequest,ListRunsResponse> listRunsCallable()

Lists runs in the given project and location. List order is descending by start_time.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   ListRunsRequest request =
       ListRunsRequest.newBuilder()
           .setParent(ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   while (true) {
     ListRunsResponse response = lineageClient.listRunsCallable().call(request);
     for (Run element : response.getRunsList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }

Returns
Type	Description
`UnaryCallable<ListRunsRequest,ListRunsResponse>`

listRunsPagedCallable()

public final UnaryCallable<ListRunsRequest,LineageClient.ListRunsPagedResponse> listRunsPagedCallable()

Lists runs in the given project and location. List order is descending by start_time.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   ListRunsRequest request =
       ListRunsRequest.newBuilder()
           .setParent(ProcessName.of("[PROJECT]", "[LOCATION]", "[PROCESS]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   ApiFuture<Run> future = lineageClient.listRunsPagedCallable().futureCall(request);
   // Do something.
   for (Run element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }

Returns
Type	Description
`UnaryCallable<ListRunsRequest,ListRunsPagedResponse>`

searchLinks(SearchLinksRequest request)

public final LineageClient.SearchLinksPagedResponse 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.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   SearchLinksRequest request =
       SearchLinksRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   for (Link element : lineageClient.searchLinks(request).iterateAll()) {
     // doThingsWith(element);
   }
 }

Parameter
Name	Description
`request`	`SearchLinksRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`LineageClient.SearchLinksPagedResponse`

searchLinksCallable()

public final UnaryCallable<SearchLinksRequest,SearchLinksResponse> searchLinksCallable()

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.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   SearchLinksRequest request =
       SearchLinksRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   while (true) {
     SearchLinksResponse response = lineageClient.searchLinksCallable().call(request);
     for (Link element : response.getLinksList()) {
       // doThingsWith(element);
     }
     String nextPageToken = response.getNextPageToken();
     if (!Strings.isNullOrEmpty(nextPageToken)) {
       request = request.toBuilder().setPageToken(nextPageToken).build();
     } else {
       break;
     }
   }
 }

Returns
Type	Description
`UnaryCallable<SearchLinksRequest,SearchLinksResponse>`

searchLinksPagedCallable()

public final UnaryCallable<SearchLinksRequest,LineageClient.SearchLinksPagedResponse> searchLinksPagedCallable()

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.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   SearchLinksRequest request =
       SearchLinksRequest.newBuilder()
           .setParent(LocationName.of("[PROJECT]", "[LOCATION]").toString())
           .setPageSize(883849137)
           .setPageToken("pageToken873572522")
           .build();
   ApiFuture<Link> future = lineageClient.searchLinksPagedCallable().futureCall(request);
   // Do something.
   for (Link element : future.get().iterateAll()) {
     // doThingsWith(element);
   }
 }

Returns
Type	Description
`UnaryCallable<SearchLinksRequest,SearchLinksPagedResponse>`

shutdown()

public void shutdown()

shutdownNow()

public void shutdownNow()

updateProcess(Process process, FieldMask updateMask)

public final Process updateProcess(Process process, FieldMask updateMask)

Updates a process.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   Process process = Process.newBuilder().build();
   FieldMask updateMask = FieldMask.newBuilder().build();
   Process response = lineageClient.updateProcess(process, updateMask);
 }

Parameters

Name Description

process

Process

Required. The lineage process to update.

The process's name field is used to identify the process to update.

updateMask

FieldMask

The list of fields to update. Currently not used. The whole message is updated.

Returns
Type	Description
`Process`

updateProcess(UpdateProcessRequest request)

public final Process updateProcess(UpdateProcessRequest request)

Updates a process.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   UpdateProcessRequest request =
       UpdateProcessRequest.newBuilder()
           .setProcess(Process.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .build();
   Process response = lineageClient.updateProcess(request);
 }

Parameter
Name	Description
`request`	`UpdateProcessRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`Process`

updateProcessCallable()

public final UnaryCallable<UpdateProcessRequest,Process> updateProcessCallable()

Updates a process.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   UpdateProcessRequest request =
       UpdateProcessRequest.newBuilder()
           .setProcess(Process.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .setAllowMissing(true)
           .build();
   ApiFuture<Process> future = lineageClient.updateProcessCallable().futureCall(request);
   // Do something.
   Process response = future.get();
 }

Returns
Type	Description
`UnaryCallable<UpdateProcessRequest,Process>`

updateRun(Run run, FieldMask updateMask)

public final Run updateRun(Run run, FieldMask updateMask)

Updates a run.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   Run run = Run.newBuilder().build();
   FieldMask updateMask = FieldMask.newBuilder().build();
   Run response = lineageClient.updateRun(run, updateMask);
 }

Parameters

Name Description

run

Run

Required. The lineage run to update.

The run's name field is used to identify the run to update.

Format: projects/{project}/locations/{location}/processes/{process}/runs/{run}.

updateMask

FieldMask

The list of fields to update. Currently not used. The whole message is updated.

Returns
Type	Description
`Run`

updateRun(UpdateRunRequest request)

public final Run updateRun(UpdateRunRequest request)

Updates a run.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   UpdateRunRequest request =
       UpdateRunRequest.newBuilder()
           .setRun(Run.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .build();
   Run response = lineageClient.updateRun(request);
 }

Parameter
Name	Description
`request`	`UpdateRunRequest` The request object containing all of the parameters for the API call.

Returns
Type	Description
`Run`

updateRunCallable()

public final UnaryCallable<UpdateRunRequest,Run> updateRunCallable()

Updates a run.

Sample code:


 // This snippet has been automatically generated and should be regarded as a code template only.
 // It will require modifications to work:
 // - It may require correct/in-range values for request initialization.
 // - It may require specifying regional endpoints when creating the service client as shown in
 // https://cloud.google.com/java/docs/setup#configure_endpoints_for_the_client_library
 try (LineageClient lineageClient = LineageClient.create()) {
   UpdateRunRequest request =
       UpdateRunRequest.newBuilder()
           .setRun(Run.newBuilder().build())
           .setUpdateMask(FieldMask.newBuilder().build())
           .build();
   ApiFuture<Run> future = lineageClient.updateRunCallable().futureCall(request);
   // Do something.
   Run response = future.get();
 }

Returns
Type	Description
`UnaryCallable<UpdateRunRequest,Run>`