public static final class MetadataServiceGrpc.MetadataServiceBlockingStub extends AbstractBlockingStub<MetadataServiceGrpc.MetadataServiceBlockingStub>
Service for reading and writing metadata entries.
Inheritance
java.lang.Object >
io.grpc.stub.AbstractStub >
io.grpc.stub.AbstractBlockingStub >
MetadataServiceGrpc.MetadataServiceBlockingStub
Inherited Members
io.grpc.stub.AbstractBlockingStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)
io.grpc.stub.AbstractBlockingStub.<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)
public AddContextArtifactsAndExecutionsResponse addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request)
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.
Parameter
Returns
addContextChildren(AddContextChildrenRequest request)
public AddContextChildrenResponse addContextChildren(AddContextChildrenRequest request)
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.
Parameter
Returns
public AddExecutionEventsResponse addExecutionEvents(AddExecutionEventsRequest request)
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.
Parameter
Returns
protected MetadataServiceGrpc.MetadataServiceBlockingStub 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 Artifact createArtifact(CreateArtifactRequest request)
Creates an Artifact associated with a MetadataStore.
Parameter
Returns
createContext(CreateContextRequest request)
public Context createContext(CreateContextRequest request)
Creates a Context associated with a MetadataStore.
Parameter
Returns
public Execution createExecution(CreateExecutionRequest request)
Creates an Execution associated with a MetadataStore.
Parameter
Returns
public MetadataSchema createMetadataSchema(CreateMetadataSchemaRequest request)
Creates a MetadataSchema.
Parameter
Returns
public Operation createMetadataStore(CreateMetadataStoreRequest request)
Initializes a MetadataStore, including allocation of resources.
Parameter
Returns
public Operation deleteArtifact(DeleteArtifactRequest request)
Parameter
Returns
deleteContext(DeleteContextRequest request)
public Operation deleteContext(DeleteContextRequest request)
Deletes a stored Context.
Parameter
Returns
public Operation deleteExecution(DeleteExecutionRequest request)
Parameter
Returns
public Operation deleteMetadataStore(DeleteMetadataStoreRequest request)
Deletes a single MetadataStore and all its child resources (Artifacts,
Executions, and Contexts).
Parameter
Returns
public Artifact getArtifact(GetArtifactRequest request)
Retrieves a specific Artifact.
Parameter
Returns
getContext(GetContextRequest request)
public Context getContext(GetContextRequest request)
Retrieves a specific Context.
Parameter
Returns
public Execution getExecution(GetExecutionRequest request)
Retrieves a specific Execution.
Parameter
Returns
public MetadataSchema getMetadataSchema(GetMetadataSchemaRequest request)
Retrieves a specific MetadataSchema.
Parameter
Returns
public MetadataStore getMetadataStore(GetMetadataStoreRequest request)
Retrieves a specific MetadataStore.
Parameter
Returns
public ListArtifactsResponse listArtifacts(ListArtifactsRequest request)
Lists Artifacts in the MetadataStore.
Parameter
Returns
listContexts(ListContextsRequest request)
public ListContextsResponse listContexts(ListContextsRequest request)
Lists Contexts on the MetadataStore.
Parameter
Returns
public ListExecutionsResponse listExecutions(ListExecutionsRequest request)
Lists Executions in the MetadataStore.
Parameter
Returns
public ListMetadataSchemasResponse listMetadataSchemas(ListMetadataSchemasRequest request)
Parameter
Returns
public ListMetadataStoresResponse listMetadataStores(ListMetadataStoresRequest request)
Lists MetadataStores for a Location.
Parameter
Returns
public Operation purgeArtifacts(PurgeArtifactsRequest request)
Parameter
Returns
purgeContexts(PurgeContextsRequest request)
public Operation purgeContexts(PurgeContextsRequest request)
Parameter
Returns
public Operation purgeExecutions(PurgeExecutionsRequest request)
Parameter
Returns
public LineageSubgraph queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request)
Retrieves lineage of an Artifact represented through Artifacts and
Executions connected by Event edges and returned as a LineageSubgraph.
Parameter
Returns
queryContextLineageSubgraph(QueryContextLineageSubgraphRequest request)
public LineageSubgraph queryContextLineageSubgraph(QueryContextLineageSubgraphRequest request)
Retrieves Artifacts and Executions within the specified Context, connected
by Event edges and returned as a LineageSubgraph.
Parameter
Returns
public LineageSubgraph queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request)
Obtains the set of input and output Artifacts for this Execution, in the
form of LineageSubgraph that also contains the Execution and connecting
Events.
Parameter
Returns
public Artifact updateArtifact(UpdateArtifactRequest request)
Updates a stored Artifact.
Parameter
Returns
updateContext(UpdateContextRequest request)
public Context updateContext(UpdateContextRequest request)
Updates a stored Context.
Parameter
Returns
public Execution updateExecution(UpdateExecutionRequest request)
Updates a stored Execution.
Parameter
Returns