Class GCloudFileSystem

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.lang.String getBucket()  
      com.google.cloud.storage.Storage getClient()  
      java.lang.String getPath()  
      RetryStrategy getRetry()  
      com.google.cloud.storage.StorageClass getStorageClass()  
      java.net.URI getUri()
      Ger URI representation of this FileSystem
      java.util.stream.Stream<Path> list​(long minTs, long maxTs)
      Return stream of Paths that represent given time range.
      Path newPath​(long ts)
      Create new Path.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
      • Methods inherited from interface cz.o2.proxima.direct.io.bulkfs.FileSystem

        list
    • Method Detail

      • getUri

        public java.net.URI getUri()
        Description copied from interface: FileSystem
        Ger URI representation of this FileSystem
        Specified by:
        getUri in interface FileSystem
        Returns:
        the URI of this FileSystem
      • list

        public java.util.stream.Stream<Path> list​(long minTs,
                                                  long maxTs)
        Description copied from interface: FileSystem
        Return stream of Paths that represent given time range.
        Specified by:
        list in interface FileSystem
        Parameters:
        minTs - minimal allowed timestamp (inclusive)
        maxTs - maximal allowd timestamp (exclusive)
        Returns:
        stream of Paths satisfying given time range
      • newPath

        public Path newPath​(long ts)
        Description copied from interface: FileSystem
        Create new Path.
        Specified by:
        newPath in interface FileSystem
        Parameters:
        ts - timestamp to create the path for
        Returns:
        new abstract Path object
      • getBucket

        public java.lang.String getBucket()
      • getPath

        public java.lang.String getPath()
      • getStorageClass

        public com.google.cloud.storage.StorageClass getStorageClass()
      • getClient

        @Nullable
        public com.google.cloud.storage.Storage getClient()