Class MetadataServiceGrpc.MetadataServiceImplBase (3.6.0)

Version 3.6.0

• 3.52.0 (latest)
• 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 abstract static class MetadataServiceGrpc.MetadataServiceImplBase implements BindableService

Service for reading and writing metadata entries.

Inheritance

java.lang.Object > MetadataServiceGrpc.MetadataServiceImplBase

Implements

io.grpc.BindableService

Inherited Members

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)

Constructors

MetadataServiceImplBase()

public MetadataServiceImplBase()

Methods

addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request, StreamObserver<AddContextArtifactsAndExecutionsResponse> responseObserver)

public void addContextArtifactsAndExecutions(AddContextArtifactsAndExecutionsRequest request, StreamObserver<AddContextArtifactsAndExecutionsResponse> responseObserver)

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.

Parameters

Name	Description
request	AddContextArtifactsAndExecutionsRequest
responseObserver	io.grpc.stub.StreamObserver<AddContextArtifactsAndExecutionsResponse>

addContextChildren(AddContextChildrenRequest request, StreamObserver<AddContextChildrenResponse> responseObserver)

public void addContextChildren(AddContextChildrenRequest request, StreamObserver<AddContextChildrenResponse> responseObserver)

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.

Parameters

Name	Description
request	AddContextChildrenRequest
responseObserver	io.grpc.stub.StreamObserver<AddContextChildrenResponse>

addExecutionEvents(AddExecutionEventsRequest request, StreamObserver<AddExecutionEventsResponse> responseObserver)

public void addExecutionEvents(AddExecutionEventsRequest request, StreamObserver<AddExecutionEventsResponse> responseObserver)

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.

Parameters

Name	Description
request	AddExecutionEventsRequest
responseObserver	io.grpc.stub.StreamObserver<AddExecutionEventsResponse>

bindService()

public final ServerServiceDefinition bindService()

Returns

Type	Description
io.grpc.ServerServiceDefinition

createArtifact(CreateArtifactRequest request, StreamObserver<Artifact> responseObserver)

public void createArtifact(CreateArtifactRequest request, StreamObserver<Artifact> responseObserver)

Creates an Artifact associated with a MetadataStore.

Parameters

Name	Description
request	CreateArtifactRequest
responseObserver	io.grpc.stub.StreamObserver<Artifact>

createContext(CreateContextRequest request, StreamObserver<Context> responseObserver)

public void createContext(CreateContextRequest request, StreamObserver<Context> responseObserver)

Creates a Context associated with a MetadataStore.

Parameters

Name	Description
request	CreateContextRequest
responseObserver	io.grpc.stub.StreamObserver<Context>

createExecution(CreateExecutionRequest request, StreamObserver<Execution> responseObserver)

public void createExecution(CreateExecutionRequest request, StreamObserver<Execution> responseObserver)

Creates an Execution associated with a MetadataStore.

Parameters

Name	Description
request	CreateExecutionRequest
responseObserver	io.grpc.stub.StreamObserver<Execution>

createMetadataSchema(CreateMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)

public void createMetadataSchema(CreateMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)

Creates a MetadataSchema.

Parameters

Name	Description
request	CreateMetadataSchemaRequest
responseObserver	io.grpc.stub.StreamObserver<MetadataSchema>

createMetadataStore(CreateMetadataStoreRequest request, StreamObserver<Operation> responseObserver)

public void createMetadataStore(CreateMetadataStoreRequest request, StreamObserver<Operation> responseObserver)

Initializes a MetadataStore, including allocation of resources.

Parameters

Name	Description
request	CreateMetadataStoreRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

deleteArtifact(DeleteArtifactRequest request, StreamObserver<Operation> responseObserver)

public void deleteArtifact(DeleteArtifactRequest request, StreamObserver<Operation> responseObserver)

Deletes an Artifact.

Parameters

Name	Description
request	DeleteArtifactRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

deleteContext(DeleteContextRequest request, StreamObserver<Operation> responseObserver)

public void deleteContext(DeleteContextRequest request, StreamObserver<Operation> responseObserver)

Deletes a stored Context.

Parameters

Name	Description
request	DeleteContextRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

