Package 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 Description static org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize>WRITER_CHUNK_SIZEstatic org.apache.flink.configuration.ConfigOption<String>WRITER_TEMPORARY_BUCKET_NAME
-
Constructor Summary
Constructors Constructor Description GSFileSystemOptions(org.apache.flink.configuration.Configuration flinkConfig)Constructs an options instance.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Optional<org.apache.flink.configuration.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.StringtoString()
-
-
-
Field Detail
-
WRITER_TEMPORARY_BUCKET_NAME
public static final org.apache.flink.configuration.ConfigOption<String> WRITER_TEMPORARY_BUCKET_NAME
-
WRITER_CHUNK_SIZE
public static final org.apache.flink.configuration.ConfigOption<org.apache.flink.configuration.MemorySize> WRITER_CHUNK_SIZE
-
-
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<org.apache.flink.configuration.MemorySize> getWriterChunkSize()
The chunk size to use for writes on the underlying Google WriteChannel.
-
-