Package org.apache.iotdb.tsfile.utils

Class TsFileGeneratorUtils

java.lang.Object

org.apache.iotdb.tsfile.utils.TsFileGeneratorUtils

public class TsFileGeneratorUtils
extends java.lang.Object

This class is only used for generating aligned or nonAligned tsfiles in test.

Field Summary

Fields

Modifier and Type	Field	Description
static int	alignDeviceOffset
static java.lang.String	testStorageGroup

Constructor Summary

Constructors

Constructor	Description
TsFileGeneratorUtils()

Method Summary

Modifier and Type	Method	Description
static java.io.File	generateAlignedTsFile(java.lang.String filePath, int deviceNum, int measurementNum, int pointNum, int startTime, int startValue, int chunkGroupSize, int pageSize)
static java.io.File	generateAlignedTsFileWithTextValues(java.lang.String filePath, java.util.List<java.lang.Integer> deviceIndex, java.util.List<java.lang.Integer> measurementIndex, int pointNum, int startTime, java.lang.String value, int chunkGroupSize, int pageSize)
static java.io.File	generateMixTsFile(java.lang.String filePath, int deviceNum, int measurementNum, int pointNum, int startTime, int startValue, int chunkGroupSize, int pageSize)
static java.io.File	generateNonAlignedTsFile(java.lang.String filePath, int deviceNum, int measurementNum, int pointNum, int startTime, int startValue, int chunkGroupSize, int pageSize)
static java.io.File	generateNonAlignedTsFileWithTextValues(java.lang.String filePath, java.util.List<java.lang.Integer> deviceIndex, java.util.List<java.lang.Integer> measurementIndex, int pointNum, int startTime, java.lang.String value, int chunkGroupSize, int pageSize)
static int	getAlignDeviceOffset()
static java.lang.String	getTsFilePath(java.lang.String fileParentPath, long tsFileVersion)
static void	writeWithTablet(TsFileWriter tsFileWriter, java.lang.String deviceId, java.util.List<MeasurementSchema> schemas, long rowNum, long startTime, long startValue, boolean isAligned)
static void	writeWithTsRecord(TsFileWriter tsFileWriter, java.lang.String deviceId, java.util.List<MeasurementSchema> schemas, long rowSize, long startTime, long startValue, boolean isAligned)

Methods inherited from class java.lang.Object

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

Field Detail

testStorageGroup

public static final java.lang.String testStorageGroup

See Also:

Constant Field Values

alignDeviceOffset

public static int alignDeviceOffset

Constructor Detail

TsFileGeneratorUtils

public TsFileGeneratorUtils()

Method Detail

writeWithTsRecord

public static void writeWithTsRecord(TsFileWriter tsFileWriter,
                                     java.lang.String deviceId,
                                     java.util.List<MeasurementSchema> schemas,
                                     long rowSize,
                                     long startTime,
                                     long startValue,
                                     boolean isAligned)
                              throws java.io.IOException,
                                     WriteProcessException

Throws:

java.io.IOException

WriteProcessException

writeWithTablet

public static void writeWithTablet(TsFileWriter tsFileWriter,
                                   java.lang.String deviceId,
                                   java.util.List<MeasurementSchema> schemas,
                                   long rowNum,
                                   long startTime,
                                   long startValue,
                                   boolean isAligned)
                            throws java.io.IOException,
                                   WriteProcessException

Throws:

java.io.IOException

WriteProcessException

generateMixTsFile

public static java.io.File generateMixTsFile(java.lang.String filePath,
                                             int deviceNum,
                                             int measurementNum,
                                             int pointNum,
                                             int startTime,
                                             int startValue,
                                             int chunkGroupSize,
                                             int pageSize)
                                      throws java.io.IOException,
                                             WriteProcessException

Throws:

java.io.IOException

WriteProcessException

generateAlignedTsFile

public static java.io.File generateAlignedTsFile(java.lang.String filePath,
                                                 int deviceNum,
                                                 int measurementNum,
                                                 int pointNum,
                                                 int startTime,
                                                 int startValue,
                                                 int chunkGroupSize,
                                                 int pageSize)
                                          throws java.io.IOException,
                                                 WriteProcessException

Throws:

java.io.IOException

WriteProcessException

generateNonAlignedTsFile

public static java.io.File generateNonAlignedTsFile(java.lang.String filePath,
                                                    int deviceNum,
                                                    int measurementNum,
                                                    int pointNum,
                                                    int startTime,
                                                    int startValue,
                                                    int chunkGroupSize,
                                                    int pageSize)
                                             throws java.io.IOException,
                                                    WriteProcessException

Throws:

java.io.IOException

WriteProcessException

generateAlignedTsFileWithTextValues

public static java.io.File generateAlignedTsFileWithTextValues(java.lang.String filePath,
                                                               java.util.List<java.lang.Integer> deviceIndex,
                                                               java.util.List<java.lang.Integer> measurementIndex,
                                                               int pointNum,
                                                               int startTime,
                                                               java.lang.String value,
                                                               int chunkGroupSize,
                                                               int pageSize)
                                                        throws java.io.IOException,
                                                               WriteProcessException

Throws:

java.io.IOException

WriteProcessException

generateNonAlignedTsFileWithTextValues

public static java.io.File generateNonAlignedTsFileWithTextValues(java.lang.String filePath,
                                                                  java.util.List<java.lang.Integer> deviceIndex,
                                                                  java.util.List<java.lang.Integer> measurementIndex,
                                                                  int pointNum,
                                                                  int startTime,
                                                                  java.lang.String value,
                                                                  int chunkGroupSize,
                                                                  int pageSize)
                                                           throws java.io.IOException,
                                                                  WriteProcessException

Throws:

java.io.IOException

WriteProcessException

getTsFilePath

public static java.lang.String getTsFilePath(java.lang.String fileParentPath,
                                             long tsFileVersion)

getAlignDeviceOffset

public static int getAlignDeviceOffset()