org.apache.flink.fs.gs

Class GSFileSystemOptions

java.lang.Object

org.apache.flink.fs.gs.GSFileSystemOptions

public class GSFileSystemOptions
extends Object

The GS file system options.

Field Summary

Fields

Modifier and Type	Field and Description
static ConfigOption<MemorySize>	WRITER_CHUNK_SIZE
static ConfigOption<String>	WRITER_TEMPORARY_BUCKET_NAME

Constructor Summary

Constructors

Constructor and Description
GSFileSystemOptions(Configuration flinkConfig) Constructs an options instance.

Method Summary

Modifier and Type	Method and Description
Optional<MemorySize>	getWriterChunkSize() The chunk size to use for writes on the underlying Google WriteChannel.
Optional<String>	getWriterTemporaryBucketName() The temporary bucket name to use for recoverable writes, if different from the final bucket name.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

WRITER_TEMPORARY_BUCKET_NAME

public static final ConfigOption<String> WRITER_TEMPORARY_BUCKET_NAME

WRITER_CHUNK_SIZE

public static final ConfigOption<MemorySize> WRITER_CHUNK_SIZE

Constructor Detail

GSFileSystemOptions

public GSFileSystemOptions(Configuration flinkConfig)

Constructs an options instance.

Parameters:

flinkConfig - The Flink configuration

Method Detail

getWriterTemporaryBucketName

public Optional<String> getWriterTemporaryBucketName()

The temporary bucket name to use for recoverable writes, if different from the final bucket name.

getWriterChunkSize

public Optional<MemorySize> getWriterChunkSize()

The chunk size to use for writes on the underlying Google WriteChannel.

toString

public String toString()

Overrides:

toString in class Object