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

Class TimeChunkWriter

java.lang.Object

org.apache.iotdb.tsfile.write.chunk.TimeChunkWriter

public class TimeChunkWriter
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
TimeChunkWriter(java.lang.String measurementId, CompressionType compressionType, TSEncoding encodingType, Encoder timeEncoder)

Method Summary

Modifier and Type	Method	Description
boolean	checkIsUnsealedPageOverThreshold(long size, long pointNum)
boolean	checkPageSizeAndMayOpenANewPage()	check occupied memory size, if it exceeds the PageSize threshold, construct a page and put it to pageBuffer
void	clearPageWriter()
long	estimateMaxSeriesMemSize()
long	getCurrentChunkSize()
TSDataType	getDataType()
int	getNumOfPages()
PublicBAOS	getPageBuffer()	only used for test
TimePageWriter	getPageWriter()
long	getPointNum()
long	getRemainingPointNumberForCurrentPage()
void	sealCurrentPage()
void	write(long time)
void	write(long[] timestamps, int batchSize, int arrayOffset)
void	writeAllPagesOfChunkToTsFile(TsFileIOWriter writer)	write the page to specified IOWriter.
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

TimeChunkWriter

public TimeChunkWriter(java.lang.String measurementId,
                       CompressionType compressionType,
                       TSEncoding encodingType,
                       Encoder timeEncoder)

Method Detail

write

public void write(long time)

write

public void write(long[] timestamps,
                  int batchSize,
                  int arrayOffset)

checkPageSizeAndMayOpenANewPage

public boolean checkPageSizeAndMayOpenANewPage()

check occupied memory size, if it exceeds the PageSize threshold, construct a page and put it to pageBuffer

getRemainingPointNumberForCurrentPage

public long getRemainingPointNumberForCurrentPage()

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()

sealCurrentPage

public void sealCurrentPage()

clearPageWriter

public void clearPageWriter()

getNumOfPages

public int getNumOfPages()

getDataType

public TSDataType getDataType()

getPointNum

public long getPointNum()

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

getPageBuffer

public PublicBAOS getPageBuffer()

only used for test

getPageWriter

public TimePageWriter getPageWriter()

checkIsUnsealedPageOverThreshold

public boolean checkIsUnsealedPageOverThreshold(long size,
                                                long pointNum)