Class MetadataServiceGrpc.MetadataServiceStub (3.64.0)

public static final class MetadataServiceGrpc.MetadataServiceStub extends AbstractAsyncStub.MetadataServiceStub>

A stub to allow clients to do asynchronous rpc calls to service MetadataService.

Service for reading and writing metadata entries.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractAsyncStub > MetadataServiceGrpc.MetadataServiceStub

Methods

addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request, StreamObserver responseObserver)

public void addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request, StreamObserver 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 responseObserver)

public void addContextChildren(AddContextChildrenRequest request, StreamObserver 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 responseObserver)

public void addExecutionEvents(AddExecutionEventsRequest request, StreamObserver 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>

build(Channel channel, CallOptions callOptions)

protected MetadataServiceGrpc.MetadataServiceStub build(Channel channel, CallOptions callOptions)
Parameters
Name Description
channel io.grpc.Channel
callOptions io.grpc.CallOptions
Returns
Type Description
MetadataServiceGrpc.MetadataServiceStub
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

createArtifact(CreateArtifactRequest request, StreamObserver responseObserver)

public void createArtifact(CreateArtifactRequest request, StreamObserver responseObserver)

Creates an Artifact associated with a MetadataStore.

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

createContext(CreateContextRequest request, StreamObserver responseObserver)

public void createContext(CreateContextRequest request, StreamObserver responseObserver)

Creates a Context associated with a MetadataStore.

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

createExecution(CreateExecutionRequest request, StreamObserver responseObserver)

public void createExecution(CreateExecutionRequest request, StreamObserver responseObserver)

Creates an Execution associated with a MetadataStore.

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

createMetadataSchema(CreateMetadataSchemaRequest request, StreamObserver responseObserver)

public void createMetadataSchema(CreateMetadataSchemaRequest request, StreamObserver responseObserver)

Creates a MetadataSchema.

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

createMetadataStore(CreateMetadataStoreRequest request, StreamObserver responseObserver)

public void createMetadataStore(CreateMetadataStoreRequest request, StreamObserver responseObserver)

Initializes a MetadataStore, including allocation of resources.

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

deleteArtifact(DeleteArtifactRequest request, StreamObserver responseObserver)

public void deleteArtifact(DeleteArtifactRequest request, StreamObserver responseObserver)

Deletes an Artifact.

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

deleteContext(DeleteContextRequest request, StreamObserver responseObserver)

public void deleteContext(DeleteContextRequest request, StreamObserver responseObserver)

Deletes a stored Context.

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

deleteExecution(DeleteExecutionRequest request, StreamObserver responseObserver)

public void deleteExecution(DeleteExecutionRequest request, StreamObserver responseObserver)

Deletes an Execution.

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

deleteMetadataStore(DeleteMetadataStoreRequest request, StreamObserver responseObserver)

public void deleteMetadataStore(DeleteMetadataStoreRequest request, StreamObserver 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 responseObserver)

public void getArtifact(GetArtifactRequest request, StreamObserver responseObserver)

Retrieves a specific Artifact.

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

getContext(GetContextRequest request, StreamObserver responseObserver)

public void getContext(GetContextRequest request, StreamObserver responseObserver)

Retrieves a specific Context.

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

getExecution(GetExecutionRequest request, StreamObserver responseObserver)

public void getExecution(GetExecutionRequest request, StreamObserver responseObserver)

Retrieves a specific Execution.

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

getMetadataSchema(GetMetadataSchemaRequest request, StreamObserver responseObserver)

public void getMetadataSchema(GetMetadataSchemaRequest request, StreamObserver responseObserver)

Retrieves a specific MetadataSchema.

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

getMetadataStore(GetMetadataStoreRequest request, StreamObserver responseObserver)

public void getMetadataStore(GetMetadataStoreRequest request, StreamObserver responseObserver)

Retrieves a specific MetadataStore.

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

listArtifacts(ListArtifactsRequest request, StreamObserver responseObserver)

public void listArtifacts(ListArtifactsRequest request, StreamObserver responseObserver)

Lists Artifacts in the MetadataStore.

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

listContexts(ListContextsRequest request, StreamObserver responseObserver)

public void listContexts(ListContextsRequest request, StreamObserver responseObserver)

Lists Contexts on the MetadataStore.

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

listExecutions(ListExecutionsRequest request, StreamObserver responseObserver)

public void listExecutions(ListExecutionsRequest request, StreamObserver responseObserver)

Lists Executions in the MetadataStore.

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

listMetadataSchemas(ListMetadataSchemasRequest request, StreamObserver responseObserver)

public void listMetadataSchemas(ListMetadataSchemasRequest request, StreamObserver responseObserver)

Lists MetadataSchemas.

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

listMetadataStores(ListMetadataStoresRequest request, StreamObserver responseObserver)

public void listMetadataStores(ListMetadataStoresRequest request, StreamObserver responseObserver)

Lists MetadataStores for a Location.

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

purgeArtifacts(PurgeArtifactsRequest request, StreamObserver responseObserver)

public void purgeArtifacts(PurgeArtifactsRequest request, StreamObserver responseObserver)

Purges Artifacts.

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

purgeContexts(PurgeContextsRequest request, StreamObserver responseObserver)

public void purgeContexts(PurgeContextsRequest request, StreamObserver responseObserver)

Purges Contexts.

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

purgeExecutions(PurgeExecutionsRequest request, StreamObserver responseObserver)

public void purgeExecutions(PurgeExecutionsRequest request, StreamObserver responseObserver)

Purges Executions.

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

queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request, StreamObserver responseObserver)

public void queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request, StreamObserver 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 responseObserver)

public void queryContextLineageSubgraph(QueryContextLineageSubgraphRequest request, StreamObserver 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 responseObserver)

public void queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request, StreamObserver 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 responseObserver)

public void removeContextChildren(RemoveContextChildrenRequest request, StreamObserver 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 responseObserver)

public void updateArtifact(UpdateArtifactRequest request, StreamObserver responseObserver)

Updates a stored Artifact.

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

updateContext(UpdateContextRequest request, StreamObserver responseObserver)

public void updateContext(UpdateContextRequest request, StreamObserver responseObserver)

Updates a stored Context.

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

updateExecution(UpdateExecutionRequest request, StreamObserver responseObserver)

public void updateExecution(UpdateExecutionRequest request, StreamObserver responseObserver)

Updates a stored Execution.

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