org.apache.beam.it.gcp.artifacts.utils

Class ArtifactUtils

java.lang.Object

org.apache.beam.it.gcp.artifacts.utils.ArtifactUtils

public final class ArtifactUtils
extends java.lang.Object

Utilities for working with test artifacts.

Method Summary

Modifier and Type	Method and Description
static java.lang.String	createRunId() Creates a unique id for the run.
static com.google.cloud.storage.Storage	createStorageClient(com.google.auth.Credentials credentials) Creates a client for GCS with the given credentials.
static java.lang.String	getFullGcsPath(java.lang.String... pathParts) Returns the full GCS path given a list of path parts.

Methods inherited from class java.lang.Object

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

Method Detail

createRunId

public static java.lang.String createRunId()

Creates a unique id for the run.

getFullGcsPath

public static java.lang.String getFullGcsPath(java.lang.String... pathParts)

Returns the full GCS path given a list of path parts.

"path parts" refers to the bucket, directories, and file. Only the bucket is mandatory and must be the first value provided.

Parameters:

pathParts - everything that makes up the path, minus the separators. There must be at least one value, and none of them can be empty

Returns:

the full path, such as 'gs://bucket/dir1/dir2/file'

createStorageClient

public static com.google.cloud.storage.Storage createStorageClient(com.google.auth.Credentials credentials)

Creates a client for GCS with the given credentials.

Parameters:

credentials - credentials to use for connecting. If not chosen, then this will use the system credentials. Using system credentials is intended only for local testing. Otherwise, it is best to pass in a short-lived access token.

Returns:

a Storage client for running GCS operations