public class GSFileSystemOptions extends Object
Modifier and Type | Field and Description |
---|---|
static ConfigOption<MemorySize> |
WRITER_CHUNK_SIZE |
static ConfigOption<String> |
WRITER_TEMPORARY_BUCKET_NAME |
Constructor and Description |
---|
GSFileSystemOptions(Configuration flinkConfig)
Constructs an options instance.
|
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() |
public static final ConfigOption<String> WRITER_TEMPORARY_BUCKET_NAME
public static final ConfigOption<MemorySize> WRITER_CHUNK_SIZE
public GSFileSystemOptions(Configuration flinkConfig)
flinkConfig
- The Flink configurationpublic Optional<String> getWriterTemporaryBucketName()
public Optional<MemorySize> getWriterChunkSize()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.