Class GSFileSystemFactory

  • All Implemented Interfaces:
    org.apache.flink.core.fs.FileSystemFactory, org.apache.flink.core.plugin.Plugin

    public class GSFileSystemFactory
    extends Object
    implements org.apache.flink.core.fs.FileSystemFactory
    Implementation of the Flink FileSystemFactory interface for Google Storage.
    • Constructor Detail

      • GSFileSystemFactory

        public GSFileSystemFactory()
        Constructs the Google Storage file system factory.
    • Method Detail

      • configure

        public void configure​(org.apache.flink.configuration.Configuration flinkConfig)
        Specified by:
        configure in interface org.apache.flink.core.plugin.Plugin
      • getScheme

        public String getScheme()
        Specified by:
        getScheme in interface org.apache.flink.core.fs.FileSystemFactory
      • create

        public org.apache.flink.core.fs.FileSystem create​(URI fsUri)
                                                   throws IOException
        Specified by:
        create in interface org.apache.flink.core.fs.FileSystemFactory
        Throws:
        IOException