Interface MetadataServiceGrpc.AsyncService (3.44.0)

Version 3.44.0

• 3.52.0 (latest)
• 3.50.0
• 3.49.0
• 3.48.0
• 3.47.0
• 3.46.0
• 3.45.0
• 3.44.0
• 3.43.0
• 3.42.0
• 3.41.0
• 3.40.0
• 3.38.0
• 3.37.0
• 3.36.0
• 3.35.0
• 3.34.0
• 3.33.0
• 3.32.0
• 3.31.0
• 3.30.0
• 3.29.0
• 3.28.0
• 3.25.0
• 3.24.0
• 3.23.0
• 3.22.0
• 3.21.0
• 3.20.0
• 3.19.0
• 3.18.0
• 3.17.0
• 3.16.0
• 3.15.0
• 3.14.0
• 3.13.0
• 3.12.0
• 3.11.0
• 3.10.0
• 3.9.0
• 3.8.0
• 3.7.0
• 3.6.0
• 3.5.0
• 3.4.2
• 3.3.0
• 3.2.0
• 3.0.0
• 2.9.8
• 2.8.9
• 2.7.4
• 2.5.3
• 2.4.0

public static interface MetadataServiceGrpc.AsyncService

Service for reading and writing metadata entries.

Methods

addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request, StreamObserver<AddContextArtifactsAndExecutionsResponse> responseObserver)

public default void addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request, StreamObserver<AddContextArtifactsAndExecutionsResponse> responseObserver)

Adds a set of Artifacts and Executions to a Context. If any of the Artifacts or Executions have already been added to a Context, they are simply skipped.

Parameters
Name	Description
request	AddContextArtifactsAndExecutionsRequest
responseObserver	io.grpc.stub.StreamObserver<AddContextArtifactsAndExecutionsResponse>

addContextChildren(AddContextChildrenRequest request, StreamObserver<AddContextChildrenResponse> responseObserver)

public default void addContextChildren(AddContextChildrenRequest request, StreamObserver<AddContextChildrenResponse> responseObserver)

Adds a set of Contexts as children to a parent Context. If any of the child Contexts have already been added to the parent Context, they are simply skipped. If this call would create a cycle or cause any Context to have more than 10 parents, the request will fail with an INVALID_ARGUMENT error.

Parameters
Name	Description
request	AddContextChildrenRequest
responseObserver	io.grpc.stub.StreamObserver<AddContextChildrenResponse>

addExecutionEvents(AddExecutionEventsRequest request, StreamObserver<AddExecutionEventsResponse> responseObserver)

public default void addExecutionEvents(AddExecutionEventsRequest request, StreamObserver<AddExecutionEventsResponse> responseObserver)

Adds Events to the specified Execution. An Event indicates whether an Artifact was used as an input or output for an Execution. If an Event already exists between the Execution and the Artifact, the Event is skipped.

Parameters
Name	Description
request	AddExecutionEventsRequest
responseObserver	io.grpc.stub.StreamObserver<AddExecutionEventsResponse>

createArtifact(CreateArtifactRequest request, StreamObserver<Artifact> responseObserver)

public default void createArtifact(CreateArtifactRequest request, StreamObserver<Artifact> responseObserver)

Creates an Artifact associated with a MetadataStore.

Parameters
Name	Description
request	CreateArtifactRequest
responseObserver	io.grpc.stub.StreamObserver<Artifact>

createContext(CreateContextRequest request, StreamObserver<Context> responseObserver)

public default void createContext(CreateContextRequest request, StreamObserver<Context> responseObserver)

Creates a Context associated with a MetadataStore.

Parameters
Name	Description
request	CreateContextRequest
responseObserver	io.grpc.stub.StreamObserver<Context>

createExecution(CreateExecutionRequest request, StreamObserver<Execution> responseObserver)

public default void createExecution(CreateExecutionRequest request, StreamObserver<Execution> responseObserver)

Creates an Execution associated with a MetadataStore.

Parameters
Name	Description
request	CreateExecutionRequest
responseObserver	io.grpc.stub.StreamObserver<Execution>

createMetadataSchema(CreateMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)

public default void createMetadataSchema(CreateMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)

Creates a MetadataSchema.

Parameters
Name	Description
request	CreateMetadataSchemaRequest
responseObserver	io.grpc.stub.StreamObserver<MetadataSchema>

createMetadataStore(CreateMetadataStoreRequest request, StreamObserver<Operation> responseObserver)

public default void createMetadataStore(CreateMetadataStoreRequest request, StreamObserver<Operation> responseObserver)

