org.apache.beam.sdk.util

Class GcsPathValidator

java.lang.Object

org.apache.beam.sdk.util.GcsPathValidator

All Implemented Interfaces:

PathValidator

public class GcsPathValidator
extends Object
implements PathValidator

GCP implementation of PathValidator. Only GCS paths are allowed.

Method Summary

Modifier and Type	Method and Description
static GcsPathValidator	fromOptions(PipelineOptions options)
String	validateInputFilePatternSupported(String filepattern) Validates the the input GCS path is accessible and that the path is well formed.
String	validateOutputFilePrefixSupported(String filePrefix) Validates the the output GCS path is accessible and that the path is well formed.
String	verifyPath(String path)

Methods inherited from class java.lang.Object

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

Method Detail

fromOptions

public static GcsPathValidator fromOptions(PipelineOptions options)

validateInputFilePatternSupported

public String validateInputFilePatternSupported(String filepattern)

Validates the the input GCS path is accessible and that the path is well formed.

Specified by:

validateInputFilePatternSupported in interface PathValidator

validateOutputFilePrefixSupported

public String validateOutputFilePrefixSupported(String filePrefix)

Validates the the output GCS path is accessible and that the path is well formed.

Specified by:

validateOutputFilePrefixSupported in interface PathValidator

verifyPath

public String verifyPath(String path)

Specified by:

verifyPath in interface PathValidator