Package org.apache.iotdb.tsfile.utils

Class TsFileGeneratorUtils

java.lang.Object

org.apache.iotdb.tsfile.utils.TsFileGeneratorUtils

public class TsFileGeneratorUtils
extends 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 String	testStorageGroup

Constructor Summary

Constructors

Constructor	Description
TsFileGeneratorUtils()

Method Summary

Modifier and Type	Method	Description
static File	generateAlignedTsFile(String filePath, int deviceNum, int measurementNum, int pointNum, int startTime, int startValue, int chunkGroupSize, int pageSize)
static File	generateAlignedTsFileWithTextValues(String filePath, List<Integer> deviceIndex, List<Integer> measurementIndex, int pointNum, int startTime, String value, int chunkGroupSize, int pageSize)
static File	generateMixTsFile(String filePath, int deviceNum, int measurementNum, int pointNum, int startTime, int startValue, int chunkGroupSize, int pageSize)
static File	generateNonAlignedTsFile(String filePath, int deviceNum, int measurementNum, int pointNum, int startTime, int startValue, int chunkGroupSize, int pageSize)
static File	generateNonAlignedTsFileWithTextValues(String filePath, List<Integer> deviceIndex, List<Integer> measurementIndex, int pointNum, int startTime, String value, int chunkGroupSize, int pageSize)
static int	getAlignDeviceOffset()
static String	getTsFilePath(String fileParentPath, long tsFileVersion)
static void	writeWithTablet(TsFileWriter tsFileWriter, String deviceId, List<MeasurementSchema> schemas, long rowNum, long startTime, long startValue, boolean isAligned)
static void	writeWithTsRecord(TsFileWriter tsFileWriter, String deviceId, 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 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,
                                     String deviceId,
                                     List<MeasurementSchema> schemas,
                                     long rowSize,
                                     long startTime,
                                     long startValue,
                                     boolean isAligned)
                              throws IOException,
                                     WriteProcessException

Throws:

IOException

WriteProcessException

writeWithTablet

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

Throws:

IOException

WriteProcessException

generateMixTsFile

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

Throws:

IOException

WriteProcessException

generateAlignedTsFile

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

Throws:

IOException

WriteProcessException

generateNonAlignedTsFile

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

Throws:

IOException

WriteProcessException

generateAlignedTsFileWithTextValues

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

Throws:

IOException

WriteProcessException

generateNonAlignedTsFileWithTextValues

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

Throws:

IOException

WriteProcessException

getTsFilePath

public static String getTsFilePath(String fileParentPath,
                                   long tsFileVersion)

getAlignDeviceOffset

public static int getAlignDeviceOffset()