Initializes a MetadataStore, including allocation of resources.

Parameters
Name	Description
request	CreateMetadataStoreRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

deleteArtifact(DeleteArtifactRequest request, StreamObserver<Operation> responseObserver)

public default void deleteArtifact(DeleteArtifactRequest request, StreamObserver<Operation> responseObserver)

Deletes an Artifact.

Parameters
Name	Description
request	DeleteArtifactRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

deleteContext(DeleteContextRequest request, StreamObserver<Operation> responseObserver)

public default void deleteContext(DeleteContextRequest request, StreamObserver<Operation> responseObserver)

Deletes a stored Context.

Parameters
Name	Description
request	DeleteContextRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

deleteExecution(DeleteExecutionRequest request, StreamObserver<Operation> responseObserver)

public default void deleteExecution(DeleteExecutionRequest request, StreamObserver<Operation> responseObserver)

Deletes an Execution.

Parameters
Name	Description
request	DeleteExecutionRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

deleteMetadataStore(DeleteMetadataStoreRequest request, StreamObserver<Operation> responseObserver)

public default void deleteMetadataStore(DeleteMetadataStoreRequest request, StreamObserver<Operation> responseObserver)

Deletes a single MetadataStore and all its child resources (Artifacts, Executions, and Contexts).

Parameters
Name	Description
request	DeleteMetadataStoreRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

getArtifact(GetArtifactRequest request, StreamObserver<Artifact> responseObserver)

public default void getArtifact(GetArtifactRequest request, StreamObserver<Artifact> responseObserver)

Retrieves a specific Artifact.

Parameters
Name	Description
request	GetArtifactRequest
responseObserver	io.grpc.stub.StreamObserver<Artifact>

getContext(GetContextRequest request, StreamObserver<Context> responseObserver)

public default void getContext(GetContextRequest request, StreamObserver<Context> responseObserver)

Retrieves a specific Context.

Parameters
Name	Description
request	GetContextRequest
responseObserver	io.grpc.stub.StreamObserver<Context>

getExecution(GetExecutionRequest request, StreamObserver<Execution> responseObserver)

public default void getExecution(GetExecutionRequest request, StreamObserver<Execution> responseObserver)

Retrieves a specific Execution.

Parameters
Name	Description
request	GetExecutionRequest
responseObserver	io.grpc.stub.StreamObserver<Execution>

getMetadataSchema(GetMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)

public default void getMetadataSchema(GetMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)

Retrieves a specific MetadataSchema.

Parameters
Name	Description
request	GetMetadataSchemaRequest
responseObserver	io.grpc.stub.StreamObserver<MetadataSchema>

getMetadataStore(GetMetadataStoreRequest request, StreamObserver<MetadataStore> responseObserver)

public default void getMetadataStore(GetMetadataStoreRequest request, StreamObserver<MetadataStore> responseObserver)

Retrieves a specific MetadataStore.

Parameters
Name	Description
request	GetMetadataStoreRequest
responseObserver	io.grpc.stub.StreamObserver<MetadataStore>

listArtifacts(ListArtifactsRequest request, StreamObserver<ListArtifactsResponse> responseObserver)

public default void listArtifacts(ListArtifactsRequest request, StreamObserver<ListArtifactsResponse> responseObserver)

Lists Artifacts in the MetadataStore.

Parameters
Name	Description
request	ListArtifactsRequest
responseObserver	io.grpc.stub.StreamObserver<ListArtifactsResponse>

listContexts(ListContextsRequest request, StreamObserver<ListContextsResponse> responseObserver)

public default void listContexts(ListContextsRequest request, StreamObserver<ListContextsResponse> responseObserver)

Lists Contexts on the MetadataStore.

Parameters
Name	Description
request	ListContextsRequest
responseObserver	io.grpc.stub.StreamObserver<ListContextsResponse>

listExecutions(ListExecutionsRequest request, StreamObserver<ListExecutionsResponse> responseObserver)

public default void listExecutions(ListExecutionsRequest request, StreamObserver<ListExecutionsResponse> responseObserver)

Lists Executions in the MetadataStore.

Parameters
Name	Description
request	ListExecutionsRequest
responseObserver	io.grpc.stub.StreamObserver<ListExecutionsResponse>

listMetadataSchemas(ListMetadataSchemasRequest request, StreamObserver<ListMetadataSchemasResponse> responseObserver)

public default void listMetadataSchemas(ListMetadataSchemasRequest request, StreamObserver<ListMetadataSchemasResponse> responseObserver)

