public class GSFileSystemOptions extends Object
Modifier and Type | Field and Description |
---|---|
static ConfigOption<Boolean> |
ENABLE_FILESINK_ENTROPY |
static ConfigOption<Integer> |
GCS_HTTP_CONNECT_TIMEOUT
Flink config option to set the http connection timeout.
|
static ConfigOption<Integer> |
GCS_HTTP_READ_TIMEOUT
Flink config option to set the http read timeout.
|
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<Integer> |
getHTTPConnectionTimeout()
Timeout in millisecond to establish the connection.
|
Optional<Integer> |
getHTTPReadTimeout()
Timeout in millisecond to read content from connection.
|
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.
|
Boolean |
isFileSinkEntropyEnabled()
Whether entropy insertion is enabled in filesink path.
|
String |
toString() |
public static final ConfigOption<String> WRITER_TEMPORARY_BUCKET_NAME
public static final ConfigOption<MemorySize> WRITER_CHUNK_SIZE
public static final ConfigOption<Boolean> ENABLE_FILESINK_ENTROPY
public static final ConfigOption<Integer> GCS_HTTP_CONNECT_TIMEOUT
public static final ConfigOption<Integer> GCS_HTTP_READ_TIMEOUT
public GSFileSystemOptions(Configuration flinkConfig)
flinkConfig
- The Flink configurationpublic Optional<String> getWriterTemporaryBucketName()
public Optional<Integer> getHTTPConnectionTimeout()
public Optional<Integer> getHTTPReadTimeout()
public Optional<MemorySize> getWriterChunkSize()
public Boolean isFileSinkEntropyEnabled()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.