Data Lineage v1 API - Class LineageClientImpl (1.2.0)

public sealed class LineageClientImpl : LineageClient

Reference documentation and code samples for the Data Lineage v1 API class LineageClientImpl.

Lineage client wrapper implementation, for convenient use.

Inheritance

object > LineageClient > LineageClientImpl

Inherited Members

LineageClient.DefaultEndpoint

LineageClient.DefaultScopes

LineageClient.ServiceMetadata

LineageClient.CreateAsync(CancellationToken)

LineageClient.Create()

LineageClient.ShutdownDefaultChannelsAsync()

LineageClient.ProcessOpenLineageRunEventAsync(ProcessOpenLineageRunEventRequest, CancellationToken)

LineageClient.ProcessOpenLineageRunEvent(string, Struct, CallSettings)

LineageClient.ProcessOpenLineageRunEventAsync(string, Struct, CallSettings)

LineageClient.ProcessOpenLineageRunEventAsync(string, Struct, CancellationToken)

LineageClient.CreateProcessAsync(CreateProcessRequest, CancellationToken)

LineageClient.CreateProcess(string, Process, CallSettings)

LineageClient.CreateProcessAsync(string, Process, CallSettings)

LineageClient.CreateProcessAsync(string, Process, CancellationToken)

LineageClient.CreateProcess(LocationName, Process, CallSettings)

LineageClient.CreateProcessAsync(LocationName, Process, CallSettings)

LineageClient.CreateProcessAsync(LocationName, Process, CancellationToken)

LineageClient.UpdateProcessAsync(UpdateProcessRequest, CancellationToken)

LineageClient.UpdateProcess(Process, FieldMask, CallSettings)

LineageClient.UpdateProcessAsync(Process, FieldMask, CallSettings)

LineageClient.UpdateProcessAsync(Process, FieldMask, CancellationToken)

LineageClient.GetProcessAsync(GetProcessRequest, CancellationToken)

LineageClient.GetProcess(string, CallSettings)

LineageClient.GetProcessAsync(string, CallSettings)

LineageClient.GetProcessAsync(string, CancellationToken)

LineageClient.GetProcess(ProcessName, CallSettings)

LineageClient.GetProcessAsync(ProcessName, CallSettings)

LineageClient.GetProcessAsync(ProcessName, CancellationToken)

LineageClient.ListProcesses(string, string, int?, CallSettings)

LineageClient.ListProcessesAsync(string, string, int?, CallSettings)

LineageClient.ListProcesses(LocationName, string, int?, CallSettings)

LineageClient.ListProcessesAsync(LocationName, string, int?, CallSettings)

LineageClient.DeleteProcessAsync(DeleteProcessRequest, CancellationToken)

LineageClient.PollOnceDeleteProcess(string, CallSettings)

LineageClient.PollOnceDeleteProcessAsync(string, CallSettings)

LineageClient.DeleteProcess(string, CallSettings)

LineageClient.DeleteProcessAsync(string, CallSettings)

LineageClient.DeleteProcessAsync(string, CancellationToken)

LineageClient.DeleteProcess(ProcessName, CallSettings)

LineageClient.DeleteProcessAsync(ProcessName, CallSettings)

LineageClient.DeleteProcessAsync(ProcessName, CancellationToken)

LineageClient.CreateRunAsync(CreateRunRequest, CancellationToken)

LineageClient.CreateRun(string, Run, CallSettings)

LineageClient.CreateRunAsync(string, Run, CallSettings)

LineageClient.CreateRunAsync(string, Run, CancellationToken)

LineageClient.CreateRun(ProcessName, Run, CallSettings)

LineageClient.CreateRunAsync(ProcessName, Run, CallSettings)

LineageClient.CreateRunAsync(ProcessName, Run, CancellationToken)

LineageClient.UpdateRunAsync(UpdateRunRequest, CancellationToken)

LineageClient.UpdateRun(Run, FieldMask, CallSettings)

LineageClient.UpdateRunAsync(Run, FieldMask, CallSettings)

LineageClient.UpdateRunAsync(Run, FieldMask, CancellationToken)

LineageClient.GetRunAsync(GetRunRequest, CancellationToken)

LineageClient.GetRun(string, CallSettings)

