Package cz.o2.proxima.direct.io.bulkfs
Interface Writer
-
- All Superinterfaces:
java.lang.AutoCloseable
,java.io.Closeable
- All Known Implementing Classes:
ProximaParquetWriter
public interface Writer extends java.io.Closeable
Proxima's abstraction of writer for bulk data.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
close()
Close and flush the writer to targetFileSystem
.Path
getPath()
GetPath
associated with the Writer.void
write(StreamElement elem)
WriteStreamElement
into this blob store.
-
-
-
Method Detail
-
write
void write(StreamElement elem) throws java.io.IOException
WriteStreamElement
into this blob store.- Parameters:
elem
- the element to write- Throws:
java.io.IOException
- on errors
-
close
void close() throws java.io.IOException
Close and flush the writer to targetFileSystem
. Note that the associatedPath
might be visible on the target FileSystem only after closing associated writer.- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Throws:
java.io.IOException
- on errors
-
-