RetryingMutateRowsOperation (Cloud Bigtable HBase Client for Java 1.12.0 API)

java.lang.Object
- io.grpc.ClientCall.Listener<ResponseT>
- - com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation<com.google.bigtable.v2.MutateRowsRequest,com.google.bigtable.v2.MutateRowsResponse,List<com.google.bigtable.v2.MutateRowsResponse>>
  - - com.google.cloud.bigtable.grpc.async.RetryingMutateRowsOperation

public class RetryingMutateRowsOperation
extends AbstractRetryingOperation<com.google.bigtable.v2.MutateRowsRequest,com.google.bigtable.v2.MutateRowsResponse,List<com.google.bigtable.v2.MutateRowsResponse>>

Performs retries for BigtableDataClient.mutateRows(MutateRowsRequest) operations.

Nested Class Summary
- Nested classes/interfaces inherited from class com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation
  AbstractRetryingOperation.GrpcFuture<RespT>

Field Summary
- Fields inherited from class com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation
  callWrapper, completionFuture, failedCount, LOG, operationSpan, operationTimerContext, retryExecutorService, retryOptions, rpc, rpcTimerContext, UNARY_DEADLINE_MINUTES

Constructor Summary

Constructors
Constructor and Description
`RetryingMutateRowsOperation(RetryOptions retryOptions, com.google.bigtable.v2.MutateRowsRequest originalRequest, BigtableAsyncRpc<com.google.bigtable.v2.MutateRowsRequest,com.google.bigtable.v2.MutateRowsResponse> retryableRpc, io.grpc.CallOptions callOptions, ScheduledExecutorService retryExecutorService, io.grpc.Metadata originalMetadata, com.google.api.core.ApiClock clock)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`protected com.google.bigtable.v2.MutateRowsRequest`	`getRetryRequest()`
`void`	`onMessage(com.google.bigtable.v2.MutateRowsResponse message)`
`protected boolean`	`onOK(io.grpc.Metadata trailers)` A subclass has the opportunity to perform the final operations it needs now that the RPC is successfully complete.

Methods inherited from class com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation
cancel, cancel, createCallController, finalizeStats, getAsyncResult, getBlockingResult, getExhaustedRetriesException, getNextBackoff, getOperationCallOptions, getRpcCallOptions, getRunnable, inRetryMode, isRequestRetryable, isStreamingRead, onClose, onError, performRetry, resetStatusBasedBackoff, run, setException

Methods inherited from class io.grpc.ClientCall.Listener
onHeaders, onReady

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RetryingMutateRowsOperation

public RetryingMutateRowsOperation(RetryOptions retryOptions,
                                   com.google.bigtable.v2.MutateRowsRequest originalRequest,
                                   BigtableAsyncRpc<com.google.bigtable.v2.MutateRowsRequest,com.google.bigtable.v2.MutateRowsResponse> retryableRpc,
                                   io.grpc.CallOptions callOptions,
                                   ScheduledExecutorService retryExecutorService,
                                   io.grpc.Metadata originalMetadata,
                                   com.google.api.core.ApiClock clock)

Method Detail
- onMessage
```
public void onMessage(com.google.bigtable.v2.MutateRowsResponse message)
```
  Overrides:
  
  onMessage in class io.grpc.ClientCall.Listener<com.google.bigtable.v2.MutateRowsResponse>
- getRetryRequest
```
protected com.google.bigtable.v2.MutateRowsRequest getRetryRequest()
```
  Overrides:
  
  getRetryRequest in class AbstractRetryingOperation<com.google.bigtable.v2.MutateRowsRequest,com.google.bigtable.v2.MutateRowsResponse,List<com.google.bigtable.v2.MutateRowsResponse>>
- onOK
```
protected boolean onOK(io.grpc.Metadata trailers)
```
  Description copied from class: AbstractRetryingOperation
  
  A subclass has the opportunity to perform the final operations it needs now that the RPC is successfully complete. If a subclass has to retry, due to the message, this method will return false
  
  Specified by:
  
  onOK in class AbstractRetryingOperation<com.google.bigtable.v2.MutateRowsRequest,com.google.bigtable.v2.MutateRowsResponse,List<com.google.bigtable.v2.MutateRowsResponse>>
  
  Returns:
  
  true if the operation was really completed.

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2024-02-15 UTC.

RetryingMutateRowsOperation (Cloud Bigtable HBase Client for Java 1.12.0 API)

Class RetryingMutateRowsOperation

Nested Class Summary

Nested classes/interfaces inherited from class com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation

Field Summary

Fields inherited from class com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation

Constructor Summary

Method Summary

Methods inherited from class com.google.cloud.bigtable.grpc.async.AbstractRetryingOperation

Methods inherited from class io.grpc.ClientCall.Listener

Methods inherited from class java.lang.Object

Constructor Detail

RetryingMutateRowsOperation

Method Detail

onMessage

getRetryRequest

onOK