Class MetadataServiceGrpc.MetadataServiceFutureStub (3.4.0)

Version 3.4.0

• 3.55.0 (latest)
• 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.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()

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>