Package cz.o2.proxima.direct.io.bulkfs
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 Summary
All Methods Static Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description java.net.URI
getUri()
GerURI
representation of this FileSystemdefault java.util.stream.Stream<Path>
list()
Get allPaths
on this FileSystemjava.util.stream.Stream<Path>
list(long minTs, long maxTs)
Return stream ofPaths
that represent given time range.static FileSystem
local(java.io.File parent, NamingConvention convention)
Path
newPath(long ts)
Create newPath
.
-
-
-
Method Detail
-
local
static FileSystem local(java.io.File parent, NamingConvention convention)
-
getUri
java.net.URI getUri()
GerURI
representation of this FileSystem- Returns:
- the URI of this FileSystem
-
list
java.util.stream.Stream<Path> list(long minTs, long maxTs)
Return stream ofPaths
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 newPath
.- Parameters:
ts
- timestamp to create the path for- Returns:
- new abstract
Path
object
-
-