LineageClient.GetRunAsync(string, CallSettings)

LineageClient.GetRunAsync(string, CancellationToken)

LineageClient.GetRun(RunName, CallSettings)

LineageClient.GetRunAsync(RunName, CallSettings)

LineageClient.GetRunAsync(RunName, CancellationToken)

LineageClient.ListRuns(string, string, int?, CallSettings)

LineageClient.ListRunsAsync(string, string, int?, CallSettings)

LineageClient.ListRuns(ProcessName, string, int?, CallSettings)

LineageClient.ListRunsAsync(ProcessName, string, int?, CallSettings)

LineageClient.DeleteRunAsync(DeleteRunRequest, CancellationToken)

LineageClient.PollOnceDeleteRun(string, CallSettings)

LineageClient.PollOnceDeleteRunAsync(string, CallSettings)

LineageClient.DeleteRun(string, CallSettings)

LineageClient.DeleteRunAsync(string, CallSettings)

LineageClient.DeleteRunAsync(string, CancellationToken)

LineageClient.DeleteRun(RunName, CallSettings)

LineageClient.DeleteRunAsync(RunName, CallSettings)

LineageClient.DeleteRunAsync(RunName, CancellationToken)

LineageClient.CreateLineageEventAsync(CreateLineageEventRequest, CancellationToken)

LineageClient.CreateLineageEvent(string, LineageEvent, CallSettings)

LineageClient.CreateLineageEventAsync(string, LineageEvent, CallSettings)

LineageClient.CreateLineageEventAsync(string, LineageEvent, CancellationToken)

LineageClient.CreateLineageEvent(RunName, LineageEvent, CallSettings)

LineageClient.CreateLineageEventAsync(RunName, LineageEvent, CallSettings)

LineageClient.CreateLineageEventAsync(RunName, LineageEvent, CancellationToken)

LineageClient.GetLineageEventAsync(GetLineageEventRequest, CancellationToken)

LineageClient.GetLineageEvent(string, CallSettings)

LineageClient.GetLineageEventAsync(string, CallSettings)

LineageClient.GetLineageEventAsync(string, CancellationToken)

LineageClient.GetLineageEvent(LineageEventName, CallSettings)

LineageClient.GetLineageEventAsync(LineageEventName, CallSettings)

LineageClient.GetLineageEventAsync(LineageEventName, CancellationToken)

LineageClient.ListLineageEvents(string, string, int?, CallSettings)

LineageClient.ListLineageEventsAsync(string, string, int?, CallSettings)

LineageClient.ListLineageEvents(RunName, string, int?, CallSettings)

LineageClient.ListLineageEventsAsync(RunName, string, int?, CallSettings)

LineageClient.DeleteLineageEventAsync(DeleteLineageEventRequest, CancellationToken)

LineageClient.DeleteLineageEvent(string, CallSettings)

LineageClient.DeleteLineageEventAsync(string, CallSettings)

LineageClient.DeleteLineageEventAsync(string, CancellationToken)

LineageClient.DeleteLineageEvent(LineageEventName, CallSettings)

LineageClient.DeleteLineageEventAsync(LineageEventName, CallSettings)

LineageClient.DeleteLineageEventAsync(LineageEventName, CancellationToken)

object.GetHashCode()

object.GetType()

object.ToString()

Namespace

Google.Cloud.DataCatalog.Lineage.V1

Assembly

Google.Cloud.DataCatalog.Lineage.V1.dll

Remarks

Lineage is used to track data flows between assets over time. You can create [LineageEvents][google.cloud.datacatalog.lineage.v1.LineageEvent] to record lineage between multiple sources and a single target, for example, when table data is based on data from multiple tables.

Constructors

LineageClientImpl(LineageClient, LineageSettings, ILogger)

public LineageClientImpl(Lineage.LineageClient grpcClient, LineageSettings settings, ILogger logger)

Constructs a client wrapper for the Lineage service, with the specified gRPC client and settings.

Parameters
Name	Description
`grpcClient`	`LineageLineageClient` The underlying gRPC client.
`settings`	`LineageSettings` The base LineageSettings used within this client.
`logger`	`ILogger` Optional ILogger to use within this client.

Properties

