Class LineageClient (0.6.0)

Version 0.6.0

• 0.45.0 (latest)
• 0.44.0
• 0.43.0
• 0.41.0
• 0.40.0
• 0.39.0
• 0.38.0
• 0.37.0
• 0.36.0
• 0.35.0
• 0.34.0
• 0.33.0
• 0.32.0
• 0.31.0
• 0.29.0
• 0.28.0
• 0.27.0
• 0.26.0
• 0.25.0
• 0.24.0
• 0.23.0
• 0.22.0
• 0.21.0
• 0.20.0
• 0.19.0
• 0.16.0
• 0.15.0
• 0.14.0
• 0.13.0
• 0.12.0
• 0.11.0
• 0.10.0
• 0.9.0
• 0.8.0
• 0.7.0
• 0.6.0
• 0.5.0
• 0.4.0
• 0.3.0
• 0.1.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:

1. 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.
2. 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.
3. 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()

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();
   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()

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();
   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()

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();
   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()

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();
   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>