Package org.apache.flink.core.fs
Class OffsetAwareOutputStream
- java.lang.Object
-
- org.apache.flink.core.fs.OffsetAwareOutputStream
-
- All Implemented Interfaces:
Closeable,AutoCloseable
@Internal public final class OffsetAwareOutputStream extends Object implements Closeable
AnOutputStreamthat keeps track of its current length.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()voidflush()longgetLength()voidwrite(byte[] b, int off, int len)
-
-
-
Method Detail
-
getLength
public long getLength()
-
write
public void write(byte[] b, int off, int len) throws IOException- Throws:
IOException
-
flush
public void flush() throws IOException- Throws:
IOException
-
close
public void close()
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable
-
-