Class DataProductServiceGrpc.DataProductServiceStub (1.86.0)

1.86.0 (latest) 1.85.0 1.83.0 1.81.0 1.80.0 1.79.0 1.78.0 1.76.0 1.74.0 1.73.0 1.72.0 1.71.0 1.70.0 1.68.0 1.66.0 1.65.0 1.62.0 1.61.0 1.60.0 1.58.0 1.57.0 1.56.0 1.55.0 1.54.0 1.53.0 1.52.0 1.51.0 1.50.0 1.49.0 1.47.0 1.46.0 1.45.0 1.44.0 1.43.0 1.42.0 1.41.0 1.40.0 1.39.0 1.38.0 1.37.0 1.35.0 1.34.0 1.33.0 1.32.0 1.31.0 1.30.0 1.29.0 1.28.0 1.27.0 1.26.0 1.25.0 1.22.0 1.21.0 1.20.0 1.19.0 1.18.0 1.17.0 1.16.0 1.15.0 1.14.0 1.13.0 1.12.0 1.11.0 1.10.0 1.9.0 1.7.0 1.6.0 1.5.0 1.4.0 1.3.0 1.2.0 1.1.2 1.0.1 0.2.2

public static final class DataProductServiceGrpc.DataProductServiceStub extends AbstractAsyncStub<DataProductServiceGrpc.DataProductServiceStub>

A stub to allow clients to do asynchronous rpc calls to service DataProductService.

DataProductService provides APIs for managing data products and the underlying data assets.

Inheritance

java.lang.Object > io.grpc.stub.AbstractStub > io.grpc.stub.AbstractAsyncStub > DataProductServiceGrpc.DataProductServiceStub

Inherited Members

io.grpc.stub.AbstractAsyncStub.<T>newStub(io.grpc.stub.AbstractStub.StubFactory<T>,io.grpc.Channel)

io.grpc.stub.AbstractAsyncStub.<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(java.time.Duration)

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.withOnReadyThreshold(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

build(Channel channel, CallOptions callOptions)

protected DataProductServiceGrpc.DataProductServiceStub build(Channel channel, CallOptions callOptions)

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

Returns
Type	Description
DataProductServiceGrpc.DataProductServiceStub

Overrides

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

createDataAsset(CreateDataAssetRequest request, StreamObserver<Operation> responseObserver)

public void createDataAsset(CreateDataAssetRequest request, StreamObserver<Operation> responseObserver)

Creates a data asset.

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

createDataProduct(CreateDataProductRequest request, StreamObserver<Operation> responseObserver)

public void createDataProduct(CreateDataProductRequest request, StreamObserver<Operation> responseObserver)

Creates a data product.

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

deleteDataAsset(DeleteDataAssetRequest request, StreamObserver<Operation> responseObserver)

public void deleteDataAsset(DeleteDataAssetRequest request, StreamObserver<Operation> responseObserver)

Deletes a data asset.

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

deleteDataProduct(DeleteDataProductRequest request, StreamObserver<Operation> responseObserver)

public void deleteDataProduct(DeleteDataProductRequest request, StreamObserver<Operation> responseObserver)

Deletes a data product. The deletion will fail if the data product is not empty (i.e. contains at least one data asset).

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

getDataAsset(GetDataAssetRequest request, StreamObserver<DataAsset> responseObserver)

public void getDataAsset(GetDataAssetRequest request, StreamObserver<DataAsset> responseObserver)

Gets a data asset.

Parameters
Name	Description
request	GetDataAssetRequest
responseObserver	io.grpc.stub.StreamObserver<DataAsset>

getDataProduct(GetDataProductRequest request, StreamObserver<DataProduct> responseObserver)

public void getDataProduct(GetDataProductRequest request, StreamObserver<DataProduct> responseObserver)

Gets a data product.

Parameters
Name	Description
request	GetDataProductRequest
responseObserver	io.grpc.stub.StreamObserver<DataProduct>

listDataAssets(ListDataAssetsRequest request, StreamObserver<ListDataAssetsResponse> responseObserver)

public void listDataAssets(ListDataAssetsRequest request, StreamObserver<ListDataAssetsResponse> responseObserver)

Lists data assets for a given data product.

Parameters
Name	Description
request	ListDataAssetsRequest
responseObserver	io.grpc.stub.StreamObserver<ListDataAssetsResponse>

listDataProducts(ListDataProductsRequest request, StreamObserver<ListDataProductsResponse> responseObserver)

public void listDataProducts(ListDataProductsRequest request, StreamObserver<ListDataProductsResponse> responseObserver)

Lists data products for a given project.

Parameters
Name	Description
request	ListDataProductsRequest
responseObserver	io.grpc.stub.StreamObserver<ListDataProductsResponse>

updateDataAsset(UpdateDataAssetRequest request, StreamObserver<Operation> responseObserver)

public void updateDataAsset(UpdateDataAssetRequest request, StreamObserver<Operation> responseObserver)

Updates a data asset.

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

updateDataProduct(UpdateDataProductRequest request, StreamObserver<Operation> responseObserver)

public void updateDataProduct(UpdateDataProductRequest request, StreamObserver<Operation> responseObserver)

Updates a data product.

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