DeleteProcessOperationsClient

public override OperationsClient DeleteProcessOperationsClient { get; }

The long-running operations client for DeleteProcess.

Property Value
Type	Description
`OperationsClient`

Overrides

LineageClient.DeleteProcessOperationsClient

DeleteRunOperationsClient

public override OperationsClient DeleteRunOperationsClient { get; }

The long-running operations client for DeleteRun.

Property Value
Type	Description
`OperationsClient`

Overrides

LineageClient.DeleteRunOperationsClient

GrpcClient

public override Lineage.LineageClient GrpcClient { get; }

The underlying gRPC Lineage client

Property Value
Type	Description
`LineageLineageClient`

Overrides

LineageClient.GrpcClient

Methods

BatchSearchLinkProcesses(BatchSearchLinkProcessesRequest, CallSettings)

public override PagedEnumerable<BatchSearchLinkProcessesResponse, ProcessLinks> BatchSearchLinkProcesses(BatchSearchLinkProcessesRequest request, CallSettings callSettings = null)

Retrieve information about LineageProcesses associated with specific links. LineageProcesses are transformation pipelines that result in data flowing from source to target assets. Links between assets represent this operation.

If you have specific link names, you can use this method to verify which LineageProcesses contribute to creating those links. See the [SearchLinks][google.cloud.datacatalog.lineage.v1.Lineage.SearchLinks] method for more information on how to retrieve link name.

You can retrieve the LineageProcess information in every project where you have the datalineage.events.get permission. The project provided in the URL is used for Billing and Quota.

Parameters
Name	Description
`request`	`BatchSearchLinkProcessesRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`PagedEnumerableBatchSearchLinkProcessesResponseProcessLinks`	A pageable sequence of ProcessLinks resources.

Overrides

LineageClient.BatchSearchLinkProcesses(BatchSearchLinkProcessesRequest, CallSettings)

BatchSearchLinkProcessesAsync(BatchSearchLinkProcessesRequest, CallSettings)

public override PagedAsyncEnumerable<BatchSearchLinkProcessesResponse, ProcessLinks> BatchSearchLinkProcessesAsync(BatchSearchLinkProcessesRequest request, CallSettings callSettings = null)

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.

Parameters
Name	Description
`request`	`BatchSearchLinkProcessesRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`PagedAsyncEnumerableBatchSearchLinkProcessesResponseProcessLinks`	A pageable asynchronous sequence of ProcessLinks resources.

Overrides

LineageClient.BatchSearchLinkProcessesAsync(BatchSearchLinkProcessesRequest, CallSettings)

CreateLineageEvent(CreateLineageEventRequest, CallSettings)

public override LineageEvent CreateLineageEvent(CreateLineageEventRequest request, CallSettings callSettings = null)

Creates a new lineage event.

Parameters
Name	Description
`request`	`CreateLineageEventRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`LineageEvent`	The RPC response.

Overrides

LineageClient.CreateLineageEvent(CreateLineageEventRequest, CallSettings)

CreateLineageEventAsync(CreateLineageEventRequest, CallSettings)

public override Task<LineageEvent> CreateLineageEventAsync(CreateLineageEventRequest request, CallSettings callSettings = null)

Creates a new lineage event.

Parameters
Name	Description
`request`	`CreateLineageEventRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`TaskLineageEvent`	A Task containing the RPC response.

Overrides

LineageClient.CreateLineageEventAsync(CreateLineageEventRequest, CallSettings)

CreateProcess(CreateProcessRequest, CallSettings)

public override Process CreateProcess(CreateProcessRequest request, CallSettings callSettings = null)

Creates a new process.

Parameters
Name	Description
`request`	`CreateProcessRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`Process`	The RPC response.

Overrides

LineageClient.CreateProcess(CreateProcessRequest, CallSettings)

CreateProcessAsync(CreateProcessRequest, CallSettings)

public override Task<Process> CreateProcessAsync(CreateProcessRequest request, CallSettings callSettings = null)

Creates a new process.

Parameters
Name	Description
`request`	`CreateProcessRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`TaskProcess`	A Task containing the RPC response.

Overrides

LineageClient.CreateProcessAsync(CreateProcessRequest, CallSettings)

