org.apache.flink.fs.s3.common.utils

Class OffsetAwareOutputStream

java.lang.Object

org.apache.flink.fs.s3.common.utils.OffsetAwareOutputStream

All Implemented Interfaces:

Closeable, AutoCloseable

@Internal
public final class OffsetAwareOutputStream
extends Object
implements Closeable

An OutputStream that keeps track of its current length.

Method Summary

Modifier and Type	Method and Description
void	close()
void	flush()
long	getLength()
void	write(byte[] b, int off, int len)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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:

close in interface Closeable

Specified by:

close in interface AutoCloseable