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