CreateRun(CreateRunRequest, CallSettings)

public override Run CreateRun(CreateRunRequest request, CallSettings callSettings = null)

Creates a new run.

Parameters
Name	Description
`request`	`CreateRunRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`Run`	The RPC response.

Overrides

LineageClient.CreateRun(CreateRunRequest, CallSettings)

CreateRunAsync(CreateRunRequest, CallSettings)

public override Task<Run> CreateRunAsync(CreateRunRequest request, CallSettings callSettings = null)

Creates a new run.

Parameters
Name	Description
`request`	`CreateRunRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`TaskRun`	A Task containing the RPC response.

Overrides

LineageClient.CreateRunAsync(CreateRunRequest, CallSettings)

DeleteLineageEvent(DeleteLineageEventRequest, CallSettings)

public override void DeleteLineageEvent(DeleteLineageEventRequest request, CallSettings callSettings = null)

Deletes the lineage event with the specified name.

Parameters
Name	Description
`request`	`DeleteLineageEventRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Overrides

LineageClient.DeleteLineageEvent(DeleteLineageEventRequest, CallSettings)

DeleteLineageEventAsync(DeleteLineageEventRequest, CallSettings)

public override Task DeleteLineageEventAsync(DeleteLineageEventRequest request, CallSettings callSettings = null)

Deletes the lineage event with the specified name.

Parameters
Name	Description
`request`	`DeleteLineageEventRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`Task`	A Task containing the RPC response.

Overrides

LineageClient.DeleteLineageEventAsync(DeleteLineageEventRequest, CallSettings)

DeleteProcess(DeleteProcessRequest, CallSettings)

public override Operation<Empty, OperationMetadata> DeleteProcess(DeleteProcessRequest request, CallSettings callSettings = null)

Deletes the process with the specified name.

Parameters
Name	Description
`request`	`DeleteProcessRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`OperationEmptyOperationMetadata`	The RPC response.

Overrides

LineageClient.DeleteProcess(DeleteProcessRequest, CallSettings)

DeleteProcessAsync(DeleteProcessRequest, CallSettings)

public override Task<Operation<Empty, OperationMetadata>> DeleteProcessAsync(DeleteProcessRequest request, CallSettings callSettings = null)

Deletes the process with the specified name.

Parameters
Name	Description
`request`	`DeleteProcessRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`TaskOperationEmptyOperationMetadata`	A Task containing the RPC response.

Overrides

LineageClient.DeleteProcessAsync(DeleteProcessRequest, CallSettings)

DeleteRun(DeleteRunRequest, CallSettings)

public override Operation<Empty, OperationMetadata> DeleteRun(DeleteRunRequest request, CallSettings callSettings = null)

Deletes the run with the specified name.

Parameters
Name	Description
`request`	`DeleteRunRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`OperationEmptyOperationMetadata`	The RPC response.

Overrides

LineageClient.DeleteRun(DeleteRunRequest, CallSettings)

DeleteRunAsync(DeleteRunRequest, CallSettings)

public override Task<Operation<Empty, OperationMetadata>> DeleteRunAsync(DeleteRunRequest request, CallSettings callSettings = null)

Deletes the run with the specified name.

Parameters
Name	Description
`request`	`DeleteRunRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`TaskOperationEmptyOperationMetadata`	A Task containing the RPC response.

Overrides

LineageClient.DeleteRunAsync(DeleteRunRequest, CallSettings)

GetLineageEvent(GetLineageEventRequest, CallSettings)

public override LineageEvent GetLineageEvent(GetLineageEventRequest request, CallSettings callSettings = null)

Gets details of a specified lineage event.

Parameters
Name	Description
`request`	`GetLineageEventRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`LineageEvent`	The RPC response.

Overrides

LineageClient.GetLineageEvent(GetLineageEventRequest, CallSettings)

GetLineageEventAsync(GetLineageEventRequest, CallSettings)

public override Task<LineageEvent> GetLineageEventAsync(GetLineageEventRequest request, CallSettings callSettings = null)

Gets details of a specified lineage event.

Parameters
Name	Description
`request`	`GetLineageEventRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`TaskLineageEvent`	A Task containing the RPC response.

Overrides

