public abstract static class AnalyticsHubServiceGrpc.AnalyticsHubServiceImplBase implements BindableService
The AnalyticsHubService API facilitates data sharing within and across organizations. It allows data providers to publish Listings --- a discoverable and searchable SKU representing a dataset. Data consumers can subscribe to Listings. Upon subscription, AnalyticsHub provisions a "Linked Datasets" surfacing the data in the consumer's project.
Implements
io.grpc.BindableServiceConstructors
AnalyticsHubServiceImplBase()
public AnalyticsHubServiceImplBase()
Methods
bindService()
public final ServerServiceDefinition bindService()
Type | Description |
io.grpc.ServerServiceDefinition |
createDataExchange(CreateDataExchangeRequest request, StreamObserver<DataExchange> responseObserver)
public void createDataExchange(CreateDataExchangeRequest request, StreamObserver<DataExchange> responseObserver)
Creates a new DataExchange in a given project and location.
Name | Description |
request | CreateDataExchangeRequest |
responseObserver | io.grpc.stub.StreamObserver<DataExchange> |
createListing(CreateListingRequest request, StreamObserver<Listing> responseObserver)
public void createListing(CreateListingRequest request, StreamObserver<Listing> responseObserver)
Creates a new Listing in a given project and location.
Name | Description |
request | CreateListingRequest |
responseObserver | io.grpc.stub.StreamObserver<Listing> |
deleteDataExchange(DeleteDataExchangeRequest request, StreamObserver<Empty> responseObserver)
public void deleteDataExchange(DeleteDataExchangeRequest request, StreamObserver<Empty> responseObserver)
Deletes a single DataExchange.
Name | Description |
request | DeleteDataExchangeRequest |
responseObserver | io.grpc.stub.StreamObserver<Empty> |
deleteListing(DeleteListingRequest request, StreamObserver<Empty> responseObserver)
public void deleteListing(DeleteListingRequest request, StreamObserver<Empty> responseObserver)
Deletes a single Listing, as long as there are no subscriptions associated with the source of this Listing.
Name | Description |
request | DeleteListingRequest |
responseObserver | io.grpc.stub.StreamObserver<Empty> |
getDataExchange(GetDataExchangeRequest request, StreamObserver<DataExchange> responseObserver)
public void getDataExchange(GetDataExchangeRequest request, StreamObserver<DataExchange> responseObserver)
Gets details of a single DataExchange.
Name | Description |
request | GetDataExchangeRequest |
responseObserver | io.grpc.stub.StreamObserver<DataExchange> |
getIamPolicy(GetIamPolicyRequest request, StreamObserver<Policy> responseObserver)
public void getIamPolicy(GetIamPolicyRequest request, StreamObserver<Policy> responseObserver)
Gets the IAM policy for a dataExchange or a listing.
Name | Description |
request | com.google.iam.v1.GetIamPolicyRequest |
responseObserver | io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> |
getListing(GetListingRequest request, StreamObserver<Listing> responseObserver)
public void getListing(GetListingRequest request, StreamObserver<Listing> responseObserver)
Gets details of a single Listing.
Name | Description |
request | GetListingRequest |
responseObserver | io.grpc.stub.StreamObserver<Listing> |
listDataExchanges(ListDataExchangesRequest request, StreamObserver<ListDataExchangesResponse> responseObserver)
public void listDataExchanges(ListDataExchangesRequest request, StreamObserver<ListDataExchangesResponse> responseObserver)
Lists DataExchanges in a given project and location.
Name | Description |
request | ListDataExchangesRequest |
responseObserver | io.grpc.stub.StreamObserver<ListDataExchangesResponse> |
listListings(ListListingsRequest request, StreamObserver<ListListingsResponse> responseObserver)
public void listListings(ListListingsRequest request, StreamObserver<ListListingsResponse> responseObserver)
Lists Listings in a given project and location.
Name | Description |
request | ListListingsRequest |
responseObserver | io.grpc.stub.StreamObserver<ListListingsResponse> |
listOrgDataExchanges(ListOrgDataExchangesRequest request, StreamObserver<ListOrgDataExchangesResponse> responseObserver)
public void listOrgDataExchanges(ListOrgDataExchangesRequest request, StreamObserver<ListOrgDataExchangesResponse> responseObserver)
Lists DataExchanges from projects in a given organization and location.
Name | Description |
request | ListOrgDataExchangesRequest |
responseObserver | io.grpc.stub.StreamObserver<ListOrgDataExchangesResponse> |
setIamPolicy(SetIamPolicyRequest request, StreamObserver<Policy> responseObserver)
public void setIamPolicy(SetIamPolicyRequest request, StreamObserver<Policy> responseObserver)
Sets the IAM policy for a dataExchange or a listing.
Name | Description |
request | com.google.iam.v1.SetIamPolicyRequest |
responseObserver | io.grpc.stub.StreamObserver<com.google.iam.v1.Policy> |
subscribeListing(SubscribeListingRequest request, StreamObserver<SubscribeListingResponse> responseObserver)
public void subscribeListing(SubscribeListingRequest request, StreamObserver<SubscribeListingResponse> responseObserver)
Subscribes to a single Listing. Data Exchange currently supports one type of Listing: a BigQuery dataset. Upon subscription to a Listing for a BigQuery dataset, Data Exchange creates a linked dataset in the subscriber's project.
Name | Description |
request | SubscribeListingRequest |
responseObserver | io.grpc.stub.StreamObserver<SubscribeListingResponse> |
testIamPermissions(TestIamPermissionsRequest request, StreamObserver<TestIamPermissionsResponse> responseObserver)
public void testIamPermissions(TestIamPermissionsRequest request, StreamObserver<TestIamPermissionsResponse> responseObserver)
Returns the permissions that a caller has on a specified dataExchange or listing.
Name | Description |
request | com.google.iam.v1.TestIamPermissionsRequest |
responseObserver | io.grpc.stub.StreamObserver<com.google.iam.v1.TestIamPermissionsResponse> |
updateDataExchange(UpdateDataExchangeRequest request, StreamObserver<DataExchange> responseObserver)
public void updateDataExchange(UpdateDataExchangeRequest request, StreamObserver<DataExchange> responseObserver)
Updates the parameters of a single DataExchange.
Name | Description |
request | UpdateDataExchangeRequest |
responseObserver | io.grpc.stub.StreamObserver<DataExchange> |
updateListing(UpdateListingRequest request, StreamObserver<Listing> responseObserver)
public void updateListing(UpdateListingRequest request, StreamObserver<Listing> responseObserver)
Updates the parameters of a single Listing.
Name | Description |
request | UpdateListingRequest |
responseObserver | io.grpc.stub.StreamObserver<Listing> |