deleteExecution(DeleteExecutionRequest request, StreamObserver<Operation> responseObserver)

public void deleteExecution(DeleteExecutionRequest request, StreamObserver<Operation> responseObserver)

Deletes an Execution.

Parameters

Name	Description
request	DeleteExecutionRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

deleteMetadataStore(DeleteMetadataStoreRequest request, StreamObserver<Operation> responseObserver)

public void deleteMetadataStore(DeleteMetadataStoreRequest request, StreamObserver<Operation> responseObserver)

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

Parameters

Name	Description
request	DeleteMetadataStoreRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

getArtifact(GetArtifactRequest request, StreamObserver<Artifact> responseObserver)

public void getArtifact(GetArtifactRequest request, StreamObserver<Artifact> responseObserver)

Retrieves a specific Artifact.

Parameters

Name	Description
request	GetArtifactRequest
responseObserver	io.grpc.stub.StreamObserver<Artifact>

getContext(GetContextRequest request, StreamObserver<Context> responseObserver)

public void getContext(GetContextRequest request, StreamObserver<Context> responseObserver)

Retrieves a specific Context.

Parameters

Name	Description
request	GetContextRequest
responseObserver	io.grpc.stub.StreamObserver<Context>

getExecution(GetExecutionRequest request, StreamObserver<Execution> responseObserver)

public void getExecution(GetExecutionRequest request, StreamObserver<Execution> responseObserver)

Retrieves a specific Execution.

Parameters

Name	Description
request	GetExecutionRequest
responseObserver	io.grpc.stub.StreamObserver<Execution>

getMetadataSchema(GetMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)

public void getMetadataSchema(GetMetadataSchemaRequest request, StreamObserver<MetadataSchema> responseObserver)

Retrieves a specific MetadataSchema.

Parameters

Name	Description
request	GetMetadataSchemaRequest
responseObserver	io.grpc.stub.StreamObserver<MetadataSchema>

getMetadataStore(GetMetadataStoreRequest request, StreamObserver<MetadataStore> responseObserver)

public void getMetadataStore(GetMetadataStoreRequest request, StreamObserver<MetadataStore> responseObserver)

Retrieves a specific MetadataStore.

Parameters

Name	Description
request	GetMetadataStoreRequest
responseObserver	io.grpc.stub.StreamObserver<MetadataStore>

listArtifacts(ListArtifactsRequest request, StreamObserver<ListArtifactsResponse> responseObserver)

public void listArtifacts(ListArtifactsRequest request, StreamObserver<ListArtifactsResponse> responseObserver)

Lists Artifacts in the MetadataStore.

Parameters

Name	Description
request	ListArtifactsRequest
responseObserver	io.grpc.stub.StreamObserver<ListArtifactsResponse>

listContexts(ListContextsRequest request, StreamObserver<ListContextsResponse> responseObserver)

public void listContexts(ListContextsRequest request, StreamObserver<ListContextsResponse> responseObserver)

Lists Contexts on the MetadataStore.

Parameters

Name	Description
request	ListContextsRequest
responseObserver	io.grpc.stub.StreamObserver<ListContextsResponse>

listExecutions(ListExecutionsRequest request, StreamObserver<ListExecutionsResponse> responseObserver)

public void listExecutions(ListExecutionsRequest request, StreamObserver<ListExecutionsResponse> responseObserver)

Lists Executions in the MetadataStore.

Parameters

Name	Description
request	ListExecutionsRequest
responseObserver	io.grpc.stub.StreamObserver<ListExecutionsResponse>

listMetadataSchemas(ListMetadataSchemasRequest request, StreamObserver<ListMetadataSchemasResponse> responseObserver)

public void listMetadataSchemas(ListMetadataSchemasRequest request, StreamObserver<ListMetadataSchemasResponse> responseObserver)

Lists MetadataSchemas.

Parameters

Name	Description
request	ListMetadataSchemasRequest
responseObserver	io.grpc.stub.StreamObserver<ListMetadataSchemasResponse>

listMetadataStores(ListMetadataStoresRequest request, StreamObserver<ListMetadataStoresResponse> responseObserver)

public void listMetadataStores(ListMetadataStoresRequest request, StreamObserver<ListMetadataStoresResponse> responseObserver)

