Package org.apache.iotdb.tsfile.write.chunk

Class ValueChunkWriter

java.lang.Object

org.apache.iotdb.tsfile.write.chunk.ValueChunkWriter

public class ValueChunkWriter
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
ValueChunkWriter(java.lang.String measurementId, CompressionType compressionType, TSDataType dataType, TSEncoding encodingType, Encoder valueEncoder)

Method Summary

Modifier and Type	Method	Description
boolean	checkIsUnsealedPageOverThreshold(long size)
boolean	checkPageSizeAndMayOpenANewPage()
void	clearPageWriter()
long	estimateMaxSeriesMemSize()
CompressionType	getCompressionType()
long	getCurrentChunkSize()
TSDataType	getDataType()
TSEncoding	getEncodingType()
java.lang.String	getMeasurementId()
int	getNumOfPages()
PublicBAOS	getPageBuffer()	only used for test
ValuePageWriter	getPageWriter()
void	sealCurrentPage()
void	write(long[] timestamps, boolean[] values, boolean[] isNull, int batchSize, int pos)
void	write(long[] timestamps, double[] values, boolean[] isNull, int batchSize, int pos)
void	write(long[] timestamps, float[] values, boolean[] isNull, int batchSize, int pos)
void	write(long[] timestamps, int[] values, boolean[] isNull, int batchSize, int pos)
void	write(long[] timestamps, long[] values, boolean[] isNull, int batchSize, int pos)
void	write(long[] timestamps, Binary[] values, boolean[] isNull, int batchSize, int pos)
void	write(long time, boolean value, boolean isNull)
void	write(long time, double value, boolean isNull)
void	write(long time, float value, boolean isNull)
void	write(long time, int value, boolean isNull)
void	write(long time, long value, boolean isNull)
void	write(long time, Binary value, boolean isNull)
void	writeAllPagesOfChunkToTsFile(TsFileIOWriter writer)	write the page to specified IOWriter.
void	writeEmptyPageToPageBuffer()
void	writePageHeaderAndDataIntoBuff(java.nio.ByteBuffer data, PageHeader header)
void	writePageToPageBuffer()
void	writeToFileWriter(TsFileIOWriter tsfileWriter)

Methods inherited from class java.lang.Object

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

Constructor Detail

ValueChunkWriter

public ValueChunkWriter(java.lang.String measurementId,
                        CompressionType compressionType,
                        TSDataType dataType,
                        TSEncoding encodingType,
                        Encoder valueEncoder)

Method Detail

write

public void write(long time,
                  long value,
                  boolean isNull)

write

public void write(long time,
                  int value,
                  boolean isNull)

write

public void write(long time,
                  boolean value,
                  boolean isNull)

write

public void write(long time,
                  float value,
                  boolean isNull)

write

public void write(long time,
                  double value,
                  boolean isNull)

write

public void write(long time,
                  Binary value,
                  boolean isNull)

write

public void write(long[] timestamps,
                  int[] values,
                  boolean[] isNull,
                  int batchSize,
                  int pos)

write

public void write(long[] timestamps,
                  long[] values,
                  boolean[] isNull,
                  int batchSize,
                  int pos)

write

public void write(long[] timestamps,
                  boolean[] values,
                  boolean[] isNull,
                  int batchSize,
                  int pos)

write

public void write(long[] timestamps,
                  float[] values,
                  boolean[] isNull,
                  int batchSize,
                  int pos)

write

public void write(long[] timestamps,
                  double[] values,
                  boolean[] isNull,
                  int batchSize,
                  int pos)

write

public void write(long[] timestamps,
                  Binary[] values,
                  boolean[] isNull,
                  int batchSize,
                  int pos)

writeEmptyPageToPageBuffer

public void writeEmptyPageToPageBuffer()
                                throws java.io.IOException

Throws:

java.io.IOException

writePageToPageBuffer

public void writePageToPageBuffer()

writePageHeaderAndDataIntoBuff

public void writePageHeaderAndDataIntoBuff(java.nio.ByteBuffer data,
                                           PageHeader header)
                                    throws PageException

Throws:

PageException

writeToFileWriter

public void writeToFileWriter(TsFileIOWriter tsfileWriter)
                       throws java.io.IOException

Throws:

java.io.IOException

estimateMaxSeriesMemSize

public long estimateMaxSeriesMemSize()

getCurrentChunkSize

public long getCurrentChunkSize()

checkPageSizeAndMayOpenANewPage

public boolean checkPageSizeAndMayOpenANewPage()

sealCurrentPage

public void sealCurrentPage()

clearPageWriter

public void clearPageWriter()

getNumOfPages

public int getNumOfPages()

getDataType

public TSDataType getDataType()

writeAllPagesOfChunkToTsFile

public void writeAllPagesOfChunkToTsFile(TsFileIOWriter writer)
                                  throws java.io.IOException

write the page to specified IOWriter.

Parameters:

writer - the specified IOWriter

Throws:

java.io.IOException - exception in IO

getMeasurementId

public java.lang.String getMeasurementId()

getEncodingType

public TSEncoding getEncodingType()

getCompressionType

public CompressionType getCompressionType()

getPageBuffer

public PublicBAOS getPageBuffer()

only used for test

checkIsUnsealedPageOverThreshold

public boolean checkIsUnsealedPageOverThreshold(long size)

getPageWriter

public ValuePageWriter getPageWriter()