LineageClient.GetLineageEventAsync(GetLineageEventRequest, CallSettings)

GetProcess(GetProcessRequest, CallSettings)

public override Process GetProcess(GetProcessRequest request, CallSettings callSettings = null)

Gets the details of the specified process.

Parameters
Name	Description
`request`	`GetProcessRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`Process`	The RPC response.

Overrides

LineageClient.GetProcess(GetProcessRequest, CallSettings)

GetProcessAsync(GetProcessRequest, CallSettings)

public override Task<Process> GetProcessAsync(GetProcessRequest request, CallSettings callSettings = null)

Gets the details of the specified process.

Parameters
Name	Description
`request`	`GetProcessRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`TaskProcess`	A Task containing the RPC response.

Overrides

LineageClient.GetProcessAsync(GetProcessRequest, CallSettings)

GetRun(GetRunRequest, CallSettings)

public override Run GetRun(GetRunRequest request, CallSettings callSettings = null)

Gets the details of the specified run.

Parameters
Name	Description
`request`	`GetRunRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`Run`	The RPC response.

Overrides

LineageClient.GetRun(GetRunRequest, CallSettings)

GetRunAsync(GetRunRequest, CallSettings)

public override Task<Run> GetRunAsync(GetRunRequest request, CallSettings callSettings = null)

Gets the details of the specified run.

Parameters
Name	Description
`request`	`GetRunRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`TaskRun`	A Task containing the RPC response.

Overrides

LineageClient.GetRunAsync(GetRunRequest, CallSettings)

ListLineageEvents(ListLineageEventsRequest, CallSettings)

public override PagedEnumerable<ListLineageEventsResponse, LineageEvent> ListLineageEvents(ListLineageEventsRequest request, CallSettings callSettings = null)

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

Parameters
Name	Description
`request`	`ListLineageEventsRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`PagedEnumerableListLineageEventsResponseLineageEvent`	A pageable sequence of LineageEvent resources.

Overrides

LineageClient.ListLineageEvents(ListLineageEventsRequest, CallSettings)

ListLineageEventsAsync(ListLineageEventsRequest, CallSettings)

public override PagedAsyncEnumerable<ListLineageEventsResponse, LineageEvent> ListLineageEventsAsync(ListLineageEventsRequest request, CallSettings callSettings = null)

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

Parameters
Name	Description
`request`	`ListLineageEventsRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`PagedAsyncEnumerableListLineageEventsResponseLineageEvent`	A pageable asynchronous sequence of LineageEvent resources.

Overrides

LineageClient.ListLineageEventsAsync(ListLineageEventsRequest, CallSettings)

ListProcesses(ListProcessesRequest, CallSettings)

public override PagedEnumerable<ListProcessesResponse, Process> ListProcesses(ListProcessesRequest request, CallSettings callSettings = null)

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

Parameters
Name	Description
`request`	`ListProcessesRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`PagedEnumerableListProcessesResponseProcess`	A pageable sequence of Process resources.

Overrides

LineageClient.ListProcesses(ListProcessesRequest, CallSettings)

ListProcessesAsync(ListProcessesRequest, CallSettings)

public override PagedAsyncEnumerable<ListProcessesResponse, Process> ListProcessesAsync(ListProcessesRequest request, CallSettings callSettings = null)

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

Parameters
Name	Description
`request`	`ListProcessesRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`PagedAsyncEnumerableListProcessesResponseProcess`	A pageable asynchronous sequence of Process resources.

Overrides

LineageClient.ListProcessesAsync(ListProcessesRequest, CallSettings)

ListRuns(ListRunsRequest, CallSettings)

public override PagedEnumerable<ListRunsResponse, Run> ListRuns(ListRunsRequest request, CallSettings callSettings = null)

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

Parameters
Name	Description
`request`	`ListRunsRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`PagedEnumerableListRunsResponseRun`	A pageable sequence of Run resources.

Overrides

LineageClient.ListRuns(ListRunsRequest, CallSettings)

ListRunsAsync(ListRunsRequest, CallSettings)

public override PagedAsyncEnumerable<ListRunsResponse, Run> ListRunsAsync(ListRunsRequest request, CallSettings callSettings = null)

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

Parameters
Name	Description
`request`	`ListRunsRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`PagedAsyncEnumerableListRunsResponseRun`	A pageable asynchronous sequence of Run resources.

