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

Class GcsUtil.GcsUtilFactory

java.lang.Object

org.apache.beam.sdk.extensions.gcp.util.GcsUtil.GcsUtilFactory

All Implemented Interfaces:

DefaultValueFactory<GcsUtil>

Enclosing class:

GcsUtil

public static class GcsUtil.GcsUtilFactory
extends Object
implements DefaultValueFactory<GcsUtil>

This is a DefaultValueFactory able to create a GcsUtil using any transport flags specified on the PipelineOptions.

Constructor Summary

Constructors

Constructor	Description
GcsUtilFactory()

Method Summary

Modifier and Type	Method	Description
GcsUtil	create(PipelineOptions options)	Returns an instance of GcsUtil based on the PipelineOptions.
static GcsUtil	create(PipelineOptions options, Storage storageClient, com.google.api.client.http.HttpRequestInitializer httpRequestInitializer, ExecutorService executorService, com.google.auth.Credentials credentials, @Nullable Integer uploadBufferSizeBytes, GcsUtil.GcsCountersOptions gcsCountersOptions, GoogleCloudStorageReadOptions gcsReadOptions)	Returns an instance of GcsUtil based on the given parameters.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

GcsUtilFactory

public GcsUtilFactory()

Method Details

create

public GcsUtil create(PipelineOptions options)

Returns an instance of GcsUtil based on the PipelineOptions.

If no instance has previously been created, one is created and the value stored in options.

Specified by:

create in interface DefaultValueFactory<GcsUtil>

Parameters:

options - The current pipeline options.

Returns:

The default value to be used for the annotated getter.

create

public static GcsUtil create(PipelineOptions options,
 Storage storageClient,
 com.google.api.client.http.HttpRequestInitializer httpRequestInitializer,
 ExecutorService executorService,
 com.google.auth.Credentials credentials,
 @Nullable Integer uploadBufferSizeBytes,
 GcsUtil.GcsCountersOptions gcsCountersOptions,
 GoogleCloudStorageReadOptions gcsReadOptions)

Returns an instance of GcsUtil based on the given parameters.