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 java.lang.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 and Description
GcsUtilFactory()

Method Summary

Modifier and Type	Method and 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, java.util.concurrent.ExecutorService executorService, com.google.auth.Credentials credentials, @Nullable java.lang.Integer uploadBufferSizeBytes, GcsUtil.GcsCountersOptions gcsCountersOptions) 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 Detail

GcsUtilFactory

public GcsUtilFactory()

Method Detail

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,
                             java.util.concurrent.ExecutorService executorService,
                             com.google.auth.Credentials credentials,
                             @Nullable java.lang.Integer uploadBufferSizeBytes,
                             GcsUtil.GcsCountersOptions gcsCountersOptions)

Returns an instance of GcsUtil based on the given parameters.