Class MetadataServiceGrpc.MetadataServiceImplBase (3.8.0)

public abstract static class MetadataServiceGrpc.MetadataServiceImplBase implements BindableService

Service for reading and writing metadata entries.

Inheritance

java.lang.Object > MetadataServiceGrpc.MetadataServiceImplBase

Implements

io.grpc.BindableService

Constructors

MetadataServiceImplBase()

public MetadataServiceImplBase()

Methods

addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request, StreamObserver<AddContextArtifactsAndExecutionsResponse> responseObserver)

public 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
NameDescription
requestAddContextArtifactsAndExecutionsRequest
responseObserverio.grpc.stub.StreamObserver<AddContextArtifactsAndExecutionsResponse>

addContextChildren(AddContextChildrenRequest request, StreamObserver<AddContextChildrenResponse> responseObserver)

public 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
NameDescription
requestAddContextChildrenRequest
responseObserverio.grpc.stub.StreamObserver<AddContextChildrenResponse>

addExecutionEvents(AddExecutionEventsRequest request, StreamObserver<AddExecutionEventsResponse> responseObserver)

public 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
NameDescription
requestAddExecutionEventsRequest
responseObserverio.grpc.stub.StreamObserver<AddExecutionEventsResponse>

bindService()

public final ServerServiceDefinition bindService()
Returns
TypeDescription
io.grpc.ServerServiceDefinition

createArtifact(CreateArtifactRequest request, StreamObserver<Artifact> responseObserver)

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

Creates an Artifact associated with a MetadataStore.

Parameters
NameDescription
requestCreateArtifactRequest
responseObserverio.grpc.stub.StreamObserver<Artifact>

createContext(CreateContextRequest request, StreamObserver<Context> responseObserver)

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

Creates a Context associated with a MetadataStore.

Parameters
NameDescription
requestCreateContextRequest
responseObserverio.grpc.stub.StreamObserver<Context>

createExecution(CreateExecutionRequest request, StreamObserver<Execution> responseObserver)

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

Creates an Execution associated with a MetadataStore.

Parameters
NameDescription
requestCreateExecutionRequest
responseObserverio.grpc.stub.StreamObserver<Execution>

createMetadataSchema(CreateMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)

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

Creates a MetadataSchema.

Parameters
NameDescription
requestCreateMetadataSchemaRequest
responseObserverio.grpc.stub.StreamObserver<MetadataSchema>

createMetadataStore(CreateMetadataStoreRequest request, StreamObserver<Operation> responseObserver)

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

Initializes a MetadataStore, including allocation of resources.

Parameters
NameDescription
requestCreateMetadataStoreRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

deleteArtifact(DeleteArtifactRequest request, StreamObserver<Operation> responseObserver)

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

Deletes an Artifact.

Parameters
NameDescription
requestDeleteArtifactRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

deleteContext(DeleteContextRequest request, StreamObserver<Operation> responseObserver)

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

Deletes a stored Context.

Parameters
NameDescription
requestDeleteContextRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

deleteExecution(DeleteExecutionRequest request, StreamObserver<Operation> responseObserver)

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

Deletes an Execution.

Parameters
NameDescription
requestDeleteExecutionRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

deleteMetadataStore(DeleteMetadataStoreRequest request, StreamObserver<Operation> responseObserver)

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

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

Parameters
NameDescription
requestDeleteMetadataStoreRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

getArtifact(GetArtifactRequest request, StreamObserver<Artifact> responseObserver)

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

Retrieves a specific Artifact.

Parameters
NameDescription
requestGetArtifactRequest
responseObserverio.grpc.stub.StreamObserver<Artifact>

getContext(GetContextRequest request, StreamObserver<Context> responseObserver)

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

Retrieves a specific Context.

Parameters
NameDescription
requestGetContextRequest
responseObserverio.grpc.stub.StreamObserver<Context>

getExecution(GetExecutionRequest request, StreamObserver<Execution> responseObserver)

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

Retrieves a specific Execution.

Parameters
NameDescription
requestGetExecutionRequest
responseObserverio.grpc.stub.StreamObserver<Execution>

getMetadataSchema(GetMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)

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

Retrieves a specific MetadataSchema.

Parameters
NameDescription
requestGetMetadataSchemaRequest
responseObserverio.grpc.stub.StreamObserver<MetadataSchema>

