Package org.apache.iotdb.tsfile.write.writer

Class LocalTsFileOutput

java.lang.Object

java.io.OutputStream

org.apache.iotdb.tsfile.write.writer.LocalTsFileOutput

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, TsFileOutput

public class LocalTsFileOutput
extends OutputStream
implements TsFileOutput

a TsFileOutput implementation with FileOutputStream. If the file is not existed, it will be created. Otherwise the file will be written from position 0.

Constructor Summary

Constructors

Constructor	Description
LocalTsFileOutput(FileOutputStream outputStream)

Method Summary

Modifier and Type	Method	Description
void	close()	close the output.
void	flush()	the same with OutputStream.flush().
void	force()	Make sure that the data in the buffer is flushed to disk
long	getPosition()	gets the current position of the Output.
void	truncate(long size)	The same with FileChannel.truncate(long).
OutputStream	wrapAsStream()	convert this TsFileOutput as a outputstream.
void	write(byte b)	Writes 1 byte to this output at the current position.
void	write(byte[] b)	Writes b.length bytes from the specified byte array to this output at the current position.
void	write(byte[] buf, int start, int offset)
void	write(int b)
void	write(ByteBuffer b)	Writes b.remaining() bytes from the specified byte array to this output at the current position.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalTsFileOutput

public LocalTsFileOutput(FileOutputStream outputStream)

Method Detail

write

public void write(int b)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] b)
           throws IOException

Description copied from interface: TsFileOutput

Writes b.length bytes from the specified byte array to this output at the current position.

Specified by:

write in interface TsFileOutput

Overrides:

write in class OutputStream

Parameters:

b - the data.

Throws:

IOException - if an I/O error occurs.

write

public void write(byte b)
           throws IOException

Description copied from interface: TsFileOutput

Writes 1 byte to this output at the current position.

Specified by:

write in interface TsFileOutput

Parameters:

b - the data.

Throws:

IOException - if an I/O error occurs.

write

public void write(byte[] buf,
                  int start,
                  int offset)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

write

public void write(ByteBuffer b)
           throws IOException

Description copied from interface: TsFileOutput

Writes b.remaining() bytes from the specified byte array to this output at the current position.

Specified by:

write in interface TsFileOutput

Parameters:

b - the data.

Throws:

IOException - if an I/O error occurs.

getPosition

public long getPosition()

Description copied from interface: TsFileOutput

gets the current position of the Output. This method is usually used for recording where the data is.
For example, if the Output is a fileOutputStream, then getPosition returns its file position.

Specified by:

getPosition in interface TsFileOutput

Returns:

current position

close

public void close()
           throws IOException

Description copied from interface: TsFileOutput

close the output.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface TsFileOutput

Overrides:

close in class OutputStream

Throws:

IOException - if an I/O error occurs.

wrapAsStream

public OutputStream wrapAsStream()

Description copied from interface: TsFileOutput

convert this TsFileOutput as a outputstream.

Specified by:

wrapAsStream in interface TsFileOutput

Returns:

an output stream whose position is the same with this Output

flush

public void flush()
           throws IOException

Description copied from interface: TsFileOutput

the same with OutputStream.flush().

Specified by:

flush in interface Flushable

Specified by:

flush in interface TsFileOutput

Overrides:

flush in class OutputStream

Throws:

IOException - if an I/O error occurs.

truncate

public void truncate(long size)
              throws IOException

Description copied from interface: TsFileOutput

The same with FileChannel.truncate(long).

Specified by:

truncate in interface TsFileOutput

Parameters:

size - size The new size, a non-negative byte count

Throws:

IOException

force

public void force()
           throws IOException

Description copied from interface: TsFileOutput

Make sure that the data in the buffer is flushed to disk

Specified by:

force in interface TsFileOutput

Throws:

IOException