Interface FileSystem

  • All Superinterfaces:
    java.io.Serializable
    All Known Implementing Classes:
    GCloudFileSystem, S3FileSystem

    @Internal
    public interface FileSystem
    extends java.io.Serializable
    A proxima's abstraction of bulk FS.
    • Method Detail

      • getUri

        java.net.URI getUri()
        Ger URI representation of this FileSystem
        Returns:
        the URI of this FileSystem
      • list

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

        Path newPath​(long ts)
        Create new Path.
        Parameters:
        ts - timestamp to create the path for
        Returns:
        new abstract Path object
      • list

        default java.util.stream.Stream<Path> list()
        Get all Paths on this FileSystem
        Returns:
        all paths on this FileSystem