Class MetadataServiceGrpc.MetadataServiceBlockingStub (3.16.0)

public static final class MetadataServiceGrpc.MetadataServiceBlockingStub extends AbstractBlockingStub<MetadataServiceGrpc.MetadataServiceBlockingStub>

A stub to allow clients to do synchronous rpc calls to service MetadataService.

Service for reading and writing metadata entries.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractBlockingStub > MetadataServiceGrpc.MetadataServiceBlockingStub

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
NameDescription
requestAddContextArtifactsAndExecutionsRequest
Returns
TypeDescription
AddContextArtifactsAndExecutionsResponse

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
NameDescription
requestAddContextChildrenRequest
Returns
TypeDescription
AddContextChildrenResponse

addExecutionEvents(AddExecutionEventsRequest request)

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
NameDescription
requestAddExecutionEventsRequest
Returns
TypeDescription
AddExecutionEventsResponse

build(Channel channel, CallOptions callOptions)

protected MetadataServiceGrpc.MetadataServiceBlockingStub build(Channel channel, CallOptions callOptions)
Parameters
NameDescription
channelio.grpc.Channel
callOptionsio.grpc.CallOptions
Returns
TypeDescription
MetadataServiceGrpc.MetadataServiceBlockingStub
Overrides
io.grpc.stub.AbstractStub.build(io.grpc.Channel,io.grpc.CallOptions)

createArtifact(CreateArtifactRequest request)

public Artifact createArtifact(CreateArtifactRequest request)

Creates an Artifact associated with a MetadataStore.

Parameter
NameDescription
requestCreateArtifactRequest
Returns
TypeDescription
Artifact

createContext(CreateContextRequest request)

public Context createContext(CreateContextRequest request)

Creates a Context associated with a MetadataStore.

Parameter
NameDescription
requestCreateContextRequest
Returns
TypeDescription
Context

createExecution(CreateExecutionRequest request)

public Execution createExecution(CreateExecutionRequest request)

Creates an Execution associated with a MetadataStore.

Parameter
NameDescription
requestCreateExecutionRequest
Returns
TypeDescription
Execution

createMetadataSchema(CreateMetadataSchemaRequest request)

public MetadataSchema createMetadataSchema(CreateMetadataSchemaRequest request)

Creates a MetadataSchema.

Parameter
NameDescription
requestCreateMetadataSchemaRequest
Returns
TypeDescription
MetadataSchema

createMetadataStore(CreateMetadataStoreRequest request)

public Operation createMetadataStore(CreateMetadataStoreRequest request)

Initializes a MetadataStore, including allocation of resources.

Parameter
NameDescription
requestCreateMetadataStoreRequest
Returns
TypeDescription
Operation

deleteArtifact(DeleteArtifactRequest request)

public Operation deleteArtifact(DeleteArtifactRequest request)

Deletes an Artifact.

Parameter
NameDescription
requestDeleteArtifactRequest
Returns
TypeDescription
Operation

deleteContext(DeleteContextRequest request)

public Operation deleteContext(DeleteContextRequest request)

Deletes a stored Context.

Parameter
NameDescription
requestDeleteContextRequest
Returns
TypeDescription
Operation

deleteExecution(DeleteExecutionRequest request)

public Operation deleteExecution(DeleteExecutionRequest request)

Deletes an Execution.

Parameter
NameDescription
requestDeleteExecutionRequest
Returns
TypeDescription
Operation

deleteMetadataStore(DeleteMetadataStoreRequest request)

public Operation deleteMetadataStore(DeleteMetadataStoreRequest request)

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

Parameter
NameDescription
requestDeleteMetadataStoreRequest
Returns
TypeDescription
Operation

getArtifact(GetArtifactRequest request)

public Artifact getArtifact(GetArtifactRequest request)

Retrieves a specific Artifact.

Parameter
NameDescription
requestGetArtifactRequest
Returns
TypeDescription
Artifact

getContext(GetContextRequest request)

public Context getContext(GetContextRequest request)

Retrieves a specific Context.

Parameter
NameDescription
requestGetContextRequest
Returns
TypeDescription
Context

getExecution(GetExecutionRequest request)

public Execution getExecution(GetExecutionRequest request)

