- 3.64.0 (latest)
- 3.63.0
- 3.61.0
- 3.60.0
- 3.59.0
- 3.58.0
- 3.57.0
- 3.56.0
- 3.55.0
- 3.54.0
- 3.53.0
- 3.52.0
- 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 final class MetadataServiceGrpc.MetadataServiceStub extends AbstractAsyncStub.MetadataServiceStub> Service for reading and writing metadata entries.
Inheritance
java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractAsyncStub > MetadataServiceGrpc.MetadataServiceStubMethods
addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request, StreamObserver responseObserver)
public void addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request, StreamObserverAdds 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.
| Name | Description |
| request | AddContextArtifactsAndExecutionsRequest |
| responseObserver | io.grpc.stub.StreamObserver<AddContextArtifactsAndExecutionsResponse> |
addContextChildren(AddContextChildrenRequest request, StreamObserver responseObserver)
public void addContextChildren(AddContextChildrenRequest request, StreamObserverAdds 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.
| Name | Description |
| request | AddContextChildrenRequest |
| responseObserver | io.grpc.stub.StreamObserver<AddContextChildrenResponse> |
addExecutionEvents(AddExecutionEventsRequest request, StreamObserver responseObserver)
public void addExecutionEvents(AddExecutionEventsRequest request, StreamObserverAdds 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.
| Name | Description |
| request | AddExecutionEventsRequest |
| responseObserver | io.grpc.stub.StreamObserver<AddExecutionEventsResponse> |
build(Channel channel, CallOptions callOptions)
protected MetadataServiceGrpc.MetadataServiceStub build(Channel channel, CallOptions callOptions)| Name | Description |
| channel | io.grpc.Channel |
| callOptions | io.grpc.CallOptions |
| Type | Description |
| MetadataServiceGrpc.MetadataServiceStub |
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
createArtifact(CreateArtifactRequest request, StreamObserver responseObserver)
public void createArtifact(CreateArtifactRequest request, StreamObserverCreates an Artifact associated with a MetadataStore.
| Name | Description |
| request | CreateArtifactRequest |
| responseObserver | io.grpc.stub.StreamObserver<Artifact> |
createContext(CreateContextRequest request, StreamObserver responseObserver)
public void createContext(CreateContextRequest request, StreamObserverCreates a Context associated with a MetadataStore.
| Name | Description |
| request | CreateContextRequest |
| responseObserver | io.grpc.stub.StreamObserver<Context> |
createExecution(CreateExecutionRequest request, StreamObserver responseObserver)
public void createExecution(CreateExecutionRequest request, StreamObserverCreates an Execution associated with a MetadataStore.
| Name | Description |
| request | CreateExecutionRequest |
| responseObserver | io.grpc.stub.StreamObserver<Execution> |
createMetadataSchema(CreateMetadataSchemaRequest request, StreamObserver responseObserver)
public void createMetadataSchema(CreateMetadataSchemaRequest request, StreamObserverCreates a MetadataSchema.
| Name | Description |
| request | CreateMetadataSchemaRequest |
| responseObserver | io.grpc.stub.StreamObserver<MetadataSchema> |
createMetadataStore(CreateMetadataStoreRequest request, StreamObserver responseObserver)
public void createMetadataStore(CreateMetadataStoreRequest request, StreamObserverInitializes a MetadataStore, including allocation of resources.
| Name | Description |
| request | CreateMetadataStoreRequest |
| responseObserver | io.grpc.stub.StreamObserver<Operation> |
deleteArtifact(DeleteArtifactRequest request, StreamObserver responseObserver)
public void deleteArtifact(DeleteArtifactRequest request, StreamObserverDeletes an Artifact.
| Name | Description |
| request | DeleteArtifactRequest |
| responseObserver | io.grpc.stub.StreamObserver<Operation> |
deleteContext(DeleteContextRequest request, StreamObserver responseObserver)
public void deleteContext(DeleteContextRequest request, StreamObserverDeletes a stored Context.
| Name | Description |
| request | DeleteContextRequest |
| responseObserver | io.grpc.stub.StreamObserver<Operation> |
deleteExecution(DeleteExecutionRequest request, StreamObserver responseObserver)
public void deleteExecution(DeleteExecutionRequest request, StreamObserverDeletes an Execution.
| Name | Description |
| request | DeleteExecutionRequest |
| responseObserver | io.grpc.stub.StreamObserver<Operation> |
deleteMetadataStore(DeleteMetadataStoreRequest request, StreamObserver responseObserver)
public void deleteMetadataStore(DeleteMetadataStoreRequest request, StreamObserverDeletes a single MetadataStore and all its child resources (Artifacts, Executions, and Contexts).
| Name | Description |
| request | DeleteMetadataStoreRequest |
| responseObserver | io.grpc.stub.StreamObserver<Operation> |
getArtifact(GetArtifactRequest request, StreamObserver responseObserver)
public void getArtifact(GetArtifactRequest request, StreamObserverRetrieves a specific Artifact.
| Name | Description |
| request | GetArtifactRequest |
| responseObserver | io.grpc.stub.StreamObserver<Artifact> |
getContext(GetContextRequest request, StreamObserver responseObserver)
public void getContext(GetContextRequest request, StreamObserverRetrieves a specific Context.
| Name | Description |
| request | GetContextRequest |
| responseObserver | io.grpc.stub.StreamObserver<Context> |
getExecution(GetExecutionRequest request, StreamObserver responseObserver)
public void getExecution(GetExecutionRequest request, StreamObserverRetrieves a specific Execution.
| Name | Description |
| request | GetExecutionRequest |
| responseObserver | io.grpc.stub.StreamObserver<Execution> |
getMetadataSchema(GetMetadataSchemaRequest request, StreamObserver responseObserver)
public void getMetadataSchema(GetMetadataSchemaRequest request, StreamObserverRetrieves a specific MetadataSchema.
| Name | Description |
| request | GetMetadataSchemaRequest |
| responseObserver | io.grpc.stub.StreamObserver<MetadataSchema> |
getMetadataStore(GetMetadataStoreRequest request, StreamObserver responseObserver)
public void getMetadataStore(GetMetadataStoreRequest request, StreamObserverRetrieves a specific MetadataStore.
| Name | Description |
| request | GetMetadataStoreRequest |
| responseObserver | io.grpc.stub.StreamObserver<MetadataStore> |
listArtifacts(ListArtifactsRequest request, StreamObserver responseObserver)
public void listArtifacts(ListArtifactsRequest request, StreamObserverLists Artifacts in the MetadataStore.
| Name | Description |
| request | ListArtifactsRequest |
| responseObserver | io.grpc.stub.StreamObserver<ListArtifactsResponse> |
listContexts(ListContextsRequest request, StreamObserver responseObserver)
public void listContexts(ListContextsRequest request, StreamObserverLists Contexts on the MetadataStore.
| Name | Description |
| request | ListContextsRequest |
| responseObserver | io.grpc.stub.StreamObserver<ListContextsResponse> |
listExecutions(ListExecutionsRequest request, StreamObserver responseObserver)
public void listExecutions(ListExecutionsRequest request, StreamObserverLists Executions in the MetadataStore.
| Name | Description |
| request | ListExecutionsRequest |
| responseObserver | io.grpc.stub.StreamObserver<ListExecutionsResponse> |
listMetadataSchemas(ListMetadataSchemasRequest request, StreamObserver responseObserver)
public void listMetadataSchemas(ListMetadataSchemasRequest request, StreamObserverLists MetadataSchemas.
| Name | Description |
| request | ListMetadataSchemasRequest |
| responseObserver | io.grpc.stub.StreamObserver<ListMetadataSchemasResponse> |
listMetadataStores(ListMetadataStoresRequest request, StreamObserver responseObserver)
public void listMetadataStores(ListMetadataStoresRequest request, StreamObserverLists MetadataStores for a Location.
| Name | Description |
| request | ListMetadataStoresRequest |
| responseObserver | io.grpc.stub.StreamObserver<ListMetadataStoresResponse> |
purgeArtifacts(PurgeArtifactsRequest request, StreamObserver responseObserver)
public void purgeArtifacts(PurgeArtifactsRequest request, StreamObserverPurges Artifacts.
| Name | Description |
| request | PurgeArtifactsRequest |
| responseObserver | io.grpc.stub.StreamObserver<Operation> |
purgeContexts(PurgeContextsRequest request, StreamObserver responseObserver)
public void purgeContexts(PurgeContextsRequest request, StreamObserverPurges Contexts.
| Name | Description |
| request | PurgeContextsRequest |
| responseObserver | io.grpc.stub.StreamObserver<Operation> |
purgeExecutions(PurgeExecutionsRequest request, StreamObserver responseObserver)
public void purgeExecutions(PurgeExecutionsRequest request, StreamObserverPurges Executions.
| Name | Description |
| request | PurgeExecutionsRequest |
| responseObserver | io.grpc.stub.StreamObserver<Operation> |
queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request, StreamObserver responseObserver)
public void queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request, StreamObserverRetrieves lineage of an Artifact represented through Artifacts and Executions connected by Event edges and returned as a LineageSubgraph.
| Name | Description |
| request | QueryArtifactLineageSubgraphRequest |
| responseObserver | io.grpc.stub.StreamObserver<LineageSubgraph> |
queryContextLineageSubgraph(QueryContextLineageSubgraphRequest request, StreamObserver responseObserver)
public void queryContextLineageSubgraph(QueryContextLineageSubgraphRequest request, StreamObserverRetrieves Artifacts and Executions within the specified Context, connected by Event edges and returned as a LineageSubgraph.
| Name | Description |
| request | QueryContextLineageSubgraphRequest |
| responseObserver | io.grpc.stub.StreamObserver<LineageSubgraph> |
queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request, StreamObserver responseObserver)
public void queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request, StreamObserverObtains the set of input and output Artifacts for this Execution, in the form of LineageSubgraph that also contains the Execution and connecting Events.
| Name | Description |
| request | QueryExecutionInputsAndOutputsRequest |
| responseObserver | io.grpc.stub.StreamObserver<LineageSubgraph> |
updateArtifact(UpdateArtifactRequest request, StreamObserver responseObserver)
public void updateArtifact(UpdateArtifactRequest request, StreamObserverUpdates a stored Artifact.
| Name | Description |
| request | UpdateArtifactRequest |
| responseObserver | io.grpc.stub.StreamObserver<Artifact> |
updateContext(UpdateContextRequest request, StreamObserver responseObserver)
public void updateContext(UpdateContextRequest request, StreamObserverUpdates a stored Context.
| Name | Description |
| request | UpdateContextRequest |
| responseObserver | io.grpc.stub.StreamObserver<Context> |
updateExecution(UpdateExecutionRequest request, StreamObserver responseObserver)
public void updateExecution(UpdateExecutionRequest request, StreamObserverUpdates a stored Execution.
| Name | Description |
| request | UpdateExecutionRequest |
| responseObserver | io.grpc.stub.StreamObserver<Execution> |