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

Class AlignedChunkGroupWriterImpl

java.lang.Object

org.apache.iotdb.tsfile.write.chunk.AlignedChunkGroupWriterImpl

All Implemented Interfaces:

IChunkGroupWriter

public class AlignedChunkGroupWriterImpl
extends Object
implements IChunkGroupWriter

Constructor Summary

Constructors

Constructor	Description
AlignedChunkGroupWriterImpl(String deviceId)

Method Summary

Modifier and Type	Method	Description
long	flushToFileWriter(TsFileIOWriter tsfileWriter)	flushing method for serializing to local file system or HDFS.
long	getCurrentChunkGroupSize()	get the serialized size of current chunkGroup header + all chunks.
Long	getLastTime()
List<String>	getMeasurements()
void	setLastTime(Long lastTime)
void	tryToAddEmptyPageAndData(ValueChunkWriter valueChunkWriter)
void	tryToAddSeriesWriter(List<MeasurementSchema> measurementSchemas)	given a measurement descriptor list, create corresponding writers and put into this ChunkGroupWriter.
void	tryToAddSeriesWriter(MeasurementSchema measurementSchema)	given a measurement descriptor, create a corresponding writer and put into this ChunkGroupWriter.
long	updateMaxGroupMemSize()	get the max memory occupied at this time.
int	write(long time, List<DataPoint> data)	receive a timestamp and a list of data points, write them to their series writers.
int	write(Tablet tablet)	receive a tablet, write it to chunk writers

Methods inherited from class java.lang.Object

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

Constructor Detail

AlignedChunkGroupWriterImpl

public AlignedChunkGroupWriterImpl(String deviceId)

Method Detail

tryToAddSeriesWriter

public void tryToAddSeriesWriter(MeasurementSchema measurementSchema)
                          throws IOException

Description copied from interface: IChunkGroupWriter

given a measurement descriptor, create a corresponding writer and put into this ChunkGroupWriter.

Specified by:

tryToAddSeriesWriter in interface IChunkGroupWriter

Parameters:

measurementSchema - a measurement descriptor containing the message of the series

Throws:

IOException

tryToAddSeriesWriter

public void tryToAddSeriesWriter(List<MeasurementSchema> measurementSchemas)
                          throws IOException

Description copied from interface: IChunkGroupWriter

given a measurement descriptor list, create corresponding writers and put into this ChunkGroupWriter.

Specified by:

tryToAddSeriesWriter in interface IChunkGroupWriter

Throws:

IOException

write

public int write(long time,
                 List<DataPoint> data)
          throws WriteProcessException,
                 IOException

Description copied from interface: IChunkGroupWriter

receive a timestamp and a list of data points, write them to their series writers.

Specified by:

write in interface IChunkGroupWriter

Parameters:

time - - all data points have unify time stamp.

data - - data point list to input

Throws:

WriteProcessException - exception in write process

IOException - exception in IO

write

public int write(Tablet tablet)
          throws WriteProcessException,
                 IOException

Description copied from interface: IChunkGroupWriter

receive a tablet, write it to chunk writers

Specified by:

write in interface IChunkGroupWriter

Throws:

WriteProcessException - exception in write process

IOException - exception in IO

flushToFileWriter

public long flushToFileWriter(TsFileIOWriter tsfileWriter)
                       throws IOException

Description copied from interface: IChunkGroupWriter

flushing method for serializing to local file system or HDFS. Implemented by ChunkWriterImpl.writeToFileWriter().

Specified by:

flushToFileWriter in interface IChunkGroupWriter

Parameters:

tsfileWriter - - TSFileIOWriter

Returns:

current ChunkGroupDataSize

Throws:

IOException - exception in IO

updateMaxGroupMemSize

public long updateMaxGroupMemSize()

Description copied from interface: IChunkGroupWriter

get the max memory occupied at this time. Note that, this method should be called after running long calcAllocatedSize()

Specified by:

updateMaxGroupMemSize in interface IChunkGroupWriter

Returns:

- allocated memory size.

getCurrentChunkGroupSize

public long getCurrentChunkGroupSize()

Description copied from interface: IChunkGroupWriter

get the serialized size of current chunkGroup header + all chunks. Notice, the value does not include any un-sealed page in the chunks.

Specified by:

getCurrentChunkGroupSize in interface IChunkGroupWriter

Returns:

the serialized size of current chunkGroup header + all chunk

tryToAddEmptyPageAndData

public void tryToAddEmptyPageAndData(ValueChunkWriter valueChunkWriter)
                              throws IOException

Throws:

IOException

getMeasurements

public List<String> getMeasurements()

getLastTime

public Long getLastTime()

setLastTime

public void setLastTime(Long lastTime)