Class MetadataServiceGrpc.MetadataServiceFutureStub (3.22.0)

public static final class MetadataServiceGrpc.MetadataServiceFutureStub extends AbstractFutureStub<MetadataServiceGrpc.MetadataServiceFutureStub>

A stub to allow clients to do ListenableFuture-style rpc calls to service MetadataService.

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()

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

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.

Parameter
Name	Description
`request`	`AddContextArtifactsAndExecutionsRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<AddContextArtifactsAndExecutionsResponse>`

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.

Parameter
Name	Description
`request`	`AddContextChildrenRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<AddContextChildrenResponse>`

addExecutionEvents(AddExecutionEventsRequest request)

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.

Parameter
Name	Description
`request`	`AddExecutionEventsRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<AddExecutionEventsResponse>`

build(Channel channel, CallOptions callOptions)

protected MetadataServiceGrpc.MetadataServiceFutureStub build(Channel channel, CallOptions callOptions)

Parameters
Name	Description
`channel`	`io.grpc.Channel`
`callOptions`	`io.grpc.CallOptions`

Returns
Type	Description
`MetadataServiceGrpc.MetadataServiceFutureStub`

Overrides

io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

createArtifact(CreateArtifactRequest request)

public ListenableFuture<Artifact> createArtifact(CreateArtifactRequest request)

Creates an Artifact associated with a MetadataStore.

Parameter
Name	Description
`request`	`CreateArtifactRequest`

Returns
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.

Parameter
Name	Description
`request`	`CreateContextRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Context>`

createExecution(CreateExecutionRequest request)

public ListenableFuture<Execution> createExecution(CreateExecutionRequest request)

Creates an Execution associated with a MetadataStore.

Parameter
Name	Description
`request`	`CreateExecutionRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Execution>`

createMetadataSchema(CreateMetadataSchemaRequest request)

public ListenableFuture<MetadataSchema> createMetadataSchema(CreateMetadataSchemaRequest request)

Creates a MetadataSchema.

Parameter
Name	Description
`request`	`CreateMetadataSchemaRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<MetadataSchema>`

createMetadataStore(CreateMetadataStoreRequest request)

public ListenableFuture<Operation> createMetadataStore(CreateMetadataStoreRequest request)

Initializes a MetadataStore, including allocation of resources.

Parameter
Name	Description
`request`	`CreateMetadataStoreRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Operation>`

deleteArtifact(DeleteArtifactRequest request)

public ListenableFuture<Operation> deleteArtifact(DeleteArtifactRequest request)

Deletes an Artifact.

Parameter
Name	Description
`request`	`DeleteArtifactRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Operation>`

deleteContext(DeleteContextRequest request)

public ListenableFuture<Operation> deleteContext(DeleteContextRequest request)

Deletes a stored Context.

Parameter
Name	Description
`request`	`DeleteContextRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Operation>`

deleteExecution(DeleteExecutionRequest request)

public ListenableFuture<Operation> deleteExecution(DeleteExecutionRequest request)

Deletes an Execution.

Parameter
Name	Description
`request`	`DeleteExecutionRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Operation>`

deleteMetadataStore(DeleteMetadataStoreRequest request)

public ListenableFuture<Operation> deleteMetadataStore(DeleteMetadataStoreRequest request)

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

Parameter
Name	Description
`request`	`DeleteMetadataStoreRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Operation>`

getArtifact(GetArtifactRequest request)

public ListenableFuture<Artifact> getArtifact(GetArtifactRequest request)

Retrieves a specific Artifact.

Parameter
Name	Description
`request`	`GetArtifactRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Artifact>`

getContext(GetContextRequest request)

public ListenableFuture<Context> getContext(GetContextRequest request)

Retrieves a specific Context.

Parameter
Name	Description
`request`	`GetContextRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Context>`

getExecution(GetExecutionRequest request)

public ListenableFuture<Execution> getExecution(GetExecutionRequest request)

Retrieves a specific Execution.

Parameter
Name	Description
`request`	`GetExecutionRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Execution>`

getMetadataSchema(GetMetadataSchemaRequest request)

public ListenableFuture<MetadataSchema> getMetadataSchema(GetMetadataSchemaRequest request)