Retrieves a specific Execution.

Parameter
NameDescription
requestGetExecutionRequest
Returns
TypeDescription
Execution

getMetadataSchema(GetMetadataSchemaRequest request)

public MetadataSchema getMetadataSchema(GetMetadataSchemaRequest request)

Retrieves a specific MetadataSchema.

Parameter
NameDescription
requestGetMetadataSchemaRequest
Returns
TypeDescription
MetadataSchema

getMetadataStore(GetMetadataStoreRequest request)

public MetadataStore getMetadataStore(GetMetadataStoreRequest request)

Retrieves a specific MetadataStore.

Parameter
NameDescription
requestGetMetadataStoreRequest
Returns
TypeDescription
MetadataStore

listArtifacts(ListArtifactsRequest request)

public ListArtifactsResponse listArtifacts(ListArtifactsRequest request)

Lists Artifacts in the MetadataStore.

Parameter
NameDescription
requestListArtifactsRequest
Returns
TypeDescription
ListArtifactsResponse

listContexts(ListContextsRequest request)

public ListContextsResponse listContexts(ListContextsRequest request)

Lists Contexts on the MetadataStore.

Parameter
NameDescription
requestListContextsRequest
Returns
TypeDescription
ListContextsResponse

listExecutions(ListExecutionsRequest request)

public ListExecutionsResponse listExecutions(ListExecutionsRequest request)

Lists Executions in the MetadataStore.

Parameter
NameDescription
requestListExecutionsRequest
Returns
TypeDescription
ListExecutionsResponse

listMetadataSchemas(ListMetadataSchemasRequest request)

public ListMetadataSchemasResponse listMetadataSchemas(ListMetadataSchemasRequest request)

Lists MetadataSchemas.

Parameter
NameDescription
requestListMetadataSchemasRequest
Returns
TypeDescription
ListMetadataSchemasResponse

listMetadataStores(ListMetadataStoresRequest request)

public ListMetadataStoresResponse listMetadataStores(ListMetadataStoresRequest request)

Lists MetadataStores for a Location.

Parameter
NameDescription
requestListMetadataStoresRequest
Returns
TypeDescription
ListMetadataStoresResponse

purgeArtifacts(PurgeArtifactsRequest request)

public Operation purgeArtifacts(PurgeArtifactsRequest request)

Purges Artifacts.

Parameter
NameDescription
requestPurgeArtifactsRequest
Returns
TypeDescription
Operation

purgeContexts(PurgeContextsRequest request)

public Operation purgeContexts(PurgeContextsRequest request)

Purges Contexts.

Parameter
NameDescription
requestPurgeContextsRequest
Returns
TypeDescription
Operation

purgeExecutions(PurgeExecutionsRequest request)

public Operation purgeExecutions(PurgeExecutionsRequest request)

Purges Executions.

Parameter
NameDescription
requestPurgeExecutionsRequest
Returns
TypeDescription
Operation

queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request)

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
NameDescription
requestQueryArtifactLineageSubgraphRequest
Returns
TypeDescription
LineageSubgraph

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
NameDescription
requestQueryContextLineageSubgraphRequest
Returns
TypeDescription
LineageSubgraph

queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request)

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
NameDescription
requestQueryExecutionInputsAndOutputsRequest
Returns
TypeDescription
LineageSubgraph

removeContextChildren(RemoveContextChildrenRequest request)

public 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
NameDescription
requestRemoveContextChildrenRequest
Returns
TypeDescription
RemoveContextChildrenResponse

updateArtifact(UpdateArtifactRequest request)

public Artifact updateArtifact(UpdateArtifactRequest request)

Updates a stored Artifact.

Parameter
NameDescription
requestUpdateArtifactRequest
Returns
TypeDescription
Artifact

updateContext(UpdateContextRequest request)

public Context updateContext(UpdateContextRequest request)

Updates a stored Context.

Parameter
NameDescription
requestUpdateContextRequest
Returns
TypeDescription
Context

updateExecution(UpdateExecutionRequest request)

public Execution updateExecution(UpdateExecutionRequest request)

Updates a stored Execution.

Parameter
NameDescription
requestUpdateExecutionRequest
Returns
TypeDescription
Execution