{
private ReservationServiceBlockingStub(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected ReservationServiceBlockingStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new ReservationServiceBlockingStub(channel, callOptions);
}
/**
*
*
*
* Creates a new reservation resource.
*
*/
public com.google.cloud.bigquery.reservation.v1.Reservation createReservation(
com.google.cloud.bigquery.reservation.v1.CreateReservationRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateReservationMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists all the reservations for the project in the specified location.
*
*/
public com.google.cloud.bigquery.reservation.v1.ListReservationsResponse listReservations(
com.google.cloud.bigquery.reservation.v1.ListReservationsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListReservationsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns information about the reservation.
*
*/
public com.google.cloud.bigquery.reservation.v1.Reservation getReservation(
com.google.cloud.bigquery.reservation.v1.GetReservationRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetReservationMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a reservation.
* Returns `google.rpc.Code.FAILED_PRECONDITION` when reservation has
* assignments.
*
*/
public com.google.protobuf.Empty deleteReservation(
com.google.cloud.bigquery.reservation.v1.DeleteReservationRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteReservationMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates an existing reservation resource.
*
*/
public com.google.cloud.bigquery.reservation.v1.Reservation updateReservation(
com.google.cloud.bigquery.reservation.v1.UpdateReservationRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateReservationMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates a new capacity commitment resource.
*
*/
public com.google.cloud.bigquery.reservation.v1.CapacityCommitment createCapacityCommitment(
com.google.cloud.bigquery.reservation.v1.CreateCapacityCommitmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateCapacityCommitmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists all the capacity commitments for the admin project.
*
*/
public com.google.cloud.bigquery.reservation.v1.ListCapacityCommitmentsResponse
listCapacityCommitments(
com.google.cloud.bigquery.reservation.v1.ListCapacityCommitmentsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListCapacityCommitmentsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Returns information about the capacity commitment.
*
*/
public com.google.cloud.bigquery.reservation.v1.CapacityCommitment getCapacityCommitment(
com.google.cloud.bigquery.reservation.v1.GetCapacityCommitmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetCapacityCommitmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a capacity commitment. Attempting to delete capacity commitment
* before its commitment_end_time will fail with the error code
* `google.rpc.Code.FAILED_PRECONDITION`.
*
*/
public com.google.protobuf.Empty deleteCapacityCommitment(
com.google.cloud.bigquery.reservation.v1.DeleteCapacityCommitmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteCapacityCommitmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates an existing capacity commitment.
* Only `plan` and `renewal_plan` fields can be updated.
* Plan can only be changed to a plan of a longer commitment period.
* Attempting to change to a plan with shorter commitment period will fail
* with the error code `google.rpc.Code.FAILED_PRECONDITION`.
*
*/
public com.google.cloud.bigquery.reservation.v1.CapacityCommitment updateCapacityCommitment(
com.google.cloud.bigquery.reservation.v1.UpdateCapacityCommitmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateCapacityCommitmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Splits capacity commitment to two commitments of the same plan and
* `commitment_end_time`.
* A common use case is to enable downgrading commitments.
* For example, in order to downgrade from 10000 slots to 8000, you might
* split a 10000 capacity commitment into commitments of 2000 and 8000. Then,
* you delete the first one after the commitment end time passes.
*
*/
public com.google.cloud.bigquery.reservation.v1.SplitCapacityCommitmentResponse
splitCapacityCommitment(
com.google.cloud.bigquery.reservation.v1.SplitCapacityCommitmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSplitCapacityCommitmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Merges capacity commitments of the same plan into a single commitment.
* The resulting capacity commitment has the greater commitment_end_time
* out of the to-be-merged capacity commitments.
* Attempting to merge capacity commitments of different plan will fail
* with the error code `google.rpc.Code.FAILED_PRECONDITION`.
*
*/
public com.google.cloud.bigquery.reservation.v1.CapacityCommitment mergeCapacityCommitments(
com.google.cloud.bigquery.reservation.v1.MergeCapacityCommitmentsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getMergeCapacityCommitmentsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Creates an assignment object which allows the given project to submit jobs
* of a certain type using slots from the specified reservation.
* Currently a
* resource (project, folder, organization) can only have one assignment per
* each (job_type, location) combination, and that reservation will be used
* for all jobs of the matching type.
* Different assignments can be created on different levels of the
* projects, folders or organization hierarchy. During query execution,
* the assignment is looked up at the project, folder and organization levels
* in that order. The first assignment found is applied to the query.
* When creating assignments, it does not matter if other assignments exist at
* higher levels.
* Example:
* * The organization `organizationA` contains two projects, `project1`
* and `project2`.
* * Assignments for all three entities (`organizationA`, `project1`, and
* `project2`) could all be created and mapped to the same or different
* reservations.
* "None" assignments represent an absence of the assignment. Projects
* assigned to None use on-demand pricing. To create a "None" assignment, use
* "none" as a reservation_id in the parent. Example parent:
* `projects/myproject/locations/US/reservations/none`.
* Returns `google.rpc.Code.PERMISSION_DENIED` if user does not have
* 'bigquery.admin' permissions on the project using the reservation
* and the project that owns this reservation.
* Returns `google.rpc.Code.INVALID_ARGUMENT` when location of the assignment
* does not match location of the reservation.
*
*/
public com.google.cloud.bigquery.reservation.v1.Assignment createAssignment(
com.google.cloud.bigquery.reservation.v1.CreateAssignmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getCreateAssignmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Lists assignments.
* Only explicitly created assignments will be returned.
* Example:
* * Organization `organizationA` contains two projects, `project1` and
* `project2`.
* * Reservation `res1` exists and was created previously.
* * CreateAssignment was used previously to define the following
* associations between entities and reservations: `<organizationA, res1>`
* and `<project1, res1>`
* In this example, ListAssignments will just return the above two assignments
* for reservation `res1`, and no expansion/merge will happen.
* The wildcard "-" can be used for
* reservations in the request. In that case all assignments belongs to the
* specified project and location will be listed.
* **Note** "-" cannot be used for projects nor locations.
*
*/
public com.google.cloud.bigquery.reservation.v1.ListAssignmentsResponse listAssignments(
com.google.cloud.bigquery.reservation.v1.ListAssignmentsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getListAssignmentsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deletes a assignment. No expansion will happen.
* Example:
* * Organization `organizationA` contains two projects, `project1` and
* `project2`.
* * Reservation `res1` exists and was created previously.
* * CreateAssignment was used previously to define the following
* associations between entities and reservations: `<organizationA, res1>`
* and `<project1, res1>`
* In this example, deletion of the `<organizationA, res1>` assignment won't
* affect the other assignment `<project1, res1>`. After said deletion,
* queries from `project1` will still use `res1` while queries from
* `project2` will switch to use on-demand mode.
*
*/
public com.google.protobuf.Empty deleteAssignment(
com.google.cloud.bigquery.reservation.v1.DeleteAssignmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getDeleteAssignmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Deprecated: Looks up assignments for a specified resource for a particular
* region. If the request is about a project:
* 1. Assignments created on the project will be returned if they exist.
* 2. Otherwise assignments created on the closest ancestor will be
* returned.
* 3. Assignments for different JobTypes will all be returned.
* The same logic applies if the request is about a folder.
* If the request is about an organization, then assignments created on the
* organization will be returned (organization doesn't have ancestors).
* Comparing to ListAssignments, there are some behavior
* differences:
* 1. permission on the assignee will be verified in this API.
* 2. Hierarchy lookup (project->folder->organization) happens in this API.
* 3. Parent here is `projects/*/locations/*`, instead of
* `projects/*/locations/*reservations/*`.
* **Note** "-" cannot be used for projects
* nor locations.
*
*/
@java.lang.Deprecated
public com.google.cloud.bigquery.reservation.v1.SearchAssignmentsResponse searchAssignments(
com.google.cloud.bigquery.reservation.v1.SearchAssignmentsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSearchAssignmentsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Looks up assignments for a specified resource for a particular region.
* If the request is about a project:
* 1. Assignments created on the project will be returned if they exist.
* 2. Otherwise assignments created on the closest ancestor will be
* returned.
* 3. Assignments for different JobTypes will all be returned.
* The same logic applies if the request is about a folder.
* If the request is about an organization, then assignments created on the
* organization will be returned (organization doesn't have ancestors).
* Comparing to ListAssignments, there are some behavior
* differences:
* 1. permission on the assignee will be verified in this API.
* 2. Hierarchy lookup (project->folder->organization) happens in this API.
* 3. Parent here is `projects/*/locations/*`, instead of
* `projects/*/locations/*reservations/*`.
*
*/
public com.google.cloud.bigquery.reservation.v1.SearchAllAssignmentsResponse
searchAllAssignments(
com.google.cloud.bigquery.reservation.v1.SearchAllAssignmentsRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getSearchAllAssignmentsMethod(), getCallOptions(), request);
}
/**
*
*
*
* Moves an assignment under a new reservation.
* This differs from removing an existing assignment and recreating a new one
* by providing a transactional change that ensures an assignee always has an
* associated reservation.
*
*/
public com.google.cloud.bigquery.reservation.v1.Assignment moveAssignment(
com.google.cloud.bigquery.reservation.v1.MoveAssignmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getMoveAssignmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates an existing assignment.
* Only the `priority` field can be updated.
*
*/
public com.google.cloud.bigquery.reservation.v1.Assignment updateAssignment(
com.google.cloud.bigquery.reservation.v1.UpdateAssignmentRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateAssignmentMethod(), getCallOptions(), request);
}
/**
*
*
*
* Retrieves a BI reservation.
*
*/
public com.google.cloud.bigquery.reservation.v1.BiReservation getBiReservation(
com.google.cloud.bigquery.reservation.v1.GetBiReservationRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getGetBiReservationMethod(), getCallOptions(), request);
}
/**
*
*
*
* Updates a BI reservation.
* Only fields specified in the `field_mask` are updated.
* A singleton BI reservation always exists with default size 0.
* In order to reserve BI capacity it needs to be updated to an amount
* greater than 0. In order to release BI capacity reservation size
* must be set to 0.
*
*/
public com.google.cloud.bigquery.reservation.v1.BiReservation updateBiReservation(
com.google.cloud.bigquery.reservation.v1.UpdateBiReservationRequest request) {
return io.grpc.stub.ClientCalls.blockingUnaryCall(
getChannel(), getUpdateBiReservationMethod(), getCallOptions(), request);
}
}
/**
* A stub to allow clients to do ListenableFuture-style rpc calls to service ReservationService.
*
*
* This API allows users to manage their BigQuery reservations.
* A reservation provides computational resource guarantees, in the form of
* [slots](https://cloud.google.com/bigquery/docs/slots), to users. A slot is a
* unit of computational power in BigQuery, and serves as the basic unit of
* parallelism. In a scan of a multi-partitioned table, a single slot operates
* on a single partition of the table. A reservation resource exists as a child
* resource of the admin project and location, e.g.:
* `projects/myproject/locations/US/reservations/reservationName`.
* A capacity commitment is a way to purchase compute capacity for BigQuery jobs
* (in the form of slots) with some committed period of usage. A capacity
* commitment resource exists as a child resource of the admin project and
* location, e.g.:
* `projects/myproject/locations/US/capacityCommitments/id`.
*
*/
public static final class ReservationServiceFutureStub
extends io.grpc.stub.AbstractFutureStub {
private ReservationServiceFutureStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
super(channel, callOptions);
}
@java.lang.Override
protected ReservationServiceFutureStub build(
io.grpc.Channel channel, io.grpc.CallOptions callOptions) {
return new ReservationServiceFutureStub(channel, callOptions);
}
/**
*
*
*
* Creates a new reservation resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.Reservation>
createReservation(
com.google.cloud.bigquery.reservation.v1.CreateReservationRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateReservationMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists all the reservations for the project in the specified location.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.ListReservationsResponse>
listReservations(com.google.cloud.bigquery.reservation.v1.ListReservationsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListReservationsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns information about the reservation.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.Reservation>
getReservation(com.google.cloud.bigquery.reservation.v1.GetReservationRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetReservationMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a reservation.
* Returns `google.rpc.Code.FAILED_PRECONDITION` when reservation has
* assignments.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteReservation(
com.google.cloud.bigquery.reservation.v1.DeleteReservationRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteReservationMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates an existing reservation resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.Reservation>
updateReservation(
com.google.cloud.bigquery.reservation.v1.UpdateReservationRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateReservationMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates a new capacity commitment resource.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.CapacityCommitment>
createCapacityCommitment(
com.google.cloud.bigquery.reservation.v1.CreateCapacityCommitmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateCapacityCommitmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists all the capacity commitments for the admin project.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.ListCapacityCommitmentsResponse>
listCapacityCommitments(
com.google.cloud.bigquery.reservation.v1.ListCapacityCommitmentsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListCapacityCommitmentsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Returns information about the capacity commitment.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.CapacityCommitment>
getCapacityCommitment(
com.google.cloud.bigquery.reservation.v1.GetCapacityCommitmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetCapacityCommitmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a capacity commitment. Attempting to delete capacity commitment
* before its commitment_end_time will fail with the error code
* `google.rpc.Code.FAILED_PRECONDITION`.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteCapacityCommitment(
com.google.cloud.bigquery.reservation.v1.DeleteCapacityCommitmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteCapacityCommitmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates an existing capacity commitment.
* Only `plan` and `renewal_plan` fields can be updated.
* Plan can only be changed to a plan of a longer commitment period.
* Attempting to change to a plan with shorter commitment period will fail
* with the error code `google.rpc.Code.FAILED_PRECONDITION`.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.CapacityCommitment>
updateCapacityCommitment(
com.google.cloud.bigquery.reservation.v1.UpdateCapacityCommitmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateCapacityCommitmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Splits capacity commitment to two commitments of the same plan and
* `commitment_end_time`.
* A common use case is to enable downgrading commitments.
* For example, in order to downgrade from 10000 slots to 8000, you might
* split a 10000 capacity commitment into commitments of 2000 and 8000. Then,
* you delete the first one after the commitment end time passes.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.SplitCapacityCommitmentResponse>
splitCapacityCommitment(
com.google.cloud.bigquery.reservation.v1.SplitCapacityCommitmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSplitCapacityCommitmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Merges capacity commitments of the same plan into a single commitment.
* The resulting capacity commitment has the greater commitment_end_time
* out of the to-be-merged capacity commitments.
* Attempting to merge capacity commitments of different plan will fail
* with the error code `google.rpc.Code.FAILED_PRECONDITION`.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.CapacityCommitment>
mergeCapacityCommitments(
com.google.cloud.bigquery.reservation.v1.MergeCapacityCommitmentsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getMergeCapacityCommitmentsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Creates an assignment object which allows the given project to submit jobs
* of a certain type using slots from the specified reservation.
* Currently a
* resource (project, folder, organization) can only have one assignment per
* each (job_type, location) combination, and that reservation will be used
* for all jobs of the matching type.
* Different assignments can be created on different levels of the
* projects, folders or organization hierarchy. During query execution,
* the assignment is looked up at the project, folder and organization levels
* in that order. The first assignment found is applied to the query.
* When creating assignments, it does not matter if other assignments exist at
* higher levels.
* Example:
* * The organization `organizationA` contains two projects, `project1`
* and `project2`.
* * Assignments for all three entities (`organizationA`, `project1`, and
* `project2`) could all be created and mapped to the same or different
* reservations.
* "None" assignments represent an absence of the assignment. Projects
* assigned to None use on-demand pricing. To create a "None" assignment, use
* "none" as a reservation_id in the parent. Example parent:
* `projects/myproject/locations/US/reservations/none`.
* Returns `google.rpc.Code.PERMISSION_DENIED` if user does not have
* 'bigquery.admin' permissions on the project using the reservation
* and the project that owns this reservation.
* Returns `google.rpc.Code.INVALID_ARGUMENT` when location of the assignment
* does not match location of the reservation.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.Assignment>
createAssignment(com.google.cloud.bigquery.reservation.v1.CreateAssignmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getCreateAssignmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Lists assignments.
* Only explicitly created assignments will be returned.
* Example:
* * Organization `organizationA` contains two projects, `project1` and
* `project2`.
* * Reservation `res1` exists and was created previously.
* * CreateAssignment was used previously to define the following
* associations between entities and reservations: `<organizationA, res1>`
* and `<project1, res1>`
* In this example, ListAssignments will just return the above two assignments
* for reservation `res1`, and no expansion/merge will happen.
* The wildcard "-" can be used for
* reservations in the request. In that case all assignments belongs to the
* specified project and location will be listed.
* **Note** "-" cannot be used for projects nor locations.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.ListAssignmentsResponse>
listAssignments(com.google.cloud.bigquery.reservation.v1.ListAssignmentsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getListAssignmentsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deletes a assignment. No expansion will happen.
* Example:
* * Organization `organizationA` contains two projects, `project1` and
* `project2`.
* * Reservation `res1` exists and was created previously.
* * CreateAssignment was used previously to define the following
* associations between entities and reservations: `<organizationA, res1>`
* and `<project1, res1>`
* In this example, deletion of the `<organizationA, res1>` assignment won't
* affect the other assignment `<project1, res1>`. After said deletion,
* queries from `project1` will still use `res1` while queries from
* `project2` will switch to use on-demand mode.
*
*/
public com.google.common.util.concurrent.ListenableFuture
deleteAssignment(com.google.cloud.bigquery.reservation.v1.DeleteAssignmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getDeleteAssignmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Deprecated: Looks up assignments for a specified resource for a particular
* region. If the request is about a project:
* 1. Assignments created on the project will be returned if they exist.
* 2. Otherwise assignments created on the closest ancestor will be
* returned.
* 3. Assignments for different JobTypes will all be returned.
* The same logic applies if the request is about a folder.
* If the request is about an organization, then assignments created on the
* organization will be returned (organization doesn't have ancestors).
* Comparing to ListAssignments, there are some behavior
* differences:
* 1. permission on the assignee will be verified in this API.
* 2. Hierarchy lookup (project->folder->organization) happens in this API.
* 3. Parent here is `projects/*/locations/*`, instead of
* `projects/*/locations/*reservations/*`.
* **Note** "-" cannot be used for projects
* nor locations.
*
*/
@java.lang.Deprecated
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.SearchAssignmentsResponse>
searchAssignments(
com.google.cloud.bigquery.reservation.v1.SearchAssignmentsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSearchAssignmentsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Looks up assignments for a specified resource for a particular region.
* If the request is about a project:
* 1. Assignments created on the project will be returned if they exist.
* 2. Otherwise assignments created on the closest ancestor will be
* returned.
* 3. Assignments for different JobTypes will all be returned.
* The same logic applies if the request is about a folder.
* If the request is about an organization, then assignments created on the
* organization will be returned (organization doesn't have ancestors).
* Comparing to ListAssignments, there are some behavior
* differences:
* 1. permission on the assignee will be verified in this API.
* 2. Hierarchy lookup (project->folder->organization) happens in this API.
* 3. Parent here is `projects/*/locations/*`, instead of
* `projects/*/locations/*reservations/*`.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.SearchAllAssignmentsResponse>
searchAllAssignments(
com.google.cloud.bigquery.reservation.v1.SearchAllAssignmentsRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getSearchAllAssignmentsMethod(), getCallOptions()), request);
}
/**
*
*
*
* Moves an assignment under a new reservation.
* This differs from removing an existing assignment and recreating a new one
* by providing a transactional change that ensures an assignee always has an
* associated reservation.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.Assignment>
moveAssignment(com.google.cloud.bigquery.reservation.v1.MoveAssignmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getMoveAssignmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates an existing assignment.
* Only the `priority` field can be updated.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.Assignment>
updateAssignment(com.google.cloud.bigquery.reservation.v1.UpdateAssignmentRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateAssignmentMethod(), getCallOptions()), request);
}
/**
*
*
*
* Retrieves a BI reservation.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.BiReservation>
getBiReservation(com.google.cloud.bigquery.reservation.v1.GetBiReservationRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getGetBiReservationMethod(), getCallOptions()), request);
}
/**
*
*
*
* Updates a BI reservation.
* Only fields specified in the `field_mask` are updated.
* A singleton BI reservation always exists with default size 0.
* In order to reserve BI capacity it needs to be updated to an amount
* greater than 0. In order to release BI capacity reservation size
* must be set to 0.
*
*/
public com.google.common.util.concurrent.ListenableFuture<
com.google.cloud.bigquery.reservation.v1.BiReservation>
updateBiReservation(
com.google.cloud.bigquery.reservation.v1.UpdateBiReservationRequest request) {
return io.grpc.stub.ClientCalls.futureUnaryCall(
getChannel().newCall(getUpdateBiReservationMethod(), getCallOptions()), request);
}
}
private static final int METHODID_CREATE_RESERVATION = 0;
private static final int METHODID_LIST_RESERVATIONS = 1;
private static final int METHODID_GET_RESERVATION = 2;
private static final int METHODID_DELETE_RESERVATION = 3;
private static final int METHODID_UPDATE_RESERVATION = 4;
private static final int METHODID_CREATE_CAPACITY_COMMITMENT = 5;
private static final int METHODID_LIST_CAPACITY_COMMITMENTS = 6;
private static final int METHODID_GET_CAPACITY_COMMITMENT = 7;
private static final int METHODID_DELETE_CAPACITY_COMMITMENT = 8;
private static final int METHODID_UPDATE_CAPACITY_COMMITMENT = 9;
private static final int METHODID_SPLIT_CAPACITY_COMMITMENT = 10;
private static final int METHODID_MERGE_CAPACITY_COMMITMENTS = 11;
private static final int METHODID_CREATE_ASSIGNMENT = 12;
private static final int METHODID_LIST_ASSIGNMENTS = 13;
private static final int METHODID_DELETE_ASSIGNMENT = 14;
private static final int METHODID_SEARCH_ASSIGNMENTS = 15;
private static final int METHODID_SEARCH_ALL_ASSIGNMENTS = 16;
private static final int METHODID_MOVE_ASSIGNMENT = 17;
private static final int METHODID_UPDATE_ASSIGNMENT = 18;
private static final int METHODID_GET_BI_RESERVATION = 19;
private static final int METHODID_UPDATE_BI_RESERVATION = 20;
private static final class MethodHandlers
implements io.grpc.stub.ServerCalls.UnaryMethod,
io.grpc.stub.ServerCalls.ServerStreamingMethod,
io.grpc.stub.ServerCalls.ClientStreamingMethod,
io.grpc.stub.ServerCalls.BidiStreamingMethod {
private final AsyncService serviceImpl;
private final int methodId;
MethodHandlers(AsyncService serviceImpl, int methodId) {
this.serviceImpl = serviceImpl;
this.methodId = methodId;
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public void invoke(Req request, io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
case METHODID_CREATE_RESERVATION:
serviceImpl.createReservation(
(com.google.cloud.bigquery.reservation.v1.CreateReservationRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_RESERVATIONS:
serviceImpl.listReservations(
(com.google.cloud.bigquery.reservation.v1.ListReservationsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.reservation.v1.ListReservationsResponse>)
responseObserver);
break;
case METHODID_GET_RESERVATION:
serviceImpl.getReservation(
(com.google.cloud.bigquery.reservation.v1.GetReservationRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_DELETE_RESERVATION:
serviceImpl.deleteReservation(
(com.google.cloud.bigquery.reservation.v1.DeleteReservationRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_RESERVATION:
serviceImpl.updateReservation(
(com.google.cloud.bigquery.reservation.v1.UpdateReservationRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_CREATE_CAPACITY_COMMITMENT:
serviceImpl.createCapacityCommitment(
(com.google.cloud.bigquery.reservation.v1.CreateCapacityCommitmentRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.reservation.v1.CapacityCommitment>)
responseObserver);
break;
case METHODID_LIST_CAPACITY_COMMITMENTS:
serviceImpl.listCapacityCommitments(
(com.google.cloud.bigquery.reservation.v1.ListCapacityCommitmentsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.reservation.v1.ListCapacityCommitmentsResponse>)
responseObserver);
break;
case METHODID_GET_CAPACITY_COMMITMENT:
serviceImpl.getCapacityCommitment(
(com.google.cloud.bigquery.reservation.v1.GetCapacityCommitmentRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.reservation.v1.CapacityCommitment>)
responseObserver);
break;
case METHODID_DELETE_CAPACITY_COMMITMENT:
serviceImpl.deleteCapacityCommitment(
(com.google.cloud.bigquery.reservation.v1.DeleteCapacityCommitmentRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_UPDATE_CAPACITY_COMMITMENT:
serviceImpl.updateCapacityCommitment(
(com.google.cloud.bigquery.reservation.v1.UpdateCapacityCommitmentRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.reservation.v1.CapacityCommitment>)
responseObserver);
break;
case METHODID_SPLIT_CAPACITY_COMMITMENT:
serviceImpl.splitCapacityCommitment(
(com.google.cloud.bigquery.reservation.v1.SplitCapacityCommitmentRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.reservation.v1.SplitCapacityCommitmentResponse>)
responseObserver);
break;
case METHODID_MERGE_CAPACITY_COMMITMENTS:
serviceImpl.mergeCapacityCommitments(
(com.google.cloud.bigquery.reservation.v1.MergeCapacityCommitmentsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.reservation.v1.CapacityCommitment>)
responseObserver);
break;
case METHODID_CREATE_ASSIGNMENT:
serviceImpl.createAssignment(
(com.google.cloud.bigquery.reservation.v1.CreateAssignmentRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_LIST_ASSIGNMENTS:
serviceImpl.listAssignments(
(com.google.cloud.bigquery.reservation.v1.ListAssignmentsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.reservation.v1.ListAssignmentsResponse>)
responseObserver);
break;
case METHODID_DELETE_ASSIGNMENT:
serviceImpl.deleteAssignment(
(com.google.cloud.bigquery.reservation.v1.DeleteAssignmentRequest) request,
(io.grpc.stub.StreamObserver) responseObserver);
break;
case METHODID_SEARCH_ASSIGNMENTS:
serviceImpl.searchAssignments(
(com.google.cloud.bigquery.reservation.v1.SearchAssignmentsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.reservation.v1.SearchAssignmentsResponse>)
responseObserver);
break;
case METHODID_SEARCH_ALL_ASSIGNMENTS:
serviceImpl.searchAllAssignments(
(com.google.cloud.bigquery.reservation.v1.SearchAllAssignmentsRequest) request,
(io.grpc.stub.StreamObserver<
com.google.cloud.bigquery.reservation.v1.SearchAllAssignmentsResponse>)
responseObserver);
break;
case METHODID_MOVE_ASSIGNMENT:
serviceImpl.moveAssignment(
(com.google.cloud.bigquery.reservation.v1.MoveAssignmentRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_ASSIGNMENT:
serviceImpl.updateAssignment(
(com.google.cloud.bigquery.reservation.v1.UpdateAssignmentRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_GET_BI_RESERVATION:
serviceImpl.getBiReservation(
(com.google.cloud.bigquery.reservation.v1.GetBiReservationRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
case METHODID_UPDATE_BI_RESERVATION:
serviceImpl.updateBiReservation(
(com.google.cloud.bigquery.reservation.v1.UpdateBiReservationRequest) request,
(io.grpc.stub.StreamObserver)
responseObserver);
break;
default:
throw new AssertionError();
}
}
@java.lang.Override
@java.lang.SuppressWarnings("unchecked")
public io.grpc.stub.StreamObserver invoke(
io.grpc.stub.StreamObserver responseObserver) {
switch (methodId) {
default:
throw new AssertionError();
}
}
}
public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) {
return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor())
.addMethod(
getCreateReservationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.CreateReservationRequest,
com.google.cloud.bigquery.reservation.v1.Reservation>(
service, METHODID_CREATE_RESERVATION)))
.addMethod(
getListReservationsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.ListReservationsRequest,
com.google.cloud.bigquery.reservation.v1.ListReservationsResponse>(
service, METHODID_LIST_RESERVATIONS)))
.addMethod(
getGetReservationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.GetReservationRequest,
com.google.cloud.bigquery.reservation.v1.Reservation>(
service, METHODID_GET_RESERVATION)))
.addMethod(
getDeleteReservationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.DeleteReservationRequest,
com.google.protobuf.Empty>(service, METHODID_DELETE_RESERVATION)))
.addMethod(
getUpdateReservationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.UpdateReservationRequest,
com.google.cloud.bigquery.reservation.v1.Reservation>(
service, METHODID_UPDATE_RESERVATION)))
.addMethod(
getCreateCapacityCommitmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.CreateCapacityCommitmentRequest,
com.google.cloud.bigquery.reservation.v1.CapacityCommitment>(
service, METHODID_CREATE_CAPACITY_COMMITMENT)))
.addMethod(
getListCapacityCommitmentsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.ListCapacityCommitmentsRequest,
com.google.cloud.bigquery.reservation.v1.ListCapacityCommitmentsResponse>(
service, METHODID_LIST_CAPACITY_COMMITMENTS)))
.addMethod(
getGetCapacityCommitmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.GetCapacityCommitmentRequest,
com.google.cloud.bigquery.reservation.v1.CapacityCommitment>(
service, METHODID_GET_CAPACITY_COMMITMENT)))
.addMethod(
getDeleteCapacityCommitmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.DeleteCapacityCommitmentRequest,
com.google.protobuf.Empty>(service, METHODID_DELETE_CAPACITY_COMMITMENT)))
.addMethod(
getUpdateCapacityCommitmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.UpdateCapacityCommitmentRequest,
com.google.cloud.bigquery.reservation.v1.CapacityCommitment>(
service, METHODID_UPDATE_CAPACITY_COMMITMENT)))
.addMethod(
getSplitCapacityCommitmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.SplitCapacityCommitmentRequest,
com.google.cloud.bigquery.reservation.v1.SplitCapacityCommitmentResponse>(
service, METHODID_SPLIT_CAPACITY_COMMITMENT)))
.addMethod(
getMergeCapacityCommitmentsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.MergeCapacityCommitmentsRequest,
com.google.cloud.bigquery.reservation.v1.CapacityCommitment>(
service, METHODID_MERGE_CAPACITY_COMMITMENTS)))
.addMethod(
getCreateAssignmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.CreateAssignmentRequest,
com.google.cloud.bigquery.reservation.v1.Assignment>(
service, METHODID_CREATE_ASSIGNMENT)))
.addMethod(
getListAssignmentsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.ListAssignmentsRequest,
com.google.cloud.bigquery.reservation.v1.ListAssignmentsResponse>(
service, METHODID_LIST_ASSIGNMENTS)))
.addMethod(
getDeleteAssignmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.DeleteAssignmentRequest,
com.google.protobuf.Empty>(service, METHODID_DELETE_ASSIGNMENT)))
.addMethod(
getSearchAssignmentsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.SearchAssignmentsRequest,
com.google.cloud.bigquery.reservation.v1.SearchAssignmentsResponse>(
service, METHODID_SEARCH_ASSIGNMENTS)))
.addMethod(
getSearchAllAssignmentsMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.SearchAllAssignmentsRequest,
com.google.cloud.bigquery.reservation.v1.SearchAllAssignmentsResponse>(
service, METHODID_SEARCH_ALL_ASSIGNMENTS)))
.addMethod(
getMoveAssignmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.MoveAssignmentRequest,
com.google.cloud.bigquery.reservation.v1.Assignment>(
service, METHODID_MOVE_ASSIGNMENT)))
.addMethod(
getUpdateAssignmentMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.UpdateAssignmentRequest,
com.google.cloud.bigquery.reservation.v1.Assignment>(
service, METHODID_UPDATE_ASSIGNMENT)))
.addMethod(
getGetBiReservationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.GetBiReservationRequest,
com.google.cloud.bigquery.reservation.v1.BiReservation>(
service, METHODID_GET_BI_RESERVATION)))
.addMethod(
getUpdateBiReservationMethod(),
io.grpc.stub.ServerCalls.asyncUnaryCall(
new MethodHandlers<
com.google.cloud.bigquery.reservation.v1.UpdateBiReservationRequest,
com.google.cloud.bigquery.reservation.v1.BiReservation>(
service, METHODID_UPDATE_BI_RESERVATION)))
.build();
}
private abstract static class ReservationServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoFileDescriptorSupplier,
io.grpc.protobuf.ProtoServiceDescriptorSupplier {
ReservationServiceBaseDescriptorSupplier() {}
@java.lang.Override
public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() {
return com.google.cloud.bigquery.reservation.v1.ReservationProto.getDescriptor();
}
@java.lang.Override
public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() {
return getFileDescriptor().findServiceByName("ReservationService");
}
}
private static final class ReservationServiceFileDescriptorSupplier
extends ReservationServiceBaseDescriptorSupplier {
ReservationServiceFileDescriptorSupplier() {}
}
private static final class ReservationServiceMethodDescriptorSupplier
extends ReservationServiceBaseDescriptorSupplier
implements io.grpc.protobuf.ProtoMethodDescriptorSupplier {
private final String methodName;
ReservationServiceMethodDescriptorSupplier(String methodName) {
this.methodName = methodName;
}
@java.lang.Override
public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() {
return getServiceDescriptor().findMethodByName(methodName);
}
}
private static volatile io.grpc.ServiceDescriptor serviceDescriptor;
public static io.grpc.ServiceDescriptor getServiceDescriptor() {
io.grpc.ServiceDescriptor result = serviceDescriptor;
if (result == null) {
synchronized (ReservationServiceGrpc.class) {
result = serviceDescriptor;
if (result == null) {
serviceDescriptor =
result =
io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME)
.setSchemaDescriptor(new ReservationServiceFileDescriptorSupplier())
.addMethod(getCreateReservationMethod())
.addMethod(getListReservationsMethod())
.addMethod(getGetReservationMethod())
.addMethod(getDeleteReservationMethod())
.addMethod(getUpdateReservationMethod())
.addMethod(getCreateCapacityCommitmentMethod())
.addMethod(getListCapacityCommitmentsMethod())
.addMethod(getGetCapacityCommitmentMethod())
.addMethod(getDeleteCapacityCommitmentMethod())
.addMethod(getUpdateCapacityCommitmentMethod())
.addMethod(getSplitCapacityCommitmentMethod())
.addMethod(getMergeCapacityCommitmentsMethod())
.addMethod(getCreateAssignmentMethod())
.addMethod(getListAssignmentsMethod())
.addMethod(getDeleteAssignmentMethod())
.addMethod(getSearchAssignmentsMethod())
.addMethod(getSearchAllAssignmentsMethod())
.addMethod(getMoveAssignmentMethod())
.addMethod(getUpdateAssignmentMethod())
.addMethod(getGetBiReservationMethod())
.addMethod(getUpdateBiReservationMethod())
.build();
}
}
}
return result;
}
}