未验证 提交 e9fe0b10 编写于 作者: C Christofer Dutz 提交者: GitHub

Feature/simplified tsfile examples (#10906)

上级 4341c152
...@@ -68,12 +68,8 @@ public class TsFileWriteAlignedWithTSRecord { ...@@ -68,12 +68,8 @@ public class TsFileWriteAlignedWithTSRecord {
// register timeseries // register timeseries
tsFileWriter.registerAlignedTimeseries(new Path(DEVICE_1), measurementSchemas); tsFileWriter.registerAlignedTimeseries(new Path(DEVICE_1), measurementSchemas);
List<IMeasurementSchema> writeMeasurementScheams = new ArrayList<>();
// example1 // example1
writeMeasurementScheams.add(measurementSchemas.get(0)); writeAligned(tsFileWriter, DEVICE_1, measurementSchemas, 1000000, 0, 0);
writeMeasurementScheams.add(measurementSchemas.get(1));
writeMeasurementScheams.add(measurementSchemas.get(2));
writeAligned(tsFileWriter, DEVICE_1, writeMeasurementScheams, 1000000, 0, 0);
} catch (WriteProcessException e) { } catch (WriteProcessException e) {
logger.error("write TSRecord failed", e); logger.error("write TSRecord failed", e);
} }
...@@ -82,7 +78,7 @@ public class TsFileWriteAlignedWithTSRecord { ...@@ -82,7 +78,7 @@ public class TsFileWriteAlignedWithTSRecord {
private static void writeAligned( private static void writeAligned(
TsFileWriter tsFileWriter, TsFileWriter tsFileWriter,
String deviceId, String deviceId,
List<IMeasurementSchema> schemas, List<MeasurementSchema> schemas,
long rowSize, long rowSize,
long startTime, long startTime,
long startValue) long startValue)
......
...@@ -66,12 +66,8 @@ public class TsFileWriteAlignedWithTablet { ...@@ -66,12 +66,8 @@ public class TsFileWriteAlignedWithTablet {
// register align timeseries // register align timeseries
tsFileWriter.registerAlignedTimeseries(new Path(DEVICE_1), measurementSchemas); tsFileWriter.registerAlignedTimeseries(new Path(DEVICE_1), measurementSchemas);
List<MeasurementSchema> writeMeasurementScheams = new ArrayList<>();
// example 1 // example 1
writeMeasurementScheams.add(measurementSchemas.get(0)); writeAlignedWithTablet(tsFileWriter, DEVICE_1, measurementSchemas, 200000, 0, 0);
writeMeasurementScheams.add(measurementSchemas.get(1));
writeMeasurementScheams.add(measurementSchemas.get(2));
writeAlignedWithTablet(tsFileWriter, DEVICE_1, writeMeasurementScheams, 200000, 0, 0);
writeNonAlignedWithTablet(tsFileWriter); // write nonAligned timeseries writeNonAlignedWithTablet(tsFileWriter); // write nonAligned timeseries
} catch (WriteProcessException e) { } catch (WriteProcessException e) {
......
...@@ -69,12 +69,8 @@ public class TsFileWriteWithTSRecord { ...@@ -69,12 +69,8 @@ public class TsFileWriteWithTSRecord {
// register timeseries // register timeseries
tsFileWriter.registerTimeseries(new Path(DEVICE_1), schemas); tsFileWriter.registerTimeseries(new Path(DEVICE_1), schemas);
List<IMeasurementSchema> writeMeasurementScheams = new ArrayList<>();
// example1 // example1
writeMeasurementScheams.add(schemas.get(0)); write(tsFileWriter, DEVICE_1, schemas, 10000, 0, 0);
writeMeasurementScheams.add(schemas.get(1));
writeMeasurementScheams.add(schemas.get(2));
write(tsFileWriter, DEVICE_1, writeMeasurementScheams, 10000, 0, 0);
} }
} catch (Exception e) { } catch (Exception e) {
logger.error("TsFileWriteWithTSRecord meet error", e); logger.error("TsFileWriteWithTSRecord meet error", e);
...@@ -84,7 +80,7 @@ public class TsFileWriteWithTSRecord { ...@@ -84,7 +80,7 @@ public class TsFileWriteWithTSRecord {
private static void write( private static void write(
TsFileWriter tsFileWriter, TsFileWriter tsFileWriter,
String deviceId, String deviceId,
List<IMeasurementSchema> schemas, List<MeasurementSchema> schemas,
long rowSize, long rowSize,
long startTime, long startTime,
long startValue) long startValue)
......
...@@ -65,12 +65,8 @@ public class TsFileWriteWithTablet { ...@@ -65,12 +65,8 @@ public class TsFileWriteWithTablet {
// register nonAligned timeseries // register nonAligned timeseries
tsFileWriter.registerTimeseries(new Path(DEVICE_1), measurementSchemas); tsFileWriter.registerTimeseries(new Path(DEVICE_1), measurementSchemas);
List<MeasurementSchema> writeMeasurementScheams = new ArrayList<>();
// example 1 // example 1
writeMeasurementScheams.add(measurementSchemas.get(0)); writeWithTablet(tsFileWriter, DEVICE_1, measurementSchemas, 10000, 0, 0);
writeMeasurementScheams.add(measurementSchemas.get(1));
writeMeasurementScheams.add(measurementSchemas.get(2));
writeWithTablet(tsFileWriter, DEVICE_1, writeMeasurementScheams, 10000, 0, 0);
} }
} catch (Exception e) { } catch (Exception e) {
logger.error("meet error in TsFileWrite with tablet", e); logger.error("meet error in TsFileWrite with tablet", e);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册