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

Class TSMIterator

java.lang.Object

org.apache.iotdb.tsfile.write.writer.tsmiterator.TSMIterator

Direct Known Subclasses:

DiskTSMIterator

public class TSMIterator
extends Object

TSMIterator returns full path of series and its TimeseriesMetadata iteratively. It accepts data source from memory or disk. Static method getTSMIteratorInMemory returns a TSMIterator that reads from memory, and static method getTSMIteratorInDisk returns a TSMIterator that reads from disk.

Field Summary

Fields

Modifier and Type	Field	Description
protected Iterator<Pair<Path,List<IChunkMetadata>>>	iterator
protected List<Pair<Path,List<IChunkMetadata>>>	sortedChunkMetadataList

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TSMIterator(List<ChunkGroupMetadata> chunkGroupMetadataList)

Method Summary

Modifier and Type	Method	Description
static TimeseriesMetadata	constructOneTimeseriesMetadata(String measurementId, List<IChunkMetadata> chunkMetadataList)
static TSMIterator	getTSMIteratorInDisk(File cmtFile, List<ChunkGroupMetadata> chunkGroupMetadataList, LinkedList<Long> serializePos)
static TSMIterator	getTSMIteratorInMemory(List<ChunkGroupMetadata> chunkGroupMetadataList)
boolean	hasNext()
Pair<Path,TimeseriesMetadata>	next()
static List<Pair<Path,List<IChunkMetadata>>>	sortChunkMetadata(List<ChunkGroupMetadata> chunkGroupMetadataList, String currentDevice, List<ChunkMetadata> chunkMetadataList)

Methods inherited from class java.lang.Object

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

Field Detail

sortedChunkMetadataList

protected List<Pair<Path,List<IChunkMetadata>>> sortedChunkMetadataList

iterator

protected Iterator<Pair<Path,List<IChunkMetadata>>> iterator

Constructor Detail

TSMIterator

protected TSMIterator(List<ChunkGroupMetadata> chunkGroupMetadataList)

Method Detail

getTSMIteratorInMemory

public static TSMIterator getTSMIteratorInMemory(List<ChunkGroupMetadata> chunkGroupMetadataList)

getTSMIteratorInDisk

public static TSMIterator getTSMIteratorInDisk(File cmtFile,
                                               List<ChunkGroupMetadata> chunkGroupMetadataList,
                                               LinkedList<Long> serializePos)
                                        throws IOException

Throws:

IOException

hasNext

public boolean hasNext()

next

public Pair<Path,TimeseriesMetadata> next()
                                         throws IOException

Throws:

IOException

constructOneTimeseriesMetadata

public static TimeseriesMetadata constructOneTimeseriesMetadata(String measurementId,
                                                                List<IChunkMetadata> chunkMetadataList)
                                                         throws IOException

Throws:

IOException

sortChunkMetadata

public static List<Pair<Path,List<IChunkMetadata>>> sortChunkMetadata(List<ChunkGroupMetadata> chunkGroupMetadataList,
                                                                            String currentDevice,
                                                                            List<ChunkMetadata> chunkMetadataList)