org.apache.beam.sdk.io

Interface FileSystemRegistrar

All Known Implementing Classes:

GcsFileSystemRegistrar, HadoopFileSystemRegistrar, LocalFileSystemRegistrar, S3FileSystemRegistrar

@Experimental(value=FILESYSTEM)
public interface FileSystemRegistrar

A registrar that creates FileSystem instances from PipelineOptions.

FileSystem creators have the ability to provide a registrar by creating a ServiceLoader entry and a concrete implementation of this interface.

It is optional but recommended to use one of the many build time tools such as AutoService to generate the necessary META-INF files automatically.

Method Summary

Modifier and Type	Method and Description
java.lang.Iterable<FileSystem>	fromOptions(PipelineOptions options) Create zero or more filesystems from the given PipelineOptions.

Method Detail

fromOptions

java.lang.Iterable<FileSystem> fromOptions(@Nullable
                                           PipelineOptions options)

Create zero or more filesystems from the given PipelineOptions.

Each scheme is required to be unique among all FileSystems registered by all FileSystemRegistrars.