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 java.lang.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 java.util.Iterator<Pair<Path,java.util.List<IChunkMetadata>>>	iterator
protected java.util.List<Pair<Path,java.util.List<IChunkMetadata>>>	sortedChunkMetadataList

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
static TimeseriesMetadata	constructOneTimeseriesMetadata(java.lang.String measurementId, java.util.List<IChunkMetadata> chunkMetadataList)
static TSMIterator	getTSMIteratorInDisk(java.io.File cmtFile, java.util.List<ChunkGroupMetadata> chunkGroupMetadataList, java.util.LinkedList<java.lang.Long> serializePos)
static TSMIterator	getTSMIteratorInMemory(java.util.List<ChunkGroupMetadata> chunkGroupMetadataList)
boolean	hasNext()
Pair<Path,TimeseriesMetadata>	next()
static java.util.List<Pair<Path,java.util.List<IChunkMetadata>>>	sortChunkMetadata(java.util.List<ChunkGroupMetadata> chunkGroupMetadataList, java.lang.String currentDevice, java.util.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 java.util.List<Pair<Path,java.util.List<IChunkMetadata>>> sortedChunkMetadataList

iterator

protected java.util.Iterator<Pair<Path,java.util.List<IChunkMetadata>>> iterator

Constructor Detail

TSMIterator

protected TSMIterator(java.util.List<ChunkGroupMetadata> chunkGroupMetadataList)

Method Detail

getTSMIteratorInMemory

public static TSMIterator getTSMIteratorInMemory(java.util.List<ChunkGroupMetadata> chunkGroupMetadataList)

getTSMIteratorInDisk

public static TSMIterator getTSMIteratorInDisk(java.io.File cmtFile,
                                               java.util.List<ChunkGroupMetadata> chunkGroupMetadataList,
                                               java.util.LinkedList<java.lang.Long> serializePos)
                                        throws java.io.IOException

Throws:

java.io.IOException

hasNext

public boolean hasNext()

next

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

Throws:

java.io.IOException

constructOneTimeseriesMetadata

public static TimeseriesMetadata constructOneTimeseriesMetadata(java.lang.String measurementId,
                                                                java.util.List<IChunkMetadata> chunkMetadataList)
                                                         throws java.io.IOException

Throws:

java.io.IOException

sortChunkMetadata

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