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(com.google.api.services.storage.Storage storageClient, com.google.api.client.http.HttpRequestInitializer httpRequestInitializer, java.util.concurrent.ExecutorService executorService, java.lang.Integer uploadBufferSizeBytes) 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(com.google.api.services.storage.Storage storageClient,
                             com.google.api.client.http.HttpRequestInitializer httpRequestInitializer,
                             java.util.concurrent.ExecutorService executorService,
                             @Nullable
                             java.lang.Integer uploadBufferSizeBytes)

Returns an instance of GcsUtil based on the given parameters.