Package org.apache.beam.sdk.io.aws2.s3

Class DefaultS3FileSystemSchemeRegistrar

java.lang.Object

org.apache.beam.sdk.io.aws2.s3.DefaultS3FileSystemSchemeRegistrar

All Implemented Interfaces:

S3FileSystemSchemeRegistrar

@AutoService(S3FileSystemSchemeRegistrar.class)
public class DefaultS3FileSystemSchemeRegistrar
extends Object
implements S3FileSystemSchemeRegistrar

Registers the "s3" uri schema to be handled by S3FileSystem.

Constructor Summary

Constructors

Constructor	Description
DefaultS3FileSystemSchemeRegistrar()

Method Summary

Modifier and Type	Method	Description
Iterable<S3FileSystemConfiguration>	fromOptions(PipelineOptions options)	Create zero or more S3FileSystemConfiguration instances from the given PipelineOptions.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultS3FileSystemSchemeRegistrar

public DefaultS3FileSystemSchemeRegistrar()

Method Details

fromOptions

public Iterable<S3FileSystemConfiguration> fromOptions(@Nonnull
 PipelineOptions options)

Description copied from interface: S3FileSystemSchemeRegistrar

Create zero or more S3FileSystemConfiguration instances from the given PipelineOptions.

Each scheme is required to be unique among all schemes registered by all S3FileSystemSchemeRegistrars, as well as among all FileSystems registered by all FileSystemRegistrars.

Specified by:

fromOptions in interface S3FileSystemSchemeRegistrar