Lists MetadataSchemas.

Parameters
Name	Description
request	ListMetadataSchemasRequest
responseObserver	io.grpc.stub.StreamObserver<ListMetadataSchemasResponse>

listMetadataStores(ListMetadataStoresRequest request, StreamObserver<ListMetadataStoresResponse> responseObserver)

public default void listMetadataStores(ListMetadataStoresRequest request, StreamObserver<ListMetadataStoresResponse> responseObserver)

Lists MetadataStores for a Location.

Parameters
Name	Description
request	ListMetadataStoresRequest
responseObserver	io.grpc.stub.StreamObserver<ListMetadataStoresResponse>

purgeArtifacts(PurgeArtifactsRequest request, StreamObserver<Operation> responseObserver)

public default void purgeArtifacts(PurgeArtifactsRequest request, StreamObserver<Operation> responseObserver)

Purges Artifacts.

Parameters
Name	Description
request	PurgeArtifactsRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

purgeContexts(PurgeContextsRequest request, StreamObserver<Operation> responseObserver)

public default void purgeContexts(PurgeContextsRequest request, StreamObserver<Operation> responseObserver)

Purges Contexts.

Parameters
Name	Description
request	PurgeContextsRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

purgeExecutions(PurgeExecutionsRequest request, StreamObserver<Operation> responseObserver)

public default void purgeExecutions(PurgeExecutionsRequest request, StreamObserver<Operation> responseObserver)

Purges Executions.

Parameters
Name	Description
request	PurgeExecutionsRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request, StreamObserver<LineageSubgraph> responseObserver)

public default void queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request, StreamObserver<LineageSubgraph> responseObserver)

Retrieves lineage of an Artifact represented through Artifacts and Executions connected by Event edges and returned as a LineageSubgraph.

Parameters
Name	Description
request	QueryArtifactLineageSubgraphRequest
responseObserver	io.grpc.stub.StreamObserver<LineageSubgraph>

queryContextLineageSubgraph(QueryContextLineageSubgraphRequest request, StreamObserver<LineageSubgraph> responseObserver)

public default void queryContextLineageSubgraph(QueryContextLineageSubgraphRequest request, StreamObserver<LineageSubgraph> responseObserver)

Retrieves Artifacts and Executions within the specified Context, connected by Event edges and returned as a LineageSubgraph.

Parameters
Name	Description
request	QueryContextLineageSubgraphRequest
responseObserver	io.grpc.stub.StreamObserver<LineageSubgraph>

queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request, StreamObserver<LineageSubgraph> responseObserver)

public default void queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request, StreamObserver<LineageSubgraph> responseObserver)

Obtains the set of input and output Artifacts for this Execution, in the form of LineageSubgraph that also contains the Execution and connecting Events.

Parameters
Name	Description
request	QueryExecutionInputsAndOutputsRequest
responseObserver	io.grpc.stub.StreamObserver<LineageSubgraph>

removeContextChildren(RemoveContextChildrenRequest request, StreamObserver<RemoveContextChildrenResponse> responseObserver)

public default void removeContextChildren(RemoveContextChildrenRequest request, StreamObserver<RemoveContextChildrenResponse> responseObserver)

Remove a set of children contexts from a parent Context. If any of the child Contexts were NOT added to the parent Context, they are simply skipped.

Parameters
Name	Description
request	RemoveContextChildrenRequest
responseObserver	io.grpc.stub.StreamObserver<RemoveContextChildrenResponse>

updateArtifact(UpdateArtifactRequest request, StreamObserver<Artifact> responseObserver)

public default void updateArtifact(UpdateArtifactRequest request, StreamObserver<Artifact> responseObserver)

Updates a stored Artifact.

Parameters
Name	Description
request	UpdateArtifactRequest
responseObserver	io.grpc.stub.StreamObserver<Artifact>

updateContext(UpdateContextRequest request, StreamObserver<Context> responseObserver)

public default void updateContext(UpdateContextRequest request, StreamObserver<Context> responseObserver)

Updates a stored Context.

Parameters
Name	Description
request	UpdateContextRequest
responseObserver	io.grpc.stub.StreamObserver<Context>

updateExecution(UpdateExecutionRequest request, StreamObserver<Execution> responseObserver)

public default void updateExecution(UpdateExecutionRequest request, StreamObserver<Execution> responseObserver)

Updates a stored Execution.

Parameters
Name	Description
request	UpdateExecutionRequest
responseObserver	io.grpc.stub.StreamObserver<Execution>