Retrieves a specific MetadataSchema.

Parameter
Name	Description
`request`	`GetMetadataSchemaRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<MetadataSchema>`

getMetadataStore(GetMetadataStoreRequest request)

public ListenableFuture<MetadataStore> getMetadataStore(GetMetadataStoreRequest request)

Retrieves a specific MetadataStore.

Parameter
Name	Description
`request`	`GetMetadataStoreRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<MetadataStore>`

listArtifacts(ListArtifactsRequest request)

public ListenableFuture<ListArtifactsResponse> listArtifacts(ListArtifactsRequest request)

Lists Artifacts in the MetadataStore.

Parameter
Name	Description
`request`	`ListArtifactsRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<ListArtifactsResponse>`

listContexts(ListContextsRequest request)

public ListenableFuture<ListContextsResponse> listContexts(ListContextsRequest request)

Lists Contexts on the MetadataStore.

Parameter
Name	Description
`request`	`ListContextsRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<ListContextsResponse>`

listExecutions(ListExecutionsRequest request)

public ListenableFuture<ListExecutionsResponse> listExecutions(ListExecutionsRequest request)

Lists Executions in the MetadataStore.

Parameter
Name	Description
`request`	`ListExecutionsRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<ListExecutionsResponse>`

listMetadataSchemas(ListMetadataSchemasRequest request)

public ListenableFuture<ListMetadataSchemasResponse> listMetadataSchemas(ListMetadataSchemasRequest request)

Lists MetadataSchemas.

Parameter
Name	Description
`request`	`ListMetadataSchemasRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<ListMetadataSchemasResponse>`

listMetadataStores(ListMetadataStoresRequest request)

public ListenableFuture<ListMetadataStoresResponse> listMetadataStores(ListMetadataStoresRequest request)

Lists MetadataStores for a Location.

Parameter
Name	Description
`request`	`ListMetadataStoresRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<ListMetadataStoresResponse>`

purgeArtifacts(PurgeArtifactsRequest request)

public ListenableFuture<Operation> purgeArtifacts(PurgeArtifactsRequest request)

Purges Artifacts.

Parameter
Name	Description
`request`	`PurgeArtifactsRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Operation>`

purgeContexts(PurgeContextsRequest request)

public ListenableFuture<Operation> purgeContexts(PurgeContextsRequest request)

Purges Contexts.

Parameter
Name	Description
`request`	`PurgeContextsRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Operation>`

purgeExecutions(PurgeExecutionsRequest request)

public ListenableFuture<Operation> purgeExecutions(PurgeExecutionsRequest request)

Purges Executions.

Parameter
Name	Description
`request`	`PurgeExecutionsRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Operation>`

queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request)

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.

Parameter
Name	Description
`request`	`QueryArtifactLineageSubgraphRequest`

Returns
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.

Parameter
Name	Description
`request`	`QueryContextLineageSubgraphRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<LineageSubgraph>`

queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request)

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.

Parameter
Name	Description
`request`	`QueryExecutionInputsAndOutputsRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<LineageSubgraph>`

removeContextChildren(RemoveContextChildrenRequest request)

public ListenableFuture<RemoveContextChildrenResponse> removeContextChildren(RemoveContextChildrenRequest request)

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.

Parameter
Name	Description
`request`	`RemoveContextChildrenRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<RemoveContextChildrenResponse>`

updateArtifact(UpdateArtifactRequest request)

public ListenableFuture<Artifact> updateArtifact(UpdateArtifactRequest request)

Updates a stored Artifact.

Parameter
Name	Description
`request`	`UpdateArtifactRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Artifact>`

updateContext(UpdateContextRequest request)

public ListenableFuture<Context> updateContext(UpdateContextRequest request)

Updates a stored Context.

Parameter
Name	Description
`request`	`UpdateContextRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Context>`

updateExecution(UpdateExecutionRequest request)

public ListenableFuture<Execution> updateExecution(UpdateExecutionRequest request)

Updates a stored Execution.

Parameter
Name	Description
`request`	`UpdateExecutionRequest`

Returns
Type	Description
`com.google.common.util.concurrent.ListenableFuture<Execution>`