public static final class MetadataServiceGrpc.MetadataServiceStub extends AbstractAsyncStub<MetadataServiceGrpc.MetadataServiceStub>
Service for reading and writing metadata entries.
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractAsyncStub >
MetadataServiceGrpc.MetadataServiceStub
Inherited Members
io.grpc.stub.AbstractAsyncStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractAsyncStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.<T>withOption(io.grpc.CallOptions.Key<T>,T)
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
io.grpc.stub.AbstractStub.getCallOptions()
io.grpc.stub.AbstractStub.getChannel()
io.grpc.stub.AbstractStub.withCallCredentials(io.grpc.CallCredentials)
io.grpc.stub.AbstractStub.withChannel(io.grpc.Channel)
io.grpc.stub.AbstractStub.withCompression(java.lang.String)
io.grpc.stub.AbstractStub.withDeadline(io.grpc.Deadline)
io.grpc.stub.AbstractStub.withDeadlineAfter(long,java.util.concurrent.TimeUnit)
io.grpc.stub.AbstractStub.withExecutor(java.util.concurrent.Executor)
io.grpc.stub.AbstractStub.withInterceptors(io.grpc.ClientInterceptor...)
io.grpc.stub.AbstractStub.withMaxInboundMessageSize(int)
io.grpc.stub.AbstractStub.withMaxOutboundMessageSize(int)
io.grpc.stub.AbstractStub.withWaitForReady()
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
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
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
protected MetadataServiceGrpc.MetadataServiceStub build(Channel channel, CallOptions callOptions)
Parameters
Name | Description |
channel | io.grpc.Channel
|
callOptions | io.grpc.CallOptions
|
Returns
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)
public void createArtifact(CreateArtifactRequest request, StreamObserver<Artifact> responseObserver)
Creates an Artifact associated with a MetadataStore.
Parameters
createContext(CreateContextRequest request, StreamObserver<Context> responseObserver)
public void createContext(CreateContextRequest request, StreamObserver<Context> responseObserver)
Creates a Context associated with a MetadataStore.
Parameters
public void createExecution(CreateExecutionRequest request, StreamObserver<Execution> responseObserver)
Creates an Execution associated with a MetadataStore.
Parameters
public void createMetadataSchema(CreateMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)
Creates a MetadataSchema.
Parameters
public void createMetadataStore(CreateMetadataStoreRequest request, StreamObserver<Operation> responseObserver)
Initializes a MetadataStore, including allocation of resources.
Parameters
public void deleteArtifact(DeleteArtifactRequest request, StreamObserver<Operation> responseObserver)
Parameters
deleteContext(DeleteContextRequest request, StreamObserver<Operation> responseObserver)
public void deleteContext(DeleteContextRequest request, StreamObserver<Operation> responseObserver)
Deletes a stored Context.
Parameters
public void deleteExecution(DeleteExecutionRequest request, StreamObserver<Operation> responseObserver)
Parameters
public void deleteMetadataStore(DeleteMetadataStoreRequest request, StreamObserver<Operation> responseObserver)
Deletes a single MetadataStore and all its child resources (Artifacts,
Executions, and Contexts).
Parameters
public void getArtifact(GetArtifactRequest request, StreamObserver<Artifact> responseObserver)
Retrieves a specific Artifact.
Parameters
getContext(GetContextRequest request, StreamObserver<Context> responseObserver)
public void getContext(GetContextRequest request, StreamObserver<Context> responseObserver)
Retrieves a specific Context.
Parameters
public void getExecution(GetExecutionRequest request, StreamObserver<Execution> responseObserver)
Retrieves a specific Execution.
Parameters
public void getMetadataSchema(GetMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)
Retrieves a specific MetadataSchema.
Parameters
public void getMetadataStore(GetMetadataStoreRequest request, StreamObserver<MetadataStore> responseObserver)
Retrieves a specific MetadataStore.
Parameters
public void listArtifacts(ListArtifactsRequest request, StreamObserver<ListArtifactsResponse> responseObserver)
Lists Artifacts in the MetadataStore.
Parameters
listContexts(ListContextsRequest request, StreamObserver<ListContextsResponse> responseObserver)
public void listContexts(ListContextsRequest request, StreamObserver<ListContextsResponse> responseObserver)
Lists Contexts on the MetadataStore.
Parameters
public void listExecutions(ListExecutionsRequest request, StreamObserver<ListExecutionsResponse> responseObserver)
Lists Executions in the MetadataStore.
Parameters
public void listMetadataSchemas(ListMetadataSchemasRequest request, StreamObserver<ListMetadataSchemasResponse> responseObserver)
Parameters
public void listMetadataStores(ListMetadataStoresRequest request, StreamObserver<ListMetadataStoresResponse> responseObserver)
Lists MetadataStores for a Location.
Parameters
public void purgeArtifacts(PurgeArtifactsRequest request, StreamObserver<Operation> responseObserver)
Parameters
purgeContexts(PurgeContextsRequest request, StreamObserver<Operation> responseObserver)
public void purgeContexts(PurgeContextsRequest request, StreamObserver<Operation> responseObserver)
Parameters
public void purgeExecutions(PurgeExecutionsRequest request, StreamObserver<Operation> responseObserver)
Parameters
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
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
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
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
public void updateArtifact(UpdateArtifactRequest request, StreamObserver<Artifact> responseObserver)
Updates a stored Artifact.
Parameters
updateContext(UpdateContextRequest request, StreamObserver<Context> responseObserver)
public void updateContext(UpdateContextRequest request, StreamObserver<Context> responseObserver)
Updates a stored Context.
Parameters
public void updateExecution(UpdateExecutionRequest request, StreamObserver<Execution> responseObserver)
Updates a stored Execution.
Parameters