getMetadataStore(GetMetadataStoreRequest request, StreamObserver<MetadataStore> responseObserver)

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

Retrieves a specific MetadataStore.

Parameters
NameDescription
requestGetMetadataStoreRequest
responseObserverio.grpc.stub.StreamObserver<MetadataStore>

listArtifacts(ListArtifactsRequest request, StreamObserver<ListArtifactsResponse> responseObserver)

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

Lists Artifacts in the MetadataStore.

Parameters
NameDescription
requestListArtifactsRequest
responseObserverio.grpc.stub.StreamObserver<ListArtifactsResponse>

listContexts(ListContextsRequest request, StreamObserver<ListContextsResponse> responseObserver)

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

Lists Contexts on the MetadataStore.

Parameters
NameDescription
requestListContextsRequest
responseObserverio.grpc.stub.StreamObserver<ListContextsResponse>

listExecutions(ListExecutionsRequest request, StreamObserver<ListExecutionsResponse> responseObserver)

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

Lists Executions in the MetadataStore.

Parameters
NameDescription
requestListExecutionsRequest
responseObserverio.grpc.stub.StreamObserver<ListExecutionsResponse>

listMetadataSchemas(ListMetadataSchemasRequest request, StreamObserver<ListMetadataSchemasResponse> responseObserver)

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

Lists MetadataSchemas.

Parameters
NameDescription
requestListMetadataSchemasRequest
responseObserverio.grpc.stub.StreamObserver<ListMetadataSchemasResponse>

listMetadataStores(ListMetadataStoresRequest request, StreamObserver<ListMetadataStoresResponse> responseObserver)

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

Lists MetadataStores for a Location.

Parameters
NameDescription
requestListMetadataStoresRequest
responseObserverio.grpc.stub.StreamObserver<ListMetadataStoresResponse>

purgeArtifacts(PurgeArtifactsRequest request, StreamObserver<Operation> responseObserver)

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

Purges Artifacts.

Parameters
NameDescription
requestPurgeArtifactsRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

purgeContexts(PurgeContextsRequest request, StreamObserver<Operation> responseObserver)

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

Purges Contexts.

Parameters
NameDescription
requestPurgeContextsRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

purgeExecutions(PurgeExecutionsRequest request, StreamObserver<Operation> responseObserver)

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

Purges Executions.

Parameters
NameDescription
requestPurgeExecutionsRequest
responseObserverio.grpc.stub.StreamObserver<Operation>

queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request, StreamObserver<LineageSubgraph> responseObserver)

public 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
NameDescription
requestQueryArtifactLineageSubgraphRequest
responseObserverio.grpc.stub.StreamObserver<LineageSubgraph>

queryContextLineageSubgraph(QueryContextLineageSubgraphRequest request, StreamObserver<LineageSubgraph> responseObserver)

public 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
NameDescription
requestQueryContextLineageSubgraphRequest
responseObserverio.grpc.stub.StreamObserver<LineageSubgraph>

queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request, StreamObserver<LineageSubgraph> responseObserver)

public 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
NameDescription
requestQueryExecutionInputsAndOutputsRequest
responseObserverio.grpc.stub.StreamObserver<LineageSubgraph>

removeContextChildren(RemoveContextChildrenRequest request, StreamObserver<RemoveContextChildrenResponse> responseObserver)

public 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
NameDescription
requestRemoveContextChildrenRequest
responseObserverio.grpc.stub.StreamObserver<RemoveContextChildrenResponse>

updateArtifact(UpdateArtifactRequest request, StreamObserver<Artifact> responseObserver)

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

Updates a stored Artifact.

Parameters
NameDescription
requestUpdateArtifactRequest
responseObserverio.grpc.stub.StreamObserver<Artifact>

updateContext(UpdateContextRequest request, StreamObserver<Context> responseObserver)

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

Updates a stored Context.

Parameters
NameDescription
requestUpdateContextRequest
responseObserverio.grpc.stub.StreamObserver<Context>

updateExecution(UpdateExecutionRequest request, StreamObserver<Execution> responseObserver)

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

Updates a stored Execution.

Parameters
NameDescription
requestUpdateExecutionRequest
responseObserverio.grpc.stub.StreamObserver<Execution>