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

Class NoopPathValidator

java.lang.Object
org.apache.beam.sdk.extensions.gcp.storage.NoopPathValidator
All Implemented Interfaces:
PathValidator
@Internal public class NoopPathValidator extends Object implements PathValidator
For internal use only; no backwards compatibility guarantees.

Noop implementation of PathValidator. All paths are allowed and returned unchanged.

  • Method Details

    • fromOptions

      public static PathValidator fromOptions(PipelineOptions options)

    • validateInputFilePatternSupported

      public void validateInputFilePatternSupported(String filepattern)
      Description copied from interface: PathValidator
      Validate that a file pattern is conforming.
      Specified by:
      validateInputFilePatternSupported in interface PathValidator
      Parameters:
      filepattern - The file pattern to verify.

    • validateOutputFilePrefixSupported

      public void validateOutputFilePrefixSupported(String filePrefix)
      Description copied from interface: PathValidator
      Validate that an output file prefix is conforming.
      Specified by:
      validateOutputFilePrefixSupported in interface PathValidator
      Parameters:
      filePrefix - the file prefix to verify.

    • validateOutputResourceSupported

      public void validateOutputResourceSupported(ResourceId resourceId)
      Description copied from interface: PathValidator
      Validates that an output path is conforming.
      Specified by:
      validateOutputResourceSupported in interface PathValidator
      Parameters:
      resourceId - the file prefix to verify.

    • verifyPath

      public String verifyPath(String path)
      Description copied from interface: PathValidator
      Validate that a path is a valid path and that the path is accessible.
      Specified by:
      verifyPath in interface PathValidator
      Parameters:
      path - The path to verify.
      Returns:
      The post-validation path.