diff --git a/core/src/main/java/cn/edu/tsinghua/iot/benchmark/schema/MetaUtil.java b/core/src/main/java/cn/edu/tsinghua/iot/benchmark/schema/MetaUtil.java index a4680abf6..495c7dc53 100644 --- a/core/src/main/java/cn/edu/tsinghua/iot/benchmark/schema/MetaUtil.java +++ b/core/src/main/java/cn/edu/tsinghua/iot/benchmark/schema/MetaUtil.java @@ -126,7 +126,7 @@ public static void distributeDevices( deviceSchemasList.add(deviceSchema); nameDataSchema.putIfAbsent(deviceSchema.getDevice(), deviceSchema); groups.add(deviceSchema.getGroup()); - if(collectTables){ + if (collectTables) { MetaDataSchema.TABLES.add(deviceSchema.getTable()); } deviceIndex++; diff --git a/core/src/main/java/cn/edu/tsinghua/iot/benchmark/schema/schemaImpl/GenerateMetaDataSchema.java b/core/src/main/java/cn/edu/tsinghua/iot/benchmark/schema/schemaImpl/GenerateMetaDataSchema.java index f9fed8b9f..c5b7091ec 100644 --- a/core/src/main/java/cn/edu/tsinghua/iot/benchmark/schema/schemaImpl/GenerateMetaDataSchema.java +++ b/core/src/main/java/cn/edu/tsinghua/iot/benchmark/schema/schemaImpl/GenerateMetaDataSchema.java @@ -48,7 +48,12 @@ public boolean createMetaDataSchema() { true); // dataClient MetaUtil.distributeDevices( - config.getDATA_CLIENT_NUMBER(), DATA_CLIENT_DATA_SCHEMA, sensors, NAME_DATA_SCHEMA, GROUPS, false); + config.getDATA_CLIENT_NUMBER(), + DATA_CLIENT_DATA_SCHEMA, + sensors, + NAME_DATA_SCHEMA, + GROUPS, + false); return true; } }