Lists MetadataStores for a Location.

Parameters

Name	Description
request	ListMetadataStoresRequest
responseObserver	io.grpc.stub.StreamObserver<ListMetadataStoresResponse>

purgeArtifacts(PurgeArtifactsRequest request, StreamObserver<Operation> responseObserver)

public void purgeArtifacts(PurgeArtifactsRequest request, StreamObserver<Operation> responseObserver)

Purges Artifacts.

Parameters

Name	Description
request	PurgeArtifactsRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

purgeContexts(PurgeContextsRequest request, StreamObserver<Operation> responseObserver)

public void purgeContexts(PurgeContextsRequest request, StreamObserver<Operation> responseObserver)

Purges Contexts.

Parameters

Name	Description
request	PurgeContextsRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

purgeExecutions(PurgeExecutionsRequest request, StreamObserver<Operation> responseObserver)

public void purgeExecutions(PurgeExecutionsRequest request, StreamObserver<Operation> responseObserver)

Purges Executions.

Parameters

Name	Description
request	PurgeExecutionsRequest
responseObserver	io.grpc.stub.StreamObserver<Operation>

queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request, StreamObserver<LineageSubgraph> responseObserver)

public void queryArtifactLineageSubgraph(QueryArtifactLineageSubgraphRequest request, StreamObserver<LineageSubgraph> responseObserver)

Retrieves lineage of an Artifact represented through Artifacts and Executions connected by Event edges and returned as a LineageSubgraph.

Parameters

Name	Description
request	QueryArtifactLineageSubgraphRequest
responseObserver	io.grpc.stub.StreamObserver<LineageSubgraph>

queryContextLineageSubgraph(QueryContextLineageSubgraphRequest request, StreamObserver<LineageSubgraph> responseObserver)

public void queryContextLineageSubgraph(QueryContextLineageSubgraphRequest request, StreamObserver<LineageSubgraph> responseObserver)

Retrieves Artifacts and Executions within the specified Context, connected by Event edges and returned as a LineageSubgraph.

Parameters

Name	Description
request	QueryContextLineageSubgraphRequest
responseObserver	io.grpc.stub.StreamObserver<LineageSubgraph>

queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request, StreamObserver<LineageSubgraph> responseObserver)

public void queryExecutionInputsAndOutputs(QueryExecutionInputsAndOutputsRequest request, StreamObserver<LineageSubgraph> responseObserver)

Obtains the set of input and output Artifacts for this Execution, in the form of LineageSubgraph that also contains the Execution and connecting Events.

Parameters

Name	Description
request	QueryExecutionInputsAndOutputsRequest
responseObserver	io.grpc.stub.StreamObserver<LineageSubgraph>

removeContextChildren(RemoveContextChildrenRequest request, StreamObserver<RemoveContextChildrenResponse> responseObserver)

public void removeContextChildren(RemoveContextChildrenRequest request, StreamObserver<RemoveContextChildrenResponse> responseObserver)

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.

Parameters

Name	Description
request	RemoveContextChildrenRequest
responseObserver	io.grpc.stub.StreamObserver<RemoveContextChildrenResponse>

updateArtifact(UpdateArtifactRequest request, StreamObserver<Artifact> responseObserver)

public void updateArtifact(UpdateArtifactRequest request, StreamObserver<Artifact> responseObserver)

Updates a stored Artifact.

Parameters

Name	Description
request	UpdateArtifactRequest
responseObserver	io.grpc.stub.StreamObserver<Artifact>

updateContext(UpdateContextRequest request, StreamObserver<Context> responseObserver)

public void updateContext(UpdateContextRequest request, StreamObserver<Context> responseObserver)

Updates a stored Context.

Parameters

Name	Description
request	UpdateContextRequest
responseObserver	io.grpc.stub.StreamObserver<Context>

updateExecution(UpdateExecutionRequest request, StreamObserver<Execution> responseObserver)

public void updateExecution(UpdateExecutionRequest request, StreamObserver<Execution> responseObserver)

Updates a stored Execution.

Parameters

Name	Description
request	UpdateExecutionRequest
responseObserver	io.grpc.stub.StreamObserver<Execution>