Page History

...

• for chunkMetadata in sensorChunkMetadataList
  • chunk = readMemChunk(chunkMetadata)
  • unclosedChunkPoint = 0L
  • tsFileResource.updateStartTime(chunkMetadata.startTime)
  • tsFileResource.updateEndTime(chunkMetadata.endTime)
  • 判断当前 chunk 是否被修改 modified
  • if isOverlap(chunkMetadata)
    • 将其与乱序数据重叠的部分合并后写入 ChunkWriter（见 算法2）
    • unclosedChunkPoint+=写入的点数
  • else if isChunkTooSmall(chunkMetadata)
    • 将这个 Chunk 解压缩后写入 ChunkWriter
    • unclosedChunkPoint+=写入的点数
  • else
    • if  unclosedChunkPoint > 0 || modifiedif  unclosedChunkPoint>0
      
      • 将这个 Chunk 解压缩后写入 ChunkWriter
    • else 
      • 将这个 Chunk 不解压缩写入 writer
  • if unclosedChunkPoint > merge_chunk_point_num_threshold
    • 将 ChunkWriter 写入 writer
    • unclosedChunkPoint = 0

...

输入：chunk, unseqReader, deviceEndTime, tsFileResource, modification

• 对 Chunk 构建一个 ChunkReader
• 使用 ChunkReader 获取 Chunk 中的每一个 Page
  • while pageData.hasNext() 
    • 获取 pageData 当前的时间戳 seqTime
    • overwriteSeqPoint = false
    • while 该 sensor 还有乱序数据并且乱序数据的下一个时间戳小于 seqTime
      • 将乱序数据写入 ChunkWrtier 中
      • tsFileResource.updateStartTime(乱序数据)
      • tsFileResource.updateEndTime(乱序数据)
      • 如果乱序数据的时间戳 == seqTime
        • overwriteSeqPoint = true
    • 根据 算法3 将该 unseqReader 小于等于 deviceEndTime 的剩余数据写入 ChunkWriter 中
    • if !overwriteSeqPoint && pageData 当前时间戳在 modification 中被删除
      • 将 pageData 当前的数据点写入 ChunkWriter 中
      • tsFileResource.updateStartTime(乱序数据)
      • tsFileResource.updateEndTime(乱序数据)

...