Package com.google.cloud.hadoop.util
package com.google.cloud.hadoop.util
-
ClassDescriptionSkeletal implementation of a WritableByteChannel that executes an asynchronous upload operation and optionally handles the result.An access boundary used to generate a downscoped access token.Translates exceptions from API calls into higher-level meaning, while allowing injectability for testing how API errors are handled.Options for the
AbstractGoogleAsyncWriteChannel.Mutable builder for the GoogleCloudStorageWriteChannelOptions class.Part file cleanup strategy for parallel composite upload.Pipe used for output stream.UploadType are in parity with various upload configuration offered by google-java-storage client ref: https://cloud.google.com/java/docs/reference/google-cloud-storage/latest/com.google.cloud.storage.BlobWriteSessionConfigsHttpRequestInitializerthat composes handlers and interceptors supplied by component handlers.CheckedFunction<T,R, E extends Throwable> Represents a function that accepts one argument and produces a result that can throw checked exception.AHttpExecuteInterceptorthat adds trailing checksum header.ClientRequestHelper provides wrapper methods around final methods of AbstractGoogleClientRequest to allow overriding them if necessary.Translates exceptions from API calls into ErrorTypeA thin class to emit checksum failure event for EventBus notification.This an Event which is published in EvenBus queue whenever a gcs request is created/executed.Event Bus classImplementation forErrorTypeExtractorfor exception specifically thrown from gRPC path.Factory for creating HttpTransport types.A utility class to manage a unique invocation ID for each thread usingInheritableThreadLocal.Translates exceptions from API calls into higher-level meaning, while allowing injectability for testing how API errors are handled.AHttpExecuteInterceptorthat adds an idempotency token header to GCS requests.Defers execution to the time that a method that expresses interest in the result (get or isDone) is called on the Future.A custom logging formatter that prefixes log messages with an invocation ID.Logs the status of uploads.Helpers for interacting with properties filesHolder class for string values that should not be logged and displayed whentoStringmethod called.Options for the GCS Requester Pays feature.Builder forRequesterPaysOptionsOperational modes of GCS Requester Pays feature.A class which defines static functions to be called to make a user-provided function more resilient by attempting retries.An implementation ofBackOffthat limits the number of calls on anotherBackOff.RetryDeterminer<X extends Exception>This abstract class is designed to tell if an exception is transient and should result in a retry or not, and should result in a returned exception to the caller.An implementation ofHttpRequestInitializerwith retries.Options for theRetryHttpInitializerclass.Builder forRetryHttpInitializerOptionsHelps track a request.Helps trace a block of code.