Package org.apache.flink.fs.gs

Class GSFileSystemOptions

  • public class GSFileSystemOptions
extends Object
    The GS file system options.

    • 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

      • ENABLE_FILESINK_ENTROPY

        public static final org.apache.flink.configuration.ConfigOption<Boolean> ENABLE_FILESINK_ENTROPY

    • Constructor Detail

      • GSFileSystemOptions

        public GSFileSystemOptions​(org.apache.flink.configuration.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<org.apache.flink.configuration.MemorySize> getWriterChunkSize()
        The chunk size to use for writes on the underlying Google WriteChannel.

      • isFileSinkEntropyEnabled

        public Boolean isFileSinkEntropyEnabled()
        Whether entropy insertion is enabled in filesink path.