Skip to content

Commit 70ae1ac

Browse files
authored
Update last cache in load (#15604)
* add load update last cache strategies * add cacheLastValuesForLoad * add cache last values for load * add memory control when caching last values * fix * fix UPDATE_NO_BLOB does not take effect * fix comments * spotless * ignore perf test
1 parent 5a42c2e commit 70ae1ac

22 files changed

Lines changed: 1118 additions & 106 deletions

File tree

integration-test/src/main/java/org/apache/iotdb/it/env/cluster/config/MppDataNodeConfig.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -107,4 +107,16 @@ public DataNodeConfig setMqttPayloadFormatter(String mqttPayloadFormatter) {
107107
setProperty("mqtt_payload_formatter", String.valueOf(mqttPayloadFormatter));
108108
return this;
109109
}
110+
111+
@Override
112+
public DataNodeConfig setLoadLastCacheStrategy(String strategyName) {
113+
setProperty("last_cache_operation_on_load", strategyName);
114+
return this;
115+
}
116+
117+
@Override
118+
public DataNodeConfig setCacheLastValuesForLoad(boolean cacheLastValuesForLoad) {
119+
setProperty("cache_last_values_for_load", String.valueOf(cacheLastValuesForLoad));
120+
return this;
121+
}
110122
}

integration-test/src/main/java/org/apache/iotdb/it/env/remote/config/RemoteDataNodeConfig.java

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -68,4 +68,14 @@ public DataNodeConfig setEnableMQTTService(boolean enableMQTTService) {
6868
public DataNodeConfig setMqttPayloadFormatter(String mqttPayloadFormatter) {
6969
return this;
7070
}
71+
72+
@Override
73+
public DataNodeConfig setLoadLastCacheStrategy(String strategyName) {
74+
return this;
75+
}
76+
77+
@Override
78+
public DataNodeConfig setCacheLastValuesForLoad(boolean cacheLastValuesForLoad) {
79+
return this;
80+
}
7181
}

integration-test/src/main/java/org/apache/iotdb/itbase/env/DataNodeConfig.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -41,4 +41,8 @@ DataNodeConfig setLoadTsFileAnalyzeSchemaMemorySizeInBytes(
4141
DataNodeConfig setEnableMQTTService(boolean enableMQTTService);
4242

4343
DataNodeConfig setMqttPayloadFormatter(String mqttPayloadFormatter);
44+
45+
DataNodeConfig setLoadLastCacheStrategy(String strategyName);
46+
47+
DataNodeConfig setCacheLastValuesForLoad(boolean cacheLastValuesForLoad);
4448
}

0 commit comments

Comments
 (0)