Overrides

LineageClient.ListRunsAsync(ListRunsRequest, CallSettings)

ProcessOpenLineageRunEvent(ProcessOpenLineageRunEventRequest, CallSettings)

public override ProcessOpenLineageRunEventResponse ProcessOpenLineageRunEvent(ProcessOpenLineageRunEventRequest request, CallSettings callSettings = null)

Creates new lineage events together with their parents: process and run. Updates the process and run if they already exist. Mapped from Open Lineage specification: https://github.com/OpenLineage/OpenLineage/blob/main/spec/OpenLineage.json.

Parameters
Name	Description
`request`	`ProcessOpenLineageRunEventRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`ProcessOpenLineageRunEventResponse`	The RPC response.

Overrides

LineageClient.ProcessOpenLineageRunEvent(ProcessOpenLineageRunEventRequest, CallSettings)

ProcessOpenLineageRunEventAsync(ProcessOpenLineageRunEventRequest, CallSettings)

public override Task<ProcessOpenLineageRunEventResponse> ProcessOpenLineageRunEventAsync(ProcessOpenLineageRunEventRequest request, CallSettings callSettings = null)

Parameters
Name	Description
`request`	`ProcessOpenLineageRunEventRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`TaskProcessOpenLineageRunEventResponse`	A Task containing the RPC response.

Overrides

LineageClient.ProcessOpenLineageRunEventAsync(ProcessOpenLineageRunEventRequest, CallSettings)

SearchLinks(SearchLinksRequest, CallSettings)

public override PagedEnumerable<SearchLinksResponse, Link> SearchLinks(SearchLinksRequest request, CallSettings callSettings = null)

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.

Parameters
Name	Description
`request`	`SearchLinksRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`PagedEnumerableSearchLinksResponseLink`	A pageable sequence of Link resources.

Overrides

LineageClient.SearchLinks(SearchLinksRequest, CallSettings)

SearchLinksAsync(SearchLinksRequest, CallSettings)

public override PagedAsyncEnumerable<SearchLinksResponse, Link> SearchLinksAsync(SearchLinksRequest request, CallSettings callSettings = null)

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.

Parameters
Name	Description
`request`	`SearchLinksRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`PagedAsyncEnumerableSearchLinksResponseLink`	A pageable asynchronous sequence of Link resources.

Overrides

LineageClient.SearchLinksAsync(SearchLinksRequest, CallSettings)

UpdateProcess(UpdateProcessRequest, CallSettings)

public override Process UpdateProcess(UpdateProcessRequest request, CallSettings callSettings = null)

Updates a process.

Parameters
Name	Description
`request`	`UpdateProcessRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`Process`	The RPC response.

Overrides

LineageClient.UpdateProcess(UpdateProcessRequest, CallSettings)

UpdateProcessAsync(UpdateProcessRequest, CallSettings)

public override Task<Process> UpdateProcessAsync(UpdateProcessRequest request, CallSettings callSettings = null)

Updates a process.

Parameters
Name	Description
`request`	`UpdateProcessRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`TaskProcess`	A Task containing the RPC response.

Overrides

LineageClient.UpdateProcessAsync(UpdateProcessRequest, CallSettings)

UpdateRun(UpdateRunRequest, CallSettings)

public override Run UpdateRun(UpdateRunRequest request, CallSettings callSettings = null)

Updates a run.

Parameters
Name	Description
`request`	`UpdateRunRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`Run`	The RPC response.

Overrides

LineageClient.UpdateRun(UpdateRunRequest, CallSettings)

UpdateRunAsync(UpdateRunRequest, CallSettings)

public override Task<Run> UpdateRunAsync(UpdateRunRequest request, CallSettings callSettings = null)

Updates a run.

Parameters
Name	Description
`request`	`UpdateRunRequest` The request object containing all of the parameters for the API call.
`callSettings`	`CallSettings` If not null, applies overrides to this RPC call.

Returns
Type	Description
`TaskRun`	A Task containing the RPC response.

Overrides

LineageClient.UpdateRunAsync(UpdateRunRequest, CallSettings)