Package org.apache.beam.sdk.extensions.gcp.util

package org.apache.beam.sdk.extensions.gcp.util

Defines Google Cloud Platform component utilities that can be used by Beam runners.

Related Packages

Package	Description
org.apache.beam.sdk.extensions.gcp.util.channels	Package contains java channel wrappers used with GCS.
org.apache.beam.sdk.extensions.gcp.util.gcsfs	Defines utilities used to interact with Google Cloud Storage.

Classes

Class	Description
BackOffAdapter	An adapter for converting between Apache Beam and Google API client representations of backoffs.
CustomHttpErrors	An optional component to use with the RetryHttpRequestInitializer in order to provide custom errors for failing http calls.
CustomHttpErrors.Builder	A Builder which allows building immutable CustomHttpErrors object.
CustomHttpErrors.MatcherAndError	A simple Tuple class for creating a list of HttpResponseMatcher and HttpResponseCustomError to print for the responses.
GceMetadataUtil
GcsUtil	Provides operations on GCS.
GcsUtil.CreateOptions
GcsUtil.CreateOptions.Builder
GcsUtil.GcsCountersOptions
GcsUtil.GcsReadOptionsFactory
GcsUtil.GcsUtilFactory	This is a DefaultValueFactory able to create a GcsUtil using any transport flags specified on the PipelineOptions.
GcsUtil.StorageObjectOrIOException	A class that holds either a StorageObject or an IOException.
LatencyRecordingHttpRequestInitializer	HttpRequestInitializer for recording request to response latency of Http-based API calls.
RetryHttpRequestInitializer	Implements a request initializer that adds retry handlers to all HttpRequests.
Transport	Helpers for cloud communication.
UploadIdResponseInterceptor	Implements a response intercepter that logs the upload id if the upload id header exists and it is the first request (does not have